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 aTextMessage to a Queue and asynchronously receives themessage from the same Queue.@author  Scott.Stark@jboss.org@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);   }}