当出站适配器无法打开目标队列时,来自源的消息将丢失



我有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" />

希望它能解决你的问题。

相关内容

  • 没有找到相关文章

最新更新