本文介紹了MDP JMS事務回滾，然后在無限循環中重新處理消息的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
如果通過指定sessionTransacted=true或transactionManager=jmsTransactionManager在DefaultMessageListenerContainer上啟用事務管理，則只要MDP中發生異常，事務就會回滾，消息就會放回隊列。這會導致消息被再次處理，事務一次又一次地回滾，從而創建一個無限循環。
我想我的問題是..。我錯過了什么嗎？如果消息只是意味著它將被反復處理，那么為什么要讓它回到隊列中呢？
<!-- jms connection factory -->
<bean name="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:ConnectionFactory" />
</bean>
<!-- jms transaction manager -->
<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>
<!-- Destination for Inbound_Email_Q -->
<bean name="inboundEmailDestination" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="queue/inbound_Email_Queue" />
</bean>
<!-- JmsTemplate for Inbound_Email_Q -->
<bean name="jmsInboundEmailTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="defaultDestination" ref="inboundEmailDestination" />
<property name="messageConverter" ref="xmlMessageConverter" />
</bean>
<!-- jms asynchronous listener -->
<bean id="emailMessageServiceMdp" class="org.site.wso.core.jms.EmailMessageServiceMdp" />
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory"/>
<!-- <property name="transactionManager" ref="jmsTransactionManager" /> -->
<!-- <property name="sessionTransacted" value="true"/> -->
<property name="destination" ref="inboundEmailDestination"/>
<property name="messageListener" ref="messageListener"/>
</bean>
<!-- jms message listener adapter -->
<bean id="messageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg>
<bean class="org.site.wso.core.jms.EmailMessageServiceMdp"/>
</constructor-arg>
<property name="messageConverter" ref="xmlMessageConverter"/>
</bean>
這是我的MDP：
public class EmailMessageServiceMdp implements MessageDelegate {
public void handleMessage(Object object) {
EmailMessageRequestVO requestVO = (EmailMessageRequestVO) object;
try {
//Service call that throw exception
} catch (Exception e) {
throw new ApplicationException(e);
}
}
}
JMS
消息重新傳遞只是您的[已配置]推薦答案實現的默認行為。這是一個無休止的爭論，它的相對用處是什么，但看起來，與其丟棄包含一些可能無法恢復的數據的消息，某種形式的重試是一種明智和保守的方法。例如，在您的示例中，您似乎要將JMS消息轉換為電子郵件消息并調度到SMTP服務器。如果SMTP網關關閉，您可能希望保留JMS消息，并在網關重新啟動時重新處理它們。
一般來說，我認為您處理失敗的消息的選項有(取決于JMS實現)：
-
丟棄郵件。
將消息寫入錯誤隊列。
延遲n秒后重新傳遞郵件。
重新傳遞消息n次，然后將消息寫入錯誤隊列。
在延遲n秒x次后重新傳遞消息，然后將消息寫入錯誤隊列。
如果您喜歡#1，那么只需取消異常，提交事務并向消息揮手告別即可。對于睡覺，應該由jms配置(或者目的地特定配置)來處理。
此外，如果您需要更具體的內容，可以查詢消息的getJMSRedelivered()和/或特定于實現的消息頭屬性，該屬性指示消息已重新傳遞了多少次(受大多數JMS實現支持，但不是標準的)，并相應地處理該消息。
這篇關于MDP JMS事務回滾，然后在無限循環中重新處理消息的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
