package csci4134.web.jms.topic;

import java.util.Properties;

import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.jms.TextMessage;

import javax.naming.InitialContext;

import java.util.Hashtable;

/**
 * This class demonstrates a simple message publisher in a
 * topic/subsriber JMS application.
 * @author Jeff Tassin
 */
public class CSCI4134Publisher
{
   public static void main(String[] args) 
   {
      try
      {
	 System.out.println( "CSCI4134Publisher started" );

	 Properties props = new Properties();
	 props.put( "java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory" );
	 props.put( "java.naming.provider.url", "localhost:1099" );
	 props.put( "java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces" );
         InitialContext ic = new InitialContext( props );


	 TopicConnectionFactory topicConnectionFactory = (TopicConnectionFactory)ic.lookup("ConnectionFactory");

	 /** note that this topic must be defined in the $JBOSS_HOME/server/default/deploy/\jbossmq-destinations-service.xml file */
	 String topicName = "topic/csci4134/demoTopic";
	 Topic topic = (Topic)ic.lookup(topicName);
	 TopicConnection topicConnection = topicConnectionFactory.createTopicConnection();
	 TopicSession topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
	 TopicPublisher topicPublisher = topicSession.createPublisher(topic);
	 
	 TextMessage message = topicSession.createTextMessage();
	 message.setText( "This is the 1st message " );
	 topicPublisher.publish(message);
	 
	 message = topicSession.createTextMessage();
	 message.setText( "This is the 2nd message " );
	 topicPublisher.publish(message);
	 
	 topicConnection.close();
      }
      catch( Exception e )
      {
	 e.printStackTrace();
      }
   }
}