Syntax

1. 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);
   		}
   	}
   }