Something

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