package rfid.examples;

import java.util.Hashtable;

import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class TextJndi {
	
	static TopicConnection connection;

	public static void main(String[] args) {
	
		Hashtable<String, String> env = new Hashtable<String, String>();
		env.put(Context.INITIAL_CONTEXT_FACTORY, 
		    "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
		env.put(Context.PROVIDER_URL,"tcp://localhost:61616");
		
		try {
			Context jndi = new InitialContext(env);
			System.out.println("Object:"+jndi.toString());
			
			TopicConnectionFactory conFactory =
				(TopicConnectionFactory)jndi.lookup("DefaultActiveMQConnectionFactory");
			
			connection  =
		        conFactory.createTopicConnection();
			
			TopicSession pubSession =
		        connection.createTopicSession(false,
		                                      Session.AUTO_ACKNOWLEDGE);
		    Queue chatTopic = (Queue)jndi.lookup("SendReceiveQueue");

		    connection.start( );

			
		} catch (NamingException e) {
			e.printStackTrace();
		} catch (JMSException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}