Package org.apache.qpid.management.common.mbeans

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker.deleteQueue()

117
118
119
120
121
122
123
124
125
126
127
            if (set.size() > 0) {
                ManagedBroker amqBrokerManagerMBean =
                        MBeanServerInvocationHandler.newProxyInstance(mBeanServer,
                                                                      (ObjectName) set.toArray()[0],
                                                                      ManagedBroker.class, false);
                amqBrokerManagerMBean.deleteQueue(queue);
            }

        } catch (MalformedObjectNameException e) {
            throw new MessageBoxException(e);
        } catch (InstanceNotFoundException e) {
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
    public void deleteQueue(String virtualHostName, String queueName)
            throws IOException, JMException, MBeanException
    {
        ManagedBroker managedBroker = getManagedBroker(virtualHostName);

        managedBroker.deleteQueue(queueName);
    }
   
    /**
   * Sets the logging level.
     *
 
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
                                       autoDelete, exclusive);

        // Clean up
        ManagedBroker managedBroker =
                _jmxUtils.getManagedBroker(VIRTUALHOST_NAME);
        managedBroker.deleteQueue(queueName);
    }

    /**
     * Test that a durable queue can be created via AMQP.
     *
 
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
                                       autoDelete, exclusive);

        // Clean up
        ManagedBroker managedBroker =
                _jmxUtils.getManagedBroker(VIRTUALHOST_NAME);
        managedBroker.deleteQueue(queueName);
    }


    /**
     * Test that a transient queue can be created via JMX.
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
        createViaJMXandValidateViaJMX(name, owner, durable);

        // Clean up
        ManagedBroker managedBroker =
                _jmxUtils.getManagedBroker(VIRTUALHOST_NAME);
        managedBroker.deleteQueue(name);
    }

    /**
     * Test that a transient queue can be deleted via JMX.
     *
 
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
        ManagedBroker managedBroker = _jmxUtils.
                getManagedBroker(VIRTUALHOST_NAME);

        try
        {
            managedBroker.deleteQueue(name);
        }
        catch (UndeclaredThrowableException e)
        {
            fail(((MBeanException) ((InvocationTargetException)
                    e.getUndeclaredThrowable()).getTargetException()).getTargetException().getMessage());
View Full Code Here
247
248
249
250
251
252
253
254
255
256
257
        ManagedBroker managedBroker = _jmxUtils.
                getManagedBroker(VIRTUALHOST_NAME);

        try
        {
            managedBroker.deleteQueue(name);
        }
        catch (UndeclaredThrowableException e)
        {
            fail(((MBeanException) ((InvocationTargetException)
                    e.getUndeclaredThrowable()).getTargetException()).getTargetException().getMessage());
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
    public void deleteQueue(String virtualHostName, String queueName)
            throws IOException, JMException, MBeanException
    {
        ManagedBroker managedBroker = getManagedBroker(virtualHostName);

        managedBroker.deleteQueue(queueName);
    }
   
    /**
   * Sets the logging level.
     *
 
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
                                       autoDelete, exclusive);

        // Clean up
        ManagedBroker managedBroker =
                _jmxUtils.getManagedBroker(VIRTUALHOST_NAME);
        managedBroker.deleteQueue(queueName);
    }

    /**
     * Test that a durable queue can be created via AMQP.
     *
 
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
                                       autoDelete, exclusive);

        // Clean up
        ManagedBroker managedBroker =
                _jmxUtils.getManagedBroker(VIRTUALHOST_NAME);
        managedBroker.deleteQueue(queueName);
    }


    /**
     * Test that a transient queue can be created via JMX.
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.