发生错误时如何不消耗JMS消息

作者: 永远的记忆
发布时间: 2024-12-17 08:40:13 (25天前)
转自：

2 条回复

0#
回复此人
林老爷的日常 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 您可以创建一个事务处理的JMS会话： </p> <pre> <code> // create JMS Session from JMS Connection session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); </code> </pre> <P> 并使用 <a href="https://docs.oracle.com/javaee/7/api/javax/jms/Session.html#rollback--" rel="nofollow noreferrer"> Session.rollback（） </A> 表示您需要再次查看该消息的方法： </p> <pre> <code> public void onMessage(Message message) { msgsReceived++; System.err.println("received: " + message); if( msgsReceived<3 ) { // simulating an error case session.rollback(); } else { session.commit(); } </code> </pre> <P> 然后你应该看到这个消息3次，直到你最后一次提交它。 </p> </DIV>

编辑

登录后才能参与评论