import javax.jms.*;
import org.hornetq.jms.client.HornetQConnectionFactory;
public class AsyncMessageProcessingExample {
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new HornetQConnectionFactory();
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("exampleQueue");
MessageProducer producer = session.createProducer(destination);
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(new MessageListener() {
public void onMessage(Message message) {
try {
System.out.println("Received message: " + ((TextMessage) message).getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
TextMessage message = session.createTextMessage("Hello, HornetQ!");
producer.send(message);
Thread.sleep(1000);
connection.close();
}
}
