import javax.jms.*;
import javax.naming.*;

public class BilboRingQueueSender {

    public static void main(String[] args) {
        String ringMessage[] = {"One Ring to rule them all," ,
                                "One Ring to find them," , 
                                "One Ring to bring them all" , 
                                "And in the darkness bind them"};
                                
        QueueConnectionFactory queueConnectionFactory = null;
        Queue ringQueue = null;

        try {
            Context jndiContext = new InitialContext();
            queueConnectionFactory = 
              (QueueConnectionFactory) 
                jndiContext.lookup("QueueConnectionFactory");
            ringQueue = (Queue) jndiContext.lookup("RingQueue");
        } catch (NamingException nameEx) {
          System.out.println("Naming Exception: " + 
                              nameEx.toString());
        }

        QueueConnection queueConnection = null;

        try {
            queueConnection = 
              queueConnectionFactory.createQueueConnection();
            QueueSession queueSession = 
              queueConnection.createQueueSession(
                false,Session.AUTO_ACKNOWLEDGE);
            QueueSender queueSender = 
                queueSession.createSender(ringQueue);
            TextMessage textMessage = 
                queueSession.createTextMessage();

            for (int msgCount = 0; 
                 msgCount < ringMessage.length; 
                 msgCount++) {
                textMessage.setText(ringMessage[msgCount]);
                queueSender.send(textMessage);
                System.out.println(" sending line " + 
                                     msgCount + " : " + 
                                     ringMessage[msgCount]);
            }

            textMessage.setText("end of message");
            queueSender.send(textMessage);
            System.out.println(" sending last line " + 
                               " : " + 
                               textMessage.getText());

            queueConnection.close();

            System.out.println(" ring sender closed");

        } catch (javax.jms.JMSException jmsEx) {
          System.out.println("JMS Exception: " + 
                              jmsEx.toString());
        } finally { if (queueConnection != null) 
            {   try 
                { queueConnection.close(); 
                } catch (javax.jms.JMSException jmse) {} 
            } 
        }

    }
}