From 20d627f2b7b97cf50ab59df7f869ccea0376ac7c Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Thu, 23 Feb 2017 17:03:31 -0500 Subject: [PATCH] ARTEMIS-989 fixing test after cherry-picking --- .../tests/integration/jms/consumer/ConsumerTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/consumer/ConsumerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/consumer/ConsumerTest.java index 078be00697..42550e7c0b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/consumer/ConsumerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/consumer/ConsumerTest.java @@ -187,7 +187,7 @@ public class ConsumerTest extends JMSTestBase { @Test public void testIndividualACKJms2() throws Exception { JMSContext context = cf.createContext(ActiveMQJMSConstants.INDIVIDUAL_ACKNOWLEDGE); - jBossQueue = ActiveMQJMSClient.createQueue(JmsConsumerTest.Q_NAME); + jBossQueue = ActiveMQJMSClient.createQueue(ConsumerTest.Q_NAME); JMSProducer producer = context.createProducer(); JMSConsumer consumer = context.createConsumer(jBossQueue); int noOfMessages = 100; @@ -224,8 +224,8 @@ public class ConsumerTest extends JMSTestBase { Assert.assertEquals("m" + i, m.getText()); } - SimpleString queueName = new SimpleString(JmsConsumerTest.Q_NAME); - Assert.assertEquals(0, ((Queue) server.getPostOffice().getBinding(queueName).getBindable()).getDeliveringCount()); + SimpleString queueName = new SimpleString(ActiveMQDestination.JMS_QUEUE_ADDRESS_PREFIX + ConsumerTest.Q_NAME); + Assert.assertEquals(0, getMessageCount((Queue) server.getPostOffice().getBinding(queueName).getBindable())); Assert.assertEquals(0, getMessageCount((Queue) server.getPostOffice().getBinding(queueName).getBindable())); context.close(); }