Added warning

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@613155 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 29 insertions, 9 deletions

diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
index 8098f62be9..c8e5d89099 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
@@ -101,8 +101,13 @@ public class Listener
             javax.jms.TopicSubscriber messageSubscriber=session.createSubscriber(topic);
 
             // Bind each topic queue to the control queue so we know when to stop
-            // Warning: this is  an AMQP specific code
-            ((TopicSubscriber) messageSubscriber).addBindingKey( topic, "control");
+            /**
+             * The following line uses a temporary, experimental
+             * Qpid extension to add another binding to the topic's private queue.
+             * This extension is expected to be replaced by an alternative,
+             * less intrusive scheme in the very near future.
+             */
+            ((TopicSubscriber) messageSubscriber).addBindingKey(topic, "control");
 
             // Set a message listener on the messageConsumer
             messageSubscriber.setMessageListener(new MyMessageListener("usa"));
@@ -114,8 +119,13 @@ public class Listener
             messageSubscriber=session.createSubscriber(topic);
 
             // Bind each topic queue to the control queue so we know when to stop
-            // Warning: this is  an AMQP specific code
-            ((org.apache.qpid.jms.TopicSubscriber) messageSubscriber).addBindingKey( topic, "control");
+            /**
+             * The following line uses a temporary, experimental
+             * Qpid extension to add another binding to the topic's private queue.
+             * This extension is expected to be replaced by an alternative,
+             * less intrusive scheme in the very near future.
+             */
+            ((org.apache.qpid.jms.TopicSubscriber) messageSubscriber).addBindingKey(topic, "control");
 
             // Set a message listener on the messageConsumer
             messageSubscriber.setMessageListener(new MyMessageListener("europe"));
@@ -127,8 +137,13 @@ public class Listener
             messageSubscriber=session.createSubscriber(topic);
 
             // Bind each topic queue to the control queue so we know when to stop
-            // Warning: this is  an AMQP specific code
-            ((org.apache.qpid.jms.TopicSubscriber) messageSubscriber).addBindingKey( topic, "control");
+            /**
+             * The following line uses a temporary, experimental
+             * Qpid extension to add another binding to the topic's private queue.
+             * This extension is expected to be replaced by an alternative,
+             * less intrusive scheme in the very near future.
+             */
+            ((org.apache.qpid.jms.TopicSubscriber) messageSubscriber).addBindingKey(topic, "control");
 
             // Set a message listener on the messageConsumer
             messageSubscriber.setMessageListener(new MyMessageListener("news"));
@@ -140,9 +155,14 @@ public class Listener
             messageSubscriber=session.createSubscriber(topic);
 
             // Bind each topic queue to the control queue so we know when to stop
-            // Warning: this is  an AMQP specific code
-            ((org.apache.qpid.jms.TopicSubscriber) messageSubscriber).addBindingKey( topic, "control");
-          
+            /**
+             * The following line uses a temporary, experimental
+             * Qpid extension to add another binding to the topic's private queue.
+             * This extension is expected to be replaced by an alternative,
+             * less intrusive scheme in the very near future.
+             */
+            ((org.apache.qpid.jms.TopicSubscriber) messageSubscriber).addBindingKey(topic, "control");
+
             // Set a message listener on the messageConsumer
             messageSubscriber.setMessageListener(new MyMessageListener("weather"));