durabletopicclient.java

jboss 的官方实例程序

package org.jboss.book.jms.ex1;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSubscriber;
import javax.jms.TopicSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import EDU.oswego.cs.dl.util.concurrent.CountDown;

/** A complete JMS client example program that sends a
TextMessage to a Queue and asynchronously receives the
message from the same Queue.

@author  [e-mail]
@version $Revision: 1.1 $
*/
public class DurableTopicClient
{
   static CountDown done = new CountDown(1);
   TopicConnection  conn = null;
   TopicSession session = null;
   Topic topic = null;

   public static class ExListener implements MessageListener
   {
      public void onMessage(Message msg)
      {
         done.release();
         TextMessage tm = (TextMessage) msg;
         try
         {
            System.out.println("onMessage, recv text="
               + tm.getText());
         }
         catch(Throwable t)
         {
            t.printStackTrace();
         }
      }
   }

   public void setupPubSub()
      throws JMSException, NamingException
   {
      InitialContext iniCtx = new InitialContext();
      Object tmp = iniCtx.lookup("TopicConnectionFactory");
      TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;
      conn = tcf.createTopicConnection("jduke", "theduke");
      conn.setClientID("OtherSubscriptions");
      topic = (Topic) iniCtx.lookup("topic/testTopic");
      session = conn.createTopicSession(false,
         TopicSession.AUTO_ACKNOWLEDGE);
      conn.start();
   }

   public void sendRecvAsync(String text)
      throws JMSException, NamingException
   {
      System.out.println("Begin sendRecvAsync");
      // Setup the pub/sub connection, session
      setupPubSub();
      // Set the async listener
      TopicSubscriber recv = session.createDurableSubscriber(topic, "AnotherExample");
      recv.setMessageListener(new ExListener());
      // Send a text msg
      TopicPublisher send = session.createPublisher(topic);
      TextMessage tm = session.createTextMessage(text);
      send.publish(tm);
      System.out.println("sendRecvAsync, sent text="
         + tm.getText());
      send.close();
      System.out.println("End sendRecvAsync");
   }

   public void stop()  throws JMSException
   {
      conn.stop();
      session.close();
      conn.close();
   }

   public static void main(String args[]) throws Exception
   {
      DurableTopicClient client = new DurableTopicClient();
      client.sendRecvAsync("A text msg");
      client.done.acquire();
      client.stop();
      System.exit(0);
   }

}