Examples of ManagedBroker

com.caucho.bam.broker.ManagedBroker
Broker is the hub which routes messages to mailboxes.
org.apache.qpid.management.common.mbeans.ManagedBroker
The ManagedBroker is the management interface to expose management features of the Broker. @version Qpid JMX API 2.1 @since Qpid JMX API 1.3
org.apache.qpid.server.management.ManagedBroker
The ManagedBroker is the management interface to expose management features of the Broker. @author Bhupendra Bhardwaj @version 0.1

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

     * @throws MBeanException if there is another problem creating the exchange
     */
    public void deleteQueue(String virtualHostName, String queueName)
            throws IOException, JMException, MBeanException
    {
        ManagedBroker managedBroker = getManagedBroker(virtualHostName);
        managedBroker.deleteQueue(queueName);
    }

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

        //Remove any previous queue declares
        _monitor.markDiscardPoint();


        _jmxUtils.createQueue("test", getName(), null, false);


        ManagedBroker managedBroker = _jmxUtils.getManagedBroker("test");


        managedBroker.deleteQueue(getName());


        List<String> results = waitAndFindMatches("QUE-1002");


        assertEquals("More than one queue deletion found", 1, results.size());

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

        //Remove any previous queue declares
        _monitor.markDiscardPoint();


        _jmxUtils.createExchange("test", getName(), "direct", false);


        ManagedBroker managedBroker = _jmxUtils.getManagedBroker("test");


        managedBroker.unregisterExchange(getName());


        List<String> results = waitAndFindMatches("EXH-1002");


        assertEquals("More than one exchange deletion found", 1, results.size());

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker


        createViaAMQPandValidateViaJMX(connection, queueName, durable,
                                       autoDelete, exclusive);


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

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker


        createViaAMQPandValidateViaJMX(connection, queueName, durable,
                                       autoDelete, exclusive);


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

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

        boolean durable = true;


        createViaJMXandValidateViaJMX(name, owner, durable);


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

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

    {
        String name = getName();


        _jmxUtils.createQueue(VIRTUALHOST_NAME, name, null, false);


        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

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

    {
        String name = getName();


        _jmxUtils.createQueue(VIRTUALHOST_NAME, name, null, true);


        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

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

        assertEquals(dataReceived, managedConnection.getTotalDataDelivered());
    }


    private void checkVHostStatistics(String vHostName, long messagesSent, long messagesReceived, long dataSent, long dataReceived)
    {
        ManagedBroker vhost = _jmxUtils.getManagedBroker(vHostName);


        assertEquals(messagesSent, vhost.getTotalMessagesReceived());
        assertEquals(messagesReceived, vhost.getTotalMessagesDelivered());


        assertEquals(dataSent, vhost.getTotalDataReceived());
        assertEquals(dataReceived, vhost.getTotalDataDelivered());
    }

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedBroker

     * that the attribute is exposed correctly through {@link ManagedQueue#getMaximumDeliveryCount()}.
     */
    public void testCreateQueueWithMaximumDeliveryCountSet() throws Exception
    {
        final String queueName = getName();
        final ManagedBroker managedBroker = _jmxUtils.getManagedBroker(VIRTUAL_HOST);


        final Integer deliveryCount = 1;
        final Map<String, Object> arguments = Collections.singletonMap(AMQQueueFactory.X_QPID_MAXIMUM_DELIVERY_COUNT, (Object)deliveryCount);
        managedBroker.createNewQueue(queueName, null, true, arguments);


        // Ensure the queue exists
        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName("test", queueName));
        assertNotNull("Manager queue expected to be available", _jmxUtils.getManagedQueue(queueName));

View Full Code Here

0 1 2 3 4 5

TOP

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.