ConnectionFactory connectionFactory = Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue destination =
MessageProducer producer = session.createProducer(destination);
Message msg = session.createMessage();
for (...) {
producer.send(msg);
}
MessageConsumer consumer = session.createConsumer(destination);
for (...) {
Message msg = consumer.receive();
...
}
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(new MessageListener() {
public void onMessage(Message msg) {
...
}
});
connection.start();
connection.close();