JMS侦听器中异常时的JMS消息重新传递
at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:98)
at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:66)
at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:660)
at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:620)
at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:591)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:308)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:246)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1142)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1134)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1031)
stacktrace的第5行特别有趣。这里的代码基本上意味着，（大多数情况下）从监听器抛出的任何异常都将绕过在org.springframework.jms.listener.AbstractMessageListenerContainer#CommitifEmented中完成的ackowledgement。
没关系，但是“在抛出异常的情况下不重新交付”是什么意思呢？
其他信息:
Spring-JMS:4.1.2
<bean id="someListenerContainerFactory" class="org.springframework.jms.config.DefaultJmsListenerContainerFactory">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="concurrency" value="1-10"/>
<property name="sessionAcknowledgeMode">
<util:constant static-field="javax.jms.Session.CLIENT_ACKNOWLEDGE"/>
</property>
</bean>
共有1个答案
这取决于您使用的侦听器容器；当使用自动ack模式时，SimpleMessageListenerContainer在侦听器返回后进行ack（即传统的JMSMessageListener)。在调用侦听器之前，DefaultMessageListenerContainer将访问，因此需要Accountygemode=“transacted”以防止消息丢失。
这方面的javadocs有点误导性，最近得到了改进。
使用client_acknowled，您可以自己执行ACK。那个医生只是说你是经纪人的心血来潮。根据JMS消息Javadoc：
-
我有一个Spring应用程序在独立的JBoss EAP 6.2中运行（带有嵌入式HornetQ提供程序）。 消息被成功地放在队列中（我可以在jboss eap-6.2\独立\data\MessagingJournal\hornetq-data-1.hq中看到它们，因为队列是持久的），但不会被侦听器拾取（侦听器中的断点不会被命中）。我怀疑配置中缺少或错误的东西，但看不出是什么。JBoss启动时没有任
-
我正在读一条来自Solace的信息。我能够成功地阅读信息。假设我正在阅读一条消息，在侦听器线程上读取/处理消息时，应用程序崩溃。那我怎么能在那上面再读一遍那条信息呢。使用下面的代码，我无法再次阅读该消息。下面是我的配置
-
我有一个可流动的工作流，我需要在某个阶段暂停，然后根据JMS消息从JMS监听器重新启动相同的工作流。
-
问题内容： 我们有一个Java侦听器，它从JBossMQ的队列中读取文本消息。如果必须重新启动JBoss，则侦听器将不会重新连接并重新开始阅读消息。我们只是每2分钟在侦听器的日志文件中收到一条消息，指出该消息无法连接。我们在代码或JBossMQ中没有设置什么吗？我是JMS的新手，因此将非常感谢您的帮助。谢谢。 问题答案： 您应该在客户端代码中实现javax.jms.ExceptionListene
-
1天前 嗨，当试图根据http://wso2.org/project/esb/java/4.0.3/docs/samples/transport_samples.html/sample250使用wso2 esb侦听来自JMS队列的消息时，我遇到了一个异常，如下所示 XML解析错误：格式不正确的位置: org.apache.axis2.axisfault:系统无法从jms://jmslistener
-
在与JMS合作的过程中，我有一个疑问。据我所知，创建同步消息消费者是可能的。但是，我必须以一定的频率启动它，因为事实上没有侦听器。接下来，为了同步使用队列中的消息，我可以创建一个MDB并将池设置为1。我认为这不是一个好的解决办法。 我的目标是在消息出现在队列中时同步地使用它们。从我的观点来看，上述解决方案并不好：1。不时推出的消费者。2.MDB（通常异步）和池设置为1。 有什么适合我的解决方案吗？
-
我正在使用WerbLogic 10.3.5和Spring 3.0实现JMS队列。我有以下Spring配置： 我的消息创建代码如下所示： 我的听众是这样的： 消息被正确创建，侦听器的onMessage（）方法被调用，但是如果逻辑失败，我抛出RuntimeException（），消息不会被重新传递。我尝试了上述代码的许多细微变化（例如设置SessionAcknowledgeMemodeName=SES
-
我有Spring启动应用程序，它通过注释从组件类中侦听 IBM MQ 队列。MQ 属性（主机名、通道、端口等）是从 yaml 文件设置的。 MQ 依赖项在分级构建中添加，如下所示： 这可以正常工作，只要我使用Tomcat容器在本地运行应用程序即可侦听消息。但是，如果我将其打包为 EAR 并部署到 Wesbphere8.5 服务器，它将引发以下异常，并且侦听器未从队列中读取消息。我确认所有运行时依赖