From ca8e0ae1c7f635eff690561d6c4dc5cc6ec62fb2 Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Fri, 18 Jan 2008 09:29:26 +0000 Subject: Qpid 742 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@613114 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/AMQTopicSubscriber.java | 11 ----------- .../java/org/apache/qpid/client/TopicSubscriberAdaptor.java | 4 ++-- .../src/main/java/org/apache/qpid/jms/TopicSubscriber.java | 11 +++++++++++ 3 files changed, 13 insertions(+), 13 deletions(-) delete mode 100644 java/client/src/main/java/org/apache/qpid/client/AMQTopicSubscriber.java create mode 100644 java/client/src/main/java/org/apache/qpid/jms/TopicSubscriber.java (limited to 'java/client/src/main') diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQTopicSubscriber.java b/java/client/src/main/java/org/apache/qpid/client/AMQTopicSubscriber.java deleted file mode 100644 index 97e2898de4..0000000000 --- a/java/client/src/main/java/org/apache/qpid/client/AMQTopicSubscriber.java +++ /dev/null @@ -1,11 +0,0 @@ -package org.apache.qpid.client; - -import org.apache.qpid.AMQException; - -import javax.jms.Topic; - -public interface AMQTopicSubscriber -{ - - void addBindingKey(Topic topic, String bindingKey) throws AMQException; -} diff --git a/java/client/src/main/java/org/apache/qpid/client/TopicSubscriberAdaptor.java b/java/client/src/main/java/org/apache/qpid/client/TopicSubscriberAdaptor.java index 507490d6fb..dd8ca8e197 100644 --- a/java/client/src/main/java/org/apache/qpid/client/TopicSubscriberAdaptor.java +++ b/java/client/src/main/java/org/apache/qpid/client/TopicSubscriberAdaptor.java @@ -21,18 +21,18 @@ package org.apache.qpid.client; import org.apache.qpid.AMQException; +import org.apache.qpid.jms.TopicSubscriber; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.Topic; -import javax.jms.TopicSubscriber; /** * Wraps a MessageConsumer to fulfill the extended TopicSubscriber contract * */ -class TopicSubscriberAdaptor implements TopicSubscriber, AMQTopicSubscriber +class TopicSubscriberAdaptor implements org.apache.qpid.jms.TopicSubscriber { private final Topic _topic; private final BasicMessageConsumer _consumer; diff --git a/java/client/src/main/java/org/apache/qpid/jms/TopicSubscriber.java b/java/client/src/main/java/org/apache/qpid/jms/TopicSubscriber.java new file mode 100644 index 0000000000..80cfa18ec1 --- /dev/null +++ b/java/client/src/main/java/org/apache/qpid/jms/TopicSubscriber.java @@ -0,0 +1,11 @@ +package org.apache.qpid.jms; + +import org.apache.qpid.AMQException; + +import javax.jms.Topic; + +public interface TopicSubscriber extends javax.jms.TopicSubscriber +{ + + void addBindingKey(Topic topic, String bindingKey) throws AMQException; +} -- cgit v1.2.1