package com.topic;

import javax.jms.JMSException;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.Context;
import javax.naming.NamingException;

import weblogic.jndi.Environment;

public class Publisher {

	
	
	public static void main(String[] args) {

		TopicConnectionFactory confactory= null;
		TopicConnection connection=null;
		TopicSession session=null;
		
		Environment env=new Environment();
		env.setProviderURL("t3://localhost:7001");
		env.setInitialContextFactory("weblogic.jndi.WLInitialContextFactory");
		
		try {
			Context ic=env.getInitialContext();
			confactory=(TopicConnectionFactory)ic.lookup("jms/confactory");
			connection=confactory.createTopicConnection();
			session=connection.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);
			
			Topic desttopic=(Topic)ic.lookup("jms/topic");
			TopicPublisher publisher=session.createPublisher(desttopic);
			TextMessage message=session.createTextMessage();
			message.setText(""+(Math.random()*10000));
			publisher.publish(message);
			System.out.println("Message submitted is "+message.getText());
			connection.start();
			
		} catch (NamingException e) {
			e.printStackTrace();
		} catch (JMSException e) {
			e.printStackTrace();
		}
		
		
	}

}