ActiveMQ的签收方式

总共有三种签收方式，注意session的签方式在生产者和消费者中都得修改。

1.自动签收。

       Session session =connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

2.手动签收

       Session session =connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

         while(true) {TextMessage message=(TextMessage) consumer.receive();if(null != message ) {System.out.println("收到消息："+message.getText());message.acknowledge();}elsebreak;}

3.session签收（事务签收）

首先在生产者中提交事务：session.commit();

Session session =connection.createSession(true, Session.SESSION_TRANSACTED);

         while(true) {TextMessage message=(TextMessage) consumer.receive();if(null != message ) {System.out.println("收到消息："+message.getText());session.commit();}elsebreak;}

ActiveMQ的签收方式相关推荐

Activemq的连接方式
http://blog.csdn.net/liangguo03/article/details/7011227 http://blog.csdn.net/johnnie_deng/article/de ...
消息中间件ActiveMQ 5：可持久化方式AMQ和KahaDB
文章目录 ActiveMQ 的持久化方式一.需要进行消息持久化的原因二.持久化方式 1.AMQ message Store(了解) 2.KahaDB消息存储(默认) ActiveMQ 的持久化方式 ...
JMS学习三（ActiveMQ消息的可靠性）
下面我们来学习一下消息接受确认和发送持久化消息.消息的过期.消息的选择器和消息的优先级. 一.消息接收确认 1.jms消息只有在被确认之后才认为成功消费了这条消息.消息的成功消费通常包括三个步骤:(1 ...
JMS之——ActiveMQ消息持久化
转载请注明出处:http://blog.csdn.net/l1028386804/article/details/68997105 之前的几篇博文中,我们实现的ActiveMQ消息未实现消息的持久化, ...
初识ActiveMQ
2019独角兽企业重金招聘Python工程师标准>>> ①.消息传递方式介绍: Activemq支持两种方式的消息传递: 广播模式:1-n的方式,是一种发布订阅模式,像腾讯新闻那样, ...
ActiveMQ详解
ActiveMQ 消息中间件概述 1.1消息中间件产生的背景在客户端与服务器进行通讯时.客户端调用后,必须等待服务对象完成处理返回结果才能继续执行. 客户与服务器对象的生命周期紧密耦合,客户进程和 ...
ActiveMQ使用及原理浅析（消息队列）
文章目录引言正文一.ActiveMQ是如何产生的? 产生背景 JMS规范基本概念 JMS体系结构二.如何使用? 基本功能消息传递 P2P pub/sub 持久订阅消息传递的可靠性事务型 ...
ActiveMQ 基础知识
第一消息中间件概述 1.1 什么是消息中间件面向消息的中间件(MessageOrlented MiddlewareMOM),发送者将消息发送给消息服务器,消息服务器将消感存放在若千队列中,在合适的 ...
ActiveMQ:消息中心基本介绍
Redis其实也可以做消息队列,但是更多的企业选择了ActiveMQ,为什么,因为Redis的消息队列比较简单,无法做到像ActiveMQ,那样做做到点对点的消息订阅与发送首先是哪些情况需要用到消息 ...

ActiveMQ的签收方式

ActiveMQ的签收方式相关推荐

最新文章

热门文章