从队列中接收消息
public static void testReceive() throws Exception {
ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = factory.createConnection();
connection.start();
final Session session = connection.createSession(true/*支持事务*/, Session.AUTO_ACKNOWLEDGE);
Destination queue = session.createQueue("test_123");
MessageConsumer consumer = session.createConsumer(queue);
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
if (message instanceof TextMessage) {
String text = ((TextMessage) message).getText();
session.commit();//如果开启事务,这儿就需要提交,才会消费掉这条消息
System.out.println(text);
}
}
catch (Exception e) {
e.printStackTrace();
}
}
});
}
可以观察到队列的变化:
相关推荐
NULL 博文链接:https://sswh.iteye.com/blog/1974169
赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...
activemq-pool-5.8.0-sources.jar
NULL 博文链接:https://sswh.iteye.com/blog/1974131
activemq-cpp-library-3.9.5编译的C++库文件,支持vs2015,vs2017,包括了依赖的库文件和头文件,可以在项目中直接使用。
NULL 博文链接:https://sswh.iteye.com/blog/1974156
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
Apache ActiveMQ是Apache软件基金会的一个开源项目,是一个基于消息的通信中间件。ActiveMQ是JMS的一个具体实现,支持JMS的两种消息模型。ActiveMQ使用AMQP协议集成多平台应用,使用STOMP协议通过websockets在Web...
activemq-all-5.12.0-sources.jar
activemq-jms-pool-5.14.4.jar
赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...
标签:activemq-web-console-5.8.0-sources.jar,activemq,web,console,5.8.0,sources,jar包下载,依赖包
标签:activemq-web-console-5.2.0-sources.jar,activemq,web,console,5.2.0,sources,jar包下载,依赖包
标签:activemq-web-console-5.2.0-javadoc.jar,activemq,web,console,5.2.0,javadoc,jar包下载,依赖包
标签:activemq-jms-pool-5.10.0-javadoc.jar,activemq,jms,pool,5.10.0,javadoc,jar包下载,依赖包
标签:activemq-kahadb-store-5.10.0-sources.jar,activemq,kahadb,store,5.10.0,sources,jar包下载,依赖包
标签:activemq-jms-pool-5.10.0.jar,activemq,jms,pool,5.10.0,jar包下载,依赖包
activemq-cpp-library-3.9.5-src.zip
标签:activemq-web-4.0-M3.jar.zip,activemq,web,4.0,M3,jar.zip包下载,依赖包