Package org.apache.activemq.broker.jmx

Examples of org.apache.activemq.broker.jmx.QueueViewMBean.browse()

201
202
203
204
205
206
207
208
209
210
211
        LOG.info("Consumer Count :" + concount);
        long messcount = proxy.getQueueSize();
        LOG.info("current number of messages in the queue :" + messcount);

        // lets browse
        CompositeData[] compdatalist = proxy.browse();
        if (compdatalist.length == 0) {
            fail("There is no message in the queue:");
        }
        String[] messageIDs = new String[compdatalist.length];
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
        LOG.info("Browse again");

        messcount = proxy.getQueueSize();
        LOG.info("current number of messages in the queue :" + messcount);

        compdatalist = proxy.browse();
        if (compdatalist.length == 0) {
            fail("There is no message in the queue:");
        }
        messageIDs = new String[compdatalist.length];
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
    }

    @Test
    public void bytesMessagePreview() throws Exception {
        QueueViewMBean queue = getProxyToQueueViewMBean();
        assertEquals(extractText(queue.browse()[0]), extractText(queue.browse()[0]));
    }

    @Test
    public void testBrowseByteMessageFails() throws Exception {
        ActiveMQBytesMessage bm = new ActiveMQBytesMessage();
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
    }

    @Test
    public void bytesMessagePreview() throws Exception {
        QueueViewMBean queue = getProxyToQueueViewMBean();
        assertEquals(extractText(queue.browse()[0]), extractText(queue.browse()[0]));
    }

    @Test
    public void testBrowseByteMessageFails() throws Exception {
        ActiveMQBytesMessage bm = new ActiveMQBytesMessage();
View Full Code Here
515
516
517
518
519
520
521
522
523
524
525
        ObjectName queueObjectName = ObjectName.getInstance(amqDomain, params);

        ManagementContext mgmtCtx = broker.getManagementContext();
        QueueViewMBean queueView = (QueueViewMBean)mgmtCtx.newProxyInstance(queueObjectName, QueueViewMBean.class, true);

        Object[] messages = queueView.browse();

        LOG.info("+Browsed with JMX: " + messages.length);

        return messages;
    }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
    }

    @Test
    public void getMessage() throws Exception {
        final QueueViewMBean queueView = getProxyToQueueViewMBean();
        final CompositeData messages[] = queueView.browse();
        messageID = (String) messages[0].get("JMSMessageID");
        assertNotNull(messageID);
        assertNotNull(queueView.getMessage(messageID));
        LOG.debug("Attempting to remove message ID: " + messageID);
        queueView.removeMessage(messageID);
View Full Code Here
198
199
200
201
202
203
204
205
206
207
208
        LOG.info("Consumer Count :" + concount);
        long messcount = proxy.getQueueSize();
        LOG.info("current number of messages in the queue :" + messcount);

        // lets browse
        CompositeData[] compdatalist = proxy.browse();
        if (compdatalist.length == 0) {
            fail("There is no message in the queue:");
        }
        String[] messageIDs = new String[compdatalist.length];
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
        LOG.info("Browse again");

        messcount = proxy.getQueueSize();
        LOG.info("current number of messages in the queue :" + messcount);

        compdatalist = proxy.browse();
        if (compdatalist.length == 0) {
            fail("There is no message in the queue:");
        }
        messageIDs = new String[compdatalist.length];
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    }

    @Test
    public void bytesMessagePreview() throws Exception {
        QueueViewMBean queue = getProxyToQueueViewMBean();
        assertEquals(extractText(queue.browse()[0]), extractText(queue.browse()[0]));
    }

    @Test
    public void testBrowseByteMessageFails() throws Exception {
        ActiveMQBytesMessage bm = new ActiveMQBytesMessage();
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    }

    @Test
    public void bytesMessagePreview() throws Exception {
        QueueViewMBean queue = getProxyToQueueViewMBean();
        assertEquals(extractText(queue.browse()[0]), extractText(queue.browse()[0]));
    }

    @Test
    public void testBrowseByteMessageFails() throws Exception {
        ActiveMQBytesMessage bm = new ActiveMQBytesMessage();
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.