3.2. JMS AMQP 1.0 Client API

      package org.apache.qpid.jms.example;

     import javax.jms.Connection;
     import javax.jms.ConnectionFactory;
     import javax.jms.DeliveryMode;
     import javax.jms.Destination;
     import javax.jms.ExceptionListener;
     import javax.jms.JMSException;
     import javax.jms.Message;
     import javax.jms.MessageConsumer;
     import javax.jms.MessageProducer;
     import javax.jms.Session;
     import javax.jms.TextMessage;
     import javax.naming.Context;
     import javax.naming.InitialContext;

      public class HelloWorld {

       private static final String USER = "guest";
       private static final String PASSWORD = "guest";\
       
    
      public static void main(String[] args) throws Exception { 
      
      try {
      
          // The configuration for the Qpid InitialContextFactory has been supplied in
          // a jndi.properties file in the classpath, which results in it being picked
          // up automatically by the InitialContext constructor.
          Context context = new InitialContext(); 1
      
          ConnectionFactory factory = (ConnectionFactory) context.lookup("myFactoryLookup"); 2
          Destination queue = (Destination) context.lookup("myQueueLookup");
          
          Connection connection = factory.createConnection(USER, PASSWORD); 3
          connection.setExceptionListener(new MyExceptionListener());
          connection.start(); 
          
          Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 4
          
          MessageProducer messageProducer = session.createProducer(queue); 5
          MessageConsumer messageConsumer = session.createConsumer(queue); 6
          
          
          TextMessage message = session.createTextMessage("Hello world!");
              messageProducer.send(message, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE);
              TextMessage receivedMessage = (TextMessage) messageConsumer.receive(2000L); 7
          
          if (receivedMessage != null) {
                System.out.println(receivedMessage.getText());
          } else {
                System.out.println("No message received within the given timeout!");
          }

          connection.close();  8
       } catch (Exception exp) {
          System.out.println("Caught exception, exiting.");
          exp.printStackTrace(System.out);
          System.exit(1);
       }
      }

      private static class MyExceptionListener implements ExceptionListener {
        @Override
        public void onException(JMSException exception) {
            System.out.println("Connection ExceptionListener fired, exiting.");
            exception.printStackTrace(System.out);
            System.exit(1);
        }
      }
    }

              
              java.naming.factory.initial = org.apache.qpid.jms.jndi.JmsInitialContextFactory
              
              connectionfactory.myFactoryLookup = amqp://localhost:5672 1

              queue.myQueueLookup = queue
              topic.myTopicLookup = topic  2