JMS and Apache ActiveMQ Broker

Download from: http://activemq.apache.org/download.html

to start Apache ActiveMQ: bin\activemq
to start:  bin\activemq stop
Admin console default: http://127.0.0.1:8161/admin

package co.uk.tedo.producent_jms;

import javax.jms.Connection;
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.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

public class Glowna {

    public static void main(String[] args) throws JMSException {
        //kod prouducenta JMS-kolejka

        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = session.createProducer(new ActiveMQQueue("nazwa_kolejki_tedo"));
        TextMessage msg = session.createTextMessage("wynik meczu Polska-Hiszpania 2:0");
        producer.send(msg);


        //kod klient JMS-kolejka
        ActiveMQConnectionFactory connectionFactory1 = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection1 = connectionFactory.createConnection();
        Session session1 = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer = session.createConsumer(new ActiveMQQueue("nazwa_kolejki_tedo"));
        consumer.setMessageListener(new MessageListener(){

            //odczytanie tresci wiadomosci z serwera JMS ActiveMQ
            /*
             *  która bedzie wywolywana asynchronicznie
                w momencie przyjscia wiadomosci.
             *
             * (non-Javadoc)
             * @see javax.jms.MessageListener#onMessage(javax.jms.Message)
             */
            public void onMessage(Message message) {
                //System.out.println("Wiadomosci nadeszla " + arg0 );
                TextMessage msg = null;
                try {
                    if (message instanceof TextMessage) {
                        msg = (TextMessage) message;
                         System.out.println("Reading message: " + msg.getText());
                    } else {
                         System.out.println("Message is not a " + "TextMessage");
                    }
                } catch (JMSException e) {
                    System.out.println("JMSException in onMessage(): " + e.toString());
                } catch (Throwable t) {
                    System.out.println("Exception in onMessage():" + t.getMessage());
                }
            }});
        connection.start();
    }

}