Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-989 fixing test after cherry-picking

This commit is contained in:
Clebert Suconic 2017-02-23 17:03:31 -05:00
parent 2b18db6a1c
commit 20d627f2b7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/consumer/ConsumerTest.java
View File

@ -187,7 +187,7 @@ public class ConsumerTest extends JMSTestBase {
@Test @Test
public void testIndividualACKJms2() throws Exception { public void testIndividualACKJms2() throws Exception {
JMSContext context = cf.createContext(ActiveMQJMSConstants.INDIVIDUAL_ACKNOWLEDGE); JMSContext context = cf.createContext(ActiveMQJMSConstants.INDIVIDUAL_ACKNOWLEDGE);
jBossQueue = ActiveMQJMSClient.createQueue(JmsConsumerTest.Q_NAME); jBossQueue = ActiveMQJMSClient.createQueue(ConsumerTest.Q_NAME);
JMSProducer producer = context.createProducer(); JMSProducer producer = context.createProducer();
JMSConsumer consumer = context.createConsumer(jBossQueue); JMSConsumer consumer = context.createConsumer(jBossQueue);
int noOfMessages = 100; int noOfMessages = 100;
@ -224,8 +224,8 @@ public class ConsumerTest extends JMSTestBase {
Assert.assertEquals("m" + i, m.getText()); Assert.assertEquals("m" + i, m.getText());
} }
SimpleString queueName = new SimpleString(JmsConsumerTest.Q_NAME); SimpleString queueName = new SimpleString(ActiveMQDestination.JMS_QUEUE_ADDRESS_PREFIX + ConsumerTest.Q_NAME);
Assert.assertEquals(0, ((Queue) server.getPostOffice().getBinding(queueName).getBindable()).getDeliveringCount()); Assert.assertEquals(0, getMessageCount((Queue) server.getPostOffice().getBinding(queueName).getBindable()));
Assert.assertEquals(0, getMessageCount((Queue) server.getPostOffice().getBinding(queueName).getBindable())); Assert.assertEquals(0, getMessageCount((Queue) server.getPostOffice().getBinding(queueName).getBindable()));
context.close(); context.close();
} }