FileDocCategorySizeDatePackage
JmsClient_1.javaAPI DocExample1783Sat May 25 22:07:54 BST 2002com.titan.clients

JmsClient_1

public class JmsClient_1 extends Object implements javax.jms.MessageListener

Fields Summary
Constructors Summary
public JmsClient_1()

        
    Context jndiContext = getInitialContext();
    
    TopicConnectionFactory factory = (TopicConnectionFactory)
        jndiContext.lookup("ConnectionFactory");
    
    Topic topic = (Topic) jndiContext.lookup("topic/titan-TicketTopic");

    TopicConnection connect = factory.createTopicConnection();

    TopicSession session = 
        connect.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); 

    TopicSubscriber subscriber = session.createSubscriber(topic);

    subscriber.setMessageListener(this);
    
    System.out.println("Listening for messages on topic/titan-TicketTopic...");
    connect.start();
Methods Summary
public static javax.naming.ContextgetInitialContext()

		return new InitialContext();
public static voidmain(java.lang.String[] args)

        
        new JmsClient_1();
        
        while(true) { Thread.sleep(1000); }
public voidonMessage(javax.jms.Message message)

    try {
        TextMessage textMsg = (TextMessage)message;
        String text = textMsg.getText();
        System.out.println("\n RESERVATION RECEIVED:\n"+text);
    } catch(JMSException jmsE) {
        jmsE.printStackTrace();
    }