Author: arnaudsimon
Date: Fri Jan 18 05:17:46 2008
New Revision: 613155
URL: http://svn.apache.org/viewvc?rev=613155&view=rev
Log:
Added warning
Modified:
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
Modified:
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java?rev=613155&r1=613154&r2=613155&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
Fri Jan 18 05:17:46 2008
@@ -101,8 +101,13 @@
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 @@
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 @@
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 @@
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"));
