我有Inbound Message Listener适配器,当出站适配器无法打开目标队列时,源队列中的消息将丢失。我正在使用spring-io进行jms队列消息传输。
在消息到达目标队列或留在源队列后,如何提交传输?
在message-driven-channel-adapter
上设置acknowledge="transacted"
。
这只是一个从消费者到生产者的事务传播问题。您可以通过执行以下附加配置轻松修复它。
如果使用DefaultMessageListenerContainer
,强烈建议将sessionTransacted设置为true或指定外部transactionManager。
如果您没有配置消息侦听器容器,而是使用message-driven-channel-adapter
,则需要将其acknowledge
属性设置为transacted
。
要配置出站适配器以参与事务,您需要按如下方式配置JmsTemplate
,并将其sessionTransacted
属性设置为true
:
<bean id="outboundJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="outboundCF" />
<property name="defaultDestination" ref="outboundDestination" />
<property name="sessionTransacted" value="true" />
</bean>
<int-jms:outbound-channel-adapter channel="jmsOutChannel" jms-template="outboundJmsTemplate" />
希望它能解决你的问题。