import java.util.Properties;

import javax.jms.*;

import javax.naming.*;

/**

 * The SimpleClient class sends several messages to a queue.

 */

public class SimpleSenderClient {

   private static final String USER = "User"; //Set the "User"

   private static final String PASSWORD = "Password"; //Set the "Password"

   private static final String SAP_NAMING_PROVIDER_URL = "server_host:p4_port"; // Set the <server_host> and the <p4_port>

   private static final String SAP_INITIAL_CONTEXT_FACTORY_IMPL = "com.sap.engine.services.jndi.InitialContextFactoryImpl";

   /**

    * Main method.

    */

   public static void main(String[] args) {

      Context jndiContext = null;

      QueueConnectionFactory queueConnectionFactory = null;

      QueueConnection queueConnection = null;

      QueueSession queueSession = null;

      Queue queue = null;

      QueueSender queueSender = null;

      TextMessage message = null;

      final int NUM_MSGS = 3;

      /* JNDI service naming environment properties initialization */

      Properties ctxProp = new Properties();

      ctxProp.put(Context.INITIAL_CONTEXT_FACTORY,

            SAP_INITIAL_CONTEXT_FACTORY_IMPL);

      ctxProp.put(Context.PROVIDER_URL, SAP_NAMING_PROVIDER_URL);

      ctxProp.put(Context.SECURITY_PRINCIPAL, USER);

      ctxProp.put(Context.SECURITY_CREDENTIALS, PASSWORD);

      /*

       * Create a JNDI API InitialContext object.

       */

      try {

         jndiContext = new InitialContext(ctxProp);

      } catch (NamingException e) {

         System.out.println("Could not create JNDI API" + "context: "

               + e.toString());

         e.printStackTrace();

         System.exit(1);

      }

      /*

       * Look up connection factory and queue. If either does not exist,   exit.

       *

       */

      try {

         queueConnectionFactory = (QueueConnectionFactory) jndiContext

               .lookup("jmsfactory/default/QueueConnectionFactory");

         System.out.println("QueueConnectionFactory looked up successully");

         queue = (Queue) jndiContext

               .lookup("jmsqueues/default/MyVeryNewQueue");

         System.out.println("MyVeryNewQueue looked up successully");

      } catch (NamingException e) {

         System.out.println("JNDI API lookup failed: " + e.toString());

         e.printStackTrace();

         System.out.println("Client will exit");

         System.exit(1);

      }

      /*

       * Create connection. Create session from connection; false means

       * session is not transacted. Create sender and text message. Send

       * messages, verifying text slightly. Finally, close connection.

       */

      try {

         queueConnection = queueConnectionFactory.createQueueConnection();

         queueSession = queueConnection.createQueueSession(false,

               Session.AUTO_ACKNOWLEDGE);

         queueSender = queueSession.createSender(queue);

         message = queueSession.createTextMessage();

         for (int i = 0; i < NUM_MSGS; i++) {

            message.setText("This is message: " + (i + 1));

            System.out.println("Sending message: " + message.getText());

            queueSender.send(message);

         }

      } catch (JMSException e) {

         System.out.println(" JMS Exception occured: " + e.toString());

         e.printStackTrace();

      } finally {

         if (queueConnection != null) {

            try {

               queueConnection.close();

               System.out.println("QueueConnection closed");

            } catch (JMSException e) {

               e.printStackTrace();

            }

         }

         System.out.println("SimpleClient finished sending messages");

         System.exit(0);

      }

   }

}