Java EE 6. Leksykon kieszonkowy

Synchroniczne odbieranie komunikatu

Komunikat JMS można odebrać w sposób synchroniczny:

@Resource(lookup = "myConnection")
ConnectionFactory connectionFactory;

@Resource(lookup = "myQueue")
Destination inboundQueue;

public void receiveMessage() {
    try {
        Connection connection =
            connectionFactory.createConnection();
        Session session =
            connection.createSession(false,
                                     Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer =
            session.createConsumer(inboundQueue);
        connection.start();
        while (true) {
            Message m = consumer.receive();
            // przetwarza komunikat
        }
    } catch (JMSException ex) {
        // ...
    }
}

W powyższym kodzie:

• ConnectionFactory i Destination to administrowane obiekty, które zostały wstrzyknięte przez kontener przy użyciu odpowiednich nazw JNDI. Ten ...