diff options
Diffstat (limited to 'java/client/src/test/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java')
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java | 26 |
1 files changed, 14 insertions, 12 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java b/java/client/src/test/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java index 6b03dd32e8..11a39df10f 100644 --- a/java/client/src/test/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java +++ b/java/client/src/test/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java @@ -20,24 +20,26 @@ */ package org.apache.qpid.client; -import junit.framework.TestCase; -import org.apache.log4j.Logger; -import org.apache.qpid.client.transport.TransportConnection; -import org.apache.qpid.jndi.PropertiesFileInitialContextFactory; +import java.util.Hashtable; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.TimeUnit; import javax.jms.Connection; -import javax.jms.Session; -import javax.jms.MessageProducer; -import javax.jms.Queue; +import javax.jms.ConnectionFactory; +import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageListener; -import javax.jms.Message; -import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; import javax.naming.Context; import javax.naming.spi.InitialContextFactory; -import java.util.Hashtable; -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.TimeUnit; + +import junit.framework.TestCase; + +import org.apache.log4j.Logger; +import org.apache.qpid.client.transport.TransportConnection; +import org.apache.qpid.jndi.PropertiesFileInitialContextFactory; /** * QPID-293 Setting MessageListener after connection has started can cause messages to be "lost" on a internal delivery queue |