package com.jms;

import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.NamingException;

import weblogic.jndi.Environment;

public class Receiver {

	public static void main(String[] args) {
		QueueConnection connection = null;
		QueueSession session =null;
		try {
			
			Environment env = new Environment();
			env.setProviderURL("t3://localhost:7001");
			env.setInitialContextFactory("weblogic.jndi.WLInitialContextFactory");
			Context ic = env.getInitialContext();
			
			QueueConnectionFactory conFactory = (QueueConnectionFactory) ic.lookup("jms/confactory");
			connection = conFactory.createQueueConnection();
			session = connection.createQueueSession(false,
					QueueSession.AUTO_ACKNOWLEDGE);
			Queue destQueue = (Queue) ic.lookup("jms/queue");
			connection.start();
			QueueReceiver receiver = session.createReceiver(destQueue);
			TextMessage message = (TextMessage) receiver.receive();
			System.out.println(message.getText());

		} catch (NamingException e) {
			e.printStackTrace();
		} catch (JMSException e) {
			e.printStackTrace();
		} finally {
			try {
				session.close();
				connection.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

}