ConnectionFactory connectionFactory = new HornetQConnectionFactory();
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = session.createConsumer(destination);
MessageListener listener = new MessageListener() {
public void onMessage(Message message) {
try {
} catch (JMSException e) {
}
}
};
consumer.setMessageListener(listener);
session.close();
connection.close();
