java消息失败重发_JMS消息在JMS侦听器中重新发送异常
Javadoc為 org.springframework.jms.listener.AbstractMessageListenerContainer 表示,如果
“sessionAcknowledgeMode”設(shè)置為“CLIENT_ACKNOWLEDGE”:成功偵聽器執(zhí)行后自動(dòng)確認(rèn)消息;如果拋出異常,則無法重新發(fā)送 .
我猜,“在拋出異常的情況下沒有重新傳遞”意味著,即使jms監(jiān)聽器中拋出異常,該消息也不會被重新傳遞(因此,我的猜測,它會得到確認(rèn)) . 但是,從偵聽器拋出的異常意味著對它的調(diào)用不成功,并且由于沒有確認(rèn)應(yīng)該重新發(fā)送 .
問題是:
What actually should happen with message acknowledgement in case of exception thrown in the jms listener?
從這個(gè)堆棧跟蹤中可以看到真正發(fā)生的事情:
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)
堆棧跟蹤的第5行是特別感興趣的 . 那里的代碼基本上意味著,(大多數(shù)情況下)從偵聽器拋出的任何異常都將繞過在 org.springframework.jms.listener.AbstractMessageListenerContainer#commitIfNecessary 中完成的確認(rèn) .
That's ok, but what does "no redelivery in case of exception thrown" mean then?
附加信息:
spring JMS:4.1.2
創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯,堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)總結(jié)
以上是生活随笔為你收集整理的java消息失败重发_JMS消息在JMS侦听器中重新发送异常的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: android sd卡不可写,Andro
- 下一篇: linux中iconv函数,Linux下