apache ActiveMQ之初体验(二)
onnection factory
connection = connectionFactory.createConnection();
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue("myQueue");
messageConsumer = session.createConsumer(destination);
connection.start();
}
/**
* receive activeMq message
*/
public static void receiveMessage() throws Exception {
while (true) {
TextMessage message = (TextMessage) messageConsumer.receive();
if (message != null) {
System.out.println("receive: " + message.getText());
} else {
break;
}
}
}
/**
* release resource
*/
public static void release() throws Exception {
messageConsumer.close();
session.close();
connection.close();
}
/**
* main method
*/
public static void main(String[] args) throws Exception {
init();
receiveMessage();
release();
}
}