diff options
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java')
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java | 24 |
1 files changed, 22 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java b/java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java index 34ef23747c..f44f8414fa 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java @@ -20,10 +20,30 @@ */ package org.apache.qpid.client; -import javax.jms.*; -import javax.jms.IllegalStateException; import java.io.Serializable; +import javax.jms.BytesMessage; +import javax.jms.Destination; +import javax.jms.IllegalStateException; +import javax.jms.JMSException; +import javax.jms.MapMessage; +import javax.jms.Message; +import javax.jms.MessageConsumer; +import javax.jms.MessageListener; +import javax.jms.MessageProducer; +import javax.jms.ObjectMessage; +import javax.jms.Queue; +import javax.jms.QueueBrowser; +import javax.jms.Session; +import javax.jms.StreamMessage; +import javax.jms.TemporaryQueue; +import javax.jms.TemporaryTopic; +import javax.jms.TextMessage; +import javax.jms.Topic; +import javax.jms.TopicPublisher; +import javax.jms.TopicSession; +import javax.jms.TopicSubscriber; + public class AMQTopicSessionAdaptor implements TopicSession, AMQSessionAdapter { protected final AMQSession _session; |