Session.AUTO_ACKNOWLEDGE

使用自动确认模式,必须要创建无事务session

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

AUTO_ACKNOWLEDGE：自动确认模式，一旦接收方应用程序的消息处理回调函数返回，会话对象就会确认消息的接收。一般接收方的做法是调用consumer.setMessageListener()注册消息处理函数。如果该函数返回，代表着一条消息被接受放成功接收， ActiveMQ服务器会认为消息接收成功。函数的返回可以是正常的返回，也可以是因为抛出异常而结束。

接收方代码，多次允许的时候，每次都会接收到1个消息。这是因为消息处理函数没有返回,ActiveMQ会认为消息接收失败。

 String url = "tcp://localhost:61616";String userName = "system";String password = "manager";ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName, password, url);Connection connection = connectionFactory.createConnection();connection.start();Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);Destination destination = session.createQueue("test_queue");MessageConsumer consumer = session.createConsumer(destination);// 消息消费者接收消息consumer.setMessageListener(new MessageListener(){@Overridepublic void onMessage(Message msg){TextMessage message = (TextMessage) msg;try{System.out.println("收到消息：" + message.getText());while(true){//throw new JmsException("error return");}}catch (JMSException e){e.printStackTrace();}}});

Session.AUTO_ACKNOWLEDGE相关推荐

JMS createSession(false, Session.AUTO_ACKNOWLEDGE); 两个参数不同组合下的区别
createSession(paramA,paramB); paramA 取值有 : true or false 表示是否支持事务 paramB 取值有:Session.AUTO_ACKNOWLED ...
SpringBoot整合activeMQ消息队列手动签收（Session.CLIENT_ACKNOWLEDGE）为什么失效啊？
今天在家隔离办公,不太忙,然后就琢磨起来消息队列activeMQ的消息事务来解决分布式事务,但是奈何在SpringBoot整合activeMQ时,其消费者手动签收消息时出现了问题-->当acti ...
Session.CLIENT_ACKNOWLEDGE
使用客户端确认模式,必须要创建无事务session Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE ...
activeMQ 本地测试
参考博主搭建~ https://www.cnblogs.com/jaycekon/p/6225058.html ActiveMQ官网下载地址:http://activemq.apache.org/d ...
ActiveMQ—安装配置及使用
安装配置及使用转自:http://blog.csdn.net/qq_21033663/article/details/52461543 (一)ActiveMQ介绍 ActiveMQ 是Apache出 ...
java jms消息删除_activemq的topic消息一直都会存在数据库中，为什么不会删除
该楼层疑似违规已被系统折叠隐藏此楼查看此楼我把消息设置的持久化到数据库.采用topic的方式发送消息. 每次发送消息之后,数据库的ACTIVEMQ_MSGS表里都会插入10条记录(每次是发送10条 ...
activemq 消息阻塞优化和消息确认机制优化
一.消息阻塞优化 1.activemq消费者在从待消费队列中获取消息是会先进行预读取,默认是1000条(prefetch=1000).这样很容易造成消息积压. 2.可以通过设置prefetch的默认值 ...
ActiveMQ（li）
一.ActiveMQ 首先,ActiveMQ不是一个框架,它不是struct,webx,netty这种框架,它更像是tomcat服务器,因为你使用它之前必须启动它,activeMQ和JMS的关系有点类 ...
ActiveMQ快速入门
2019独角兽企业重金招聘Python工程师标准>>> 1.下载ActiveMQ 去官方网站下载:http://activemq.apache.org/ 2.运行ActiveMQ 解 ...

Session.AUTO_ACKNOWLEDGE

Session.AUTO_ACKNOWLEDGE相关推荐

最新文章

热门文章