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

tidy up test

This commit is contained in:
gtully 2016-05-09 12:51:28 +01:00
parent 9fc2661049
commit 1a8e17fbc3
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/SelectorAwareVTThatDropsMessagesWhenNoConsumer.java
View File

@ -45,7 +45,7 @@ import static org.junit.Assert.assertEquals;
public class SelectorAwareVTThatDropsMessagesWhenNoConsumer { public class SelectorAwareVTThatDropsMessagesWhenNoConsumer {
protected static final Logger LOG = LoggerFactory.getLogger(SelectorAwareVTThatDropsMessagesWhenNoConsumer.class); protected static final Logger LOG = LoggerFactory.getLogger(SelectorAwareVTThatDropsMessagesWhenNoConsumer.class);
private static final String QUEUE_NAME="AMQ4899TestQueue"; private static final String QUEUE_NAME="TestQ";
private static final String CONSUMER_QUEUE="Consumer.Orders.VirtualOrders." + QUEUE_NAME; private static final String CONSUMER_QUEUE="Consumer.Orders.VirtualOrders." + QUEUE_NAME;
private static final String PRODUCER_DESTINATION_NAME = "VirtualOrders." + QUEUE_NAME; private static final String PRODUCER_DESTINATION_NAME = "VirtualOrders." + QUEUE_NAME;
@ -67,7 +67,7 @@ public class SelectorAwareVTThatDropsMessagesWhenNoConsumer {
} }
@Test(timeout = 60 * 1000) @Test(timeout = 60 * 1000)
public void testVirtualTopicMultipleSelectors() throws Exception{ public void verifyNoDispatchDuringDisconnect() throws Exception{
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost"); ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
Connection connection = factory.createConnection(); Connection connection = factory.createConnection();
connection.start(); connection.start();