Topic Publisher Example

import javax.jms.*;
import java.util.Properties;
import javax.naming.*;
 
/**
 * An example class that represents a producer to a Topic.
 */
public class Producer {
   private static final String USER = "Administrator";
   private static final String PASSWORD = "admin_pass";
   private static final String SAP_NAMING_PROVIDER_URL = "localhost:50004";
   private static final String SAP_INITIAL_CONTEXT_FACTORY_IMPL =
      "com.sap.engine.services.jndi.InitialContextFactoryImpl";
 
   TopicConnectionFactory topicConnectionFactory = null;
   TopicConnection topicConnection = null;
   Topic topic = null;
   TopicSession topicSession = null;
   TopicPublisher topicPublisher = null;
 
   /**
    * Get InitialContext with default values.
    */
   private InitialContext getInitialContext() {
      try {
         // set the properties for the InitalContext
         Properties properties = new Properties();
         properties.put(
            Context.INITIAL_CONTEXT_FACTORY,
            SAP_INITIAL_CONTEXT_FACTORY_IMPL);
         properties.put(Context.PROVIDER_URL, SAP_NAMING_PROVIDER_URL);
         properties.put(Context.SECURITY_PRINCIPAL, USER);
         properties.put(Context.SECURITY_CREDENTIALS, PASSWORD);
 
         // initalize and return the InitalContext with the specified properties
         return new InitialContext(properties);
 
      } catch (NamingException ne) {
         System.out.println("NamingException: " + ne);
      }
 
      return null;
   }
 
   /**
    * Initialize JMS.
    */
   private void initJMS() {
      try {
         InitialContext context = getInitialContext();
 
         // look up the TopicConnectionFactory
         topicConnectionFactory =
            (TopicConnectionFactory) context.lookup(
               " jmsfactory/default/TopicConnectionFactory");
 
         // create topic connection
         topicConnection = topicConnectionFactory.createTopicConnection();
 
         // start the connection
         topicConnection.start();
 
      } catch (NamingException ne) {
         System.out.println("NamingException : " + ne);
      } catch (JMSException jmse) {
         System.out.println("JMSException : " + jmse);
      }
   }
 
   /**
    * Closes all resorces used in this test. This should be called
     * when you want to finish using JMS.
    */
   private void closeJMS() {
      try {
 
         //close the jms topic session
         topicSession.close();
 
         //close the jms topic connection
         topicConnection.close();
 
      } catch (JMSException jmse) {
         System.out.println("JMSException: " + jmse);
      }
   }
 
   /**
    * Create a topic connection and a session.
    * Then use the session to create a topic publisher.
    */
   public void aMethod() {
      try {
 
         // initializes all important JMS data
         initJMS();
 
         // create topic session
         topicSession = topicConnection.createTopicSession(false, 1);
 
         // create topic destination
         topic = topicSession.createTopic("ExampleTopic");
 
         // create topic publisher
         topicPublisher = topicSession.createPublisher(topic);
 
         /**
          * Publish some messages.
          */
 
         // Closes all resources used in this test.
         closeJMS();
 
      } catch (JMSException jmse) {
         System.out.println("JMSException : " + jmse);
      }
   }
 
}