Productor Java para ActiveMQ

La forma más sencilla de conectarse con ActiveMQ y meter mensajes a las colas es casi como lo haríamos con la especificación JMS. Incluso es posible hacerlo, solo que perderíamos las características adicionales (mejoras) que ActiveMQ nos brinda. El siguiente código hace posible dicha conexión.

El proyecto lo he realizado en NetBeans, así que también incluyo el proyecto para su descarga.

Notar las librerías que se incorporan al proyecto.

 El código se puede mejorar, específicamente el tema de las conexiones, sería mejor incluirlo en un bloque finally, de tal suerte que se cierre la conexión sin importar que no se ejecute correctamente el bloque try.

Las palabras en negritas deben ser sustituidas por los parámetros de su ambiente.

He aquí:

 try {
        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("tcp://127.0.0.1:61613");
       
        javax.jms.Connection connection = cf.createConnection("admin","password");
        connection.start();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue("apollo.myqueue");
        MessageProducer producer = session.createProducer(queue);
        TextMessage message = session.createTextMessage();
       
        for(int i = 0; i< 10000; i++) {
            message.setText("Mi Mensaje:" +i);
            producer.send(message);
        }
       
       
        session.close();
        connection.close();
       
        }
        catch(JMSException jmse) {jmse.printStackTrace();}
       
    }