rendered paste bodypublic 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");
}
}