package com.brainysoftware.ejb;

import javax.jms.*;
import javax.naming.*;
public class MessageReceiver {
  public static void main(String[] args) {
    QueueConnection queueConnection = null;
    try {
      Context context = new InitialContext();
      QueueConnectionFactory queueConnectionFactory =
        (QueueConnectionFactory) context.lookup("QueueConnectionFactory");
      String queueName = "MyQueue";
      Queue queue = (Queue) context.lookup(queueName);
      queueConnection =
        queueConnectionFactory.createQueueConnection();
      QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
      QueueReceiver queueReceiver = queueSession.createReceiver(queue);
      queueConnection.start();
      Message message = queueReceiver.receive(1);
      if (message != null) {
        if (message instanceof TextMessage) {
          TextMessage textMessage = (TextMessage) message;
          System.out.println(textMessage.getText());
        }
      }
    }
    catch (NamingException e) {
      System.out.println("Naming Exception");
    }
    catch (JMSException e) {
      System.out.println("JMS Exception");
    }
    finally {
      if (queueConnection != null) {
        try {
          queueConnection.close();
        }
        catch (JMSException e) {}
      }
    }
  }
}