All pastes #904665 Raw Edit

Something

public text v1 · immutable
·published 2008-02-15 03:51 UTC
rendered paste body
public class LogClientSubscriber implements MessageListener {

    public void onMessage(Message msg) {
        System.out.println("Message recieved");
        System.out.println("Message: " + msg);
    }

    public static void main(String[] args) throws Exception {
        //Initialize JNDI
        InitialContext ctx = new InitialContext();
        //lookup connection factory
        TopicConnectionFactory factory = (TopicConnectionFactory) ctx.lookup("jms/LogBeanFactory");
        // use connection factory to create JMS connection
        TopicConnection connection = factory.createTopicConnection();
        //use connection to create a session
        TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
        //Lookup destination
        Topic topic = (Topic) ctx.lookup("jms/LogBean");
        //create a message subscriber
        TopicSubscriber subscriber = session.createSubscriber(topic);
        //get message
        connection.start();
        int i = 0;
        while (i<10) {
            Message msg = subscriber.receive();
            System.out.println("Message recieved");
            System.out.println("Message: " + msg);
            i++;
        }
        //finish
        connection.close();
        System.out.println("Shutting down");
    }
}