User: hiram
Date: 00/12/27 09:02:27
Modified: examples DurableSubscriberExample.java
Log:
Feature Add: Durable Topic Subscriptions now work!
More work still has to be done with user managment (who
is allowed to create durable subscriptions). The DurableSubscriptionExample
class now works.
Revision Changes Path
1.2 +260 -262 spyderMQ/examples/DurableSubscriberExample.java
Index: DurableSubscriberExample.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/examples/DurableSubscriberExample.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- DurableSubscriberExample.java 2000/12/12 21:30:45 1.1
+++ DurableSubscriberExample.java 2000/12/27 17:02:27 1.2
@@ -50,267 +50,265 @@
* @version 1.6, 08/18/00
*/
public class DurableSubscriberExample {
- String topicName = null;
- int exitResult = 0;
- static int startindex = 0;
-
- /**
- * The DurableSubscriber class contains a constructor, a startSubscriber
- * method, a closeSubscriber method, and a finish method.
- * <p>
- * The class fetches messages asynchronously, using a message listener,
- * TextListener.
- *
- * @author Kim Haase
- * @version 1.6, 08/18/00
- */
- public class DurableSubscriber {
- TopicConnection topicConnection = null;
- TopicSession topicSession = null;
- Topic topic = null;
- TopicSubscriber topicSubscriber = null;
- TextListener topicListener = null;
-
- /**
- * The TextListener class implements the MessageListener interface by
- * defining an onMessage method for the DurableSubscriber class.
- *
- * @author Kim Haase
- * @version 1.6, 08/18/00
- */
- private class TextListener implements MessageListener {
- final SampleUtilities.DoneLatch monitor =
- new SampleUtilities.DoneLatch();
-
- /**
- * Casts the message to a TextMessage and displays its text.
- * A non-text message is interpreted as the end of the message
- * stream, and the message listener sets its monitor state to all
- * done processing messages.
- *
- * @param message the incoming message
- */
- public void onMessage(Message message) {
- if (message instanceof TextMessage) {
- TextMessage msg = (TextMessage) message;
-
- try {
- System.out.println("SUBSCRIBER: Reading message: "
- + msg.getText());
- } catch (JMSException e) {
- System.out.println("Exception in onMessage(): "
- + e.toString());
- }
- } else {
- monitor.allDone();
- }
- }
- }
-
- /**
- * Constructor: looks up a connection factory and topic and creates a
- * connection and session.
- */
- public DurableSubscriber() {
- TopicConnectionFactory topicConnectionFactory = null;
-
- try {
- topicConnectionFactory =
- SampleUtilities.getTopicConnectionFactory();
- topicConnection =
- topicConnectionFactory.createTopicConnection();
- topicConnection.setClientID("DurableSubscriberExample");
- topicSession = topicConnection.createTopicSession(false,
- Session.AUTO_ACKNOWLEDGE);
- topic = SampleUtilities.getTopic(topicName, topicSession);
- } catch (Exception e) {
- System.out.println("Connection problem: " + e.toString());
- if (topicConnection != null) {
- try {
- topicConnection.close();
- } catch (JMSException ee) {}
- }
- System.exit(1);
- }
- }
-
- /**
- * Stops connection, then creates durable subscriber, registers message
- * listener (TextListener), and starts message delivery; listener
- * displays the messages obtained.
- */
- public void startSubscriber() {
- try {
- System.out.println("Starting subscriber");
- topicConnection.stop();
- topicSubscriber = topicSession.createDurableSubscriber(topic,
- "MakeItLast");
- topicListener = new TextListener();
- topicSubscriber.setMessageListener(topicListener);
- topicConnection.start();
- } catch (JMSException e) {
- System.out.println("Exception occurred: " + e.toString());
- exitResult = 1;
- }
- }
-
- /**
- * Blocks until publisher issues a control message indicating
- * end of publish stream, then closes subscriber.
- */
- public void closeSubscriber() {
- try {
- topicListener.monitor.waitTillDone();
- System.out.println("Closing subscriber");
- topicSubscriber.close();
- } catch (JMSException e) {
- System.out.println("Exception occurred: " + e.toString());
- exitResult = 1;
- }
- }
-
- /**
- * Closes the connection.
- */
- public void finish() {
- if (topicConnection != null) {
- try {
- topicSession.unsubscribe("MakeItLast");
- topicConnection.close();
- } catch (JMSException e) {
- exitResult = 1;
- }
- }
- }
- }
-
- /**
- * The MultiplePublisher class publishes several messages to a topic. It
- * contains a constructor, a publishMessages method, and a finish method.
- *
- * @author Kim Haase
- * @version 1.6, 08/18/00
- */
- public class MultiplePublisher {
- TopicConnection topicConnection = null;
- TopicSession topicSession = null;
- Topic topic = null;
- TopicPublisher topicPublisher = null;
-
- /**
- * Constructor: looks up a connection factory and topic and creates a
- * connection and session. Also creates the publisher.
- */
- public MultiplePublisher() {
- TopicConnectionFactory topicConnectionFactory = null;
-
- try {
- topicConnectionFactory =
- SampleUtilities.getTopicConnectionFactory();
- topicConnection =
- topicConnectionFactory.createTopicConnection();
- topicSession = topicConnection.createTopicSession(false,
- Session.AUTO_ACKNOWLEDGE);
- topic = SampleUtilities.getTopic(topicName, topicSession);
- topicPublisher = topicSession.createPublisher(topic);
- } catch (Exception e) {
- System.out.println("Connection problem: " + e.toString());
- if (topicConnection != null) {
- try {
- topicConnection.close();
- } catch (JMSException ee) {}
- }
- System.exit(1);
- }
- }
-
- /**
- * Creates text message.
- * Sends some messages, varying text slightly.
- * Messages must be persistent.
- */
- public void publishMessages() {
- TextMessage message = null;
- int i;
- final int NUMMSGS = 3;
- final String MSG_TEXT = new String("Here is a message");
-
- try {
- message = topicSession.createTextMessage();
- for (i = startindex; i < startindex + NUMMSGS; i++) {
- message.setText(MSG_TEXT + " " + (i + 1));
- System.out.println("PUBLISHER: Publishing message: "
- + message.getText());
- topicPublisher.publish(message);
- }
-
- // Send a non-text control message indicating end of messages.
- topicPublisher.publish(topicSession.createMessage());
- startindex = i;
- } catch (JMSException e) {
- System.out.println("Exception occurred: " + e.toString());
- exitResult = 1;
- }
- }
-
- /**
- * Closes the connection.
- */
- public void finish() {
- if (topicConnection != null) {
- try {
- topicConnection.close();
- } catch (JMSException e) {
- exitResult = 1;
- }
- }
- }
- }
+ String topicName = null;
+ int exitResult = 0;
+ static int startindex = 0;
+
+ /**
+ * The DurableSubscriber class contains a constructor, a startSubscriber
+ * method, a closeSubscriber method, and a finish method.
+ * <p>
+ * The class fetches messages asynchronously, using a message listener,
+ * TextListener.
+ *
+ * @author Kim Haase
+ * @version 1.6, 08/18/00
+ */
+ public class DurableSubscriber {
+ TopicConnection topicConnection = null;
+ TopicSession topicSession = null;
+ Topic topic = null;
+ TopicSubscriber topicSubscriber = null;
+ TextListener topicListener = null;
+
+ /**
+ * The TextListener class implements the MessageListener interface by
+ * defining an onMessage method for the DurableSubscriber class.
+ *
+ * @author Kim Haase
+ * @version 1.6, 08/18/00
+ */
+ private class TextListener implements MessageListener {
+ final SampleUtilities.DoneLatch monitor =
+ new SampleUtilities.DoneLatch();
+
+ /**
+ * Casts the message to a TextMessage and displays its text.
+ * A non-text message is interpreted as the end of the message
+ * stream, and the message listener sets its monitor state to
all
+ * done processing messages.
+ *
+ * @param message the incoming message
+ */
+ public void onMessage(Message message) {
+ if (message instanceof TextMessage) {
+ TextMessage msg = (TextMessage) message;
+
+ try {
+ System.out.println("SUBSCRIBER:
Reading message: "
+ +
msg.getText());
+ } catch (JMSException e) {
+ System.out.println("Exception in
onMessage(): "
+ +
e.toString());
+ }
+ } else {
+ monitor.allDone();
+ }
+ }
+ }
+
+ /**
+ * Constructor: looks up a connection factory and topic and creates a
+ * connection and session.
+ */
+ public DurableSubscriber() {
+ TopicConnectionFactory topicConnectionFactory = null;
+
+ try {
+ topicConnectionFactory =
+ SampleUtilities.getTopicConnectionFactory();
+ topicConnection =
+
topicConnectionFactory.createTopicConnection("john", "needle");
+ topicSession =
topicConnection.createTopicSession(false,
+ Session.AUTO_ACKNOWLEDGE);
+ topic = SampleUtilities.getTopic(topicName,
topicSession);
+ } catch (Exception e) {
+ System.out.println("Connection problem: " +
e.toString());
+ if (topicConnection != null) {
+ try {
+ topicConnection.close();
+ } catch (JMSException ee) {}
+ }
+ System.exit(1);
+ }
+ }
+
+ /**
+ * Stops connection, then creates durable subscriber, registers
message
+ * listener (TextListener), and starts message delivery; listener
+ * displays the messages obtained.
+ */
+ public void startSubscriber() {
+ try {
+ System.out.println("Starting subscriber");
+ topicConnection.stop();
+ topicSubscriber =
topicSession.createDurableSubscriber(topic,
+ "MakeItLast");
+ topicListener = new TextListener();
+ topicSubscriber.setMessageListener(topicListener);
+ topicConnection.start();
+ } catch (JMSException e) {
+ System.out.println("Exception occurred: " +
e.toString());
+ exitResult = 1;
+ }
+ }
+
+ /**
+ * Blocks until publisher issues a control message indicating
+ * end of publish stream, then closes subscriber.
+ */
+ public void closeSubscriber() {
+ try {
+ topicListener.monitor.waitTillDone();
+ System.out.println("Closing subscriber");
+ topicSubscriber.close();
+ } catch (JMSException e) {
+ System.out.println("Exception occurred: " +
e.toString());
+ exitResult = 1;
+ }
+ }
+
+ /**
+ * Closes the connection.
+ */
+ public void finish() {
+ if (topicConnection != null) {
+ try {
+ topicSession.unsubscribe("MakeItLast");
+ topicConnection.close();
+ } catch (JMSException e) {
+ exitResult = 1;
+ }
+ }
+ }
+ }
+
+ /**
+ * The MultiplePublisher class publishes several messages to a topic. It
+ * contains a constructor, a publishMessages method, and a finish method.
+ *
+ * @author Kim Haase
+ * @version 1.6, 08/18/00
+ */
+ public class MultiplePublisher {
+ TopicConnection topicConnection = null;
+ TopicSession topicSession = null;
+ Topic topic = null;
+ TopicPublisher topicPublisher = null;
+
+ /**
+ * Constructor: looks up a connection factory and topic and creates a
+ * connection and session. Also creates the publisher.
+ */
+ public MultiplePublisher() {
+ TopicConnectionFactory topicConnectionFactory = null;
+
+ try {
+ topicConnectionFactory =
+ SampleUtilities.getTopicConnectionFactory();
+ topicConnection =
+ topicConnectionFactory.createTopicConnection();
+ topicSession =
topicConnection.createTopicSession(false,
+ Session.AUTO_ACKNOWLEDGE);
+ topic = SampleUtilities.getTopic(topicName,
topicSession);
+ topicPublisher = topicSession.createPublisher(topic);
+ } catch (Exception e) {
+ System.out.println("Connection problem: " +
e.toString());
+ if (topicConnection != null) {
+ try {
+ topicConnection.close();
+ } catch (JMSException ee) {}
+ }
+ System.exit(1);
+ }
+ }
+
+ /**
+ * Creates text message.
+ * Sends some messages, varying text slightly.
+ * Messages must be persistent.
+ */
+ public void publishMessages() {
+ TextMessage message = null;
+ int i;
+ final int NUMMSGS = 3;
+ final String MSG_TEXT = new String("Here is a message");
+
+ try {
+ message = topicSession.createTextMessage();
+ for (i = startindex; i < startindex + NUMMSGS; i++) {
+ message.setText(MSG_TEXT + " " + (i + 1));
+ System.out.println("PUBLISHER: Publishing
message: "
+ + message.getText());
+ topicPublisher.publish(message);
+ }
+
+ // Send a non-text control message indicating end of
messages.
+ topicPublisher.publish(topicSession.createMessage());
+ startindex = i;
+ } catch (JMSException e) {
+ System.out.println("Exception occurred: " +
e.toString());
+ exitResult = 1;
+ }
+ }
+
+ /**
+ * Closes the connection.
+ */
+ public void finish() {
+ if (topicConnection != null) {
+ try {
+ topicConnection.close();
+ } catch (JMSException e) {
+ exitResult = 1;
+ }
+ }
+ }
+ }
- /**
- * Instantiates the subscriber and publisher classes.
- *
- * Starts the subscriber; the publisher publishes some messages.
- *
- * Closes the subscriber; while it is closed, the publisher publishes
- * some more messages.
- *
- * Restarts the subscriber and fetches the messages.
- *
- * Finally, closes the connections.
- */
- public void run_program() {
- DurableSubscriber durableSubscriber = new DurableSubscriber();
- MultiplePublisher multiplePublisher = new MultiplePublisher();
-
- durableSubscriber.startSubscriber();
- multiplePublisher.publishMessages();
- durableSubscriber.closeSubscriber();
- multiplePublisher.publishMessages();
- durableSubscriber.startSubscriber();
- durableSubscriber.closeSubscriber();
- multiplePublisher.finish();
- durableSubscriber.finish();
- }
-
- /**
- * Reads the topic name from the command line, then calls the
- * run_program method.
- *
- * @param args the topic used by the example
- */
- public static void main(String[] args) {
- DurableSubscriberExample dse = new DurableSubscriberExample();
-
- if (args.length != 1) {
- System.out.println("Usage: java DurableSubscriberExample <topic_name>");
- System.exit(1);
- }
- dse.topicName = new String(args[0]);
- System.out.println("Topic name is " + dse.topicName);
-
- dse.run_program();
- SampleUtilities.exit(dse.exitResult);
- }
+ /**
+ * Instantiates the subscriber and publisher classes.
+ *
+ * Starts the subscriber; the publisher publishes some messages.
+ *
+ * Closes the subscriber; while it is closed, the publisher publishes
+ * some more messages.
+ *
+ * Restarts the subscriber and fetches the messages.
+ *
+ * Finally, closes the connections.
+ */
+ public void run_program() {
+ DurableSubscriber durableSubscriber = new DurableSubscriber();
+ MultiplePublisher multiplePublisher = new MultiplePublisher();
+
+ durableSubscriber.startSubscriber();
+ multiplePublisher.publishMessages();
+ durableSubscriber.closeSubscriber();
+ multiplePublisher.publishMessages();
+ durableSubscriber.startSubscriber();
+ durableSubscriber.closeSubscriber();
+ multiplePublisher.finish();
+ durableSubscriber.finish();
+ }
+
+ /**
+ * Reads the topic name from the command line, then calls the
+ * run_program method.
+ *
+ * @param args the topic used by the example
+ */
+ public static void main(String[] args) {
+ DurableSubscriberExample dse = new DurableSubscriberExample();
+
+ if (args.length != 1) {
+ System.out.println("Usage: java DurableSubscriberExample
<topic_name>");
+ System.exit(1);
+ }
+ dse.topicName = new String(args[0]);
+ System.out.println("Topic name is " + dse.topicName);
+
+ dse.run_program();
+ SampleUtilities.exit(dse.exitResult);
+ }
}
-
