From ee868d743079b6183dd1efdeae54443504bb37d2 Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Fri, 18 Jan 2008 13:17:46 +0000 Subject: Added warning git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@613155 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/example/jmsexample/pubsub/Listener.java | 38 +++++++++++++++++----- 1 file changed, 29 insertions(+), 9 deletions(-) (limited to 'qpid/java/client/example') diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java index 8098f62be9..c8e5d89099 100644 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java +++ b/qpid/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")); -- cgit v1.2.1