自定义MessageListener到DefaultMessageListenerContainer被覆盖

Question

首先，我是Spring集成和Spring JMS方面的新手，所以我尝试采用的解决方案可能不适合我的需求。

我将尝试解释我需要实现什么：基本上，我需要将消息放在一个队列中，并在另一个队列中异步等待答案。

1、将消息放入队列：

我的解决方案：

<int-jms:outbound-gateway id="sendMessageOutboundGW"
                        connection-factory="jmsGatewayConnectionFactory"
                        request-channel="marshaledSendMessageJmsRequestChannel"
                        request-destination="sendMessageRequestQueue"
                        requires-reply="false"
                        reply-destination="sendMessageResponseQueue" 
                        correlation-key="JMSCorrelationID">
</int-jms:outbound-gateway>

--

2.异步监听来自另一个队列的回复消息：

我的解决方案1：

<bean id="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsGatewayConnectionFactory" />
<property name="destination" ref="sendMessageResponseQueue" />
<property name="messageListener" ref="messageListener" />
<property name="errorHandler" ref="sendMessageResponseErrorHandler" />
</bean>

<int-jms:message-driven-channel-adapter id="sendMessageInboundGW"
                                      container="messageListenerContainer"
                                      channel="sendMessageJmsResponseChannel" />

自定义MessageListener实现javax.jms.MessageListener。

然而，看起来我为messageListenerContainer设置的消息侦听器正在被覆盖，并且是一个org.springframework.integration.jms。改用ChannelPublishingJmsMessageListener。我可以在日志中看到，messageListenerContainer正在提取接收到的消息。

此外，使用此解决方案，我可以在日志中看到以下警告消息：提供的侦听器容器已经有了MessageListener实现，但它将被提供的ChannelPublishingJmsMessageListener覆盖。

我的解决方案2：

<bean id="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsGatewayConnectionFactory" />
<property name="destination" ref="sendMessageResponseQueue" />
<property name="messageListener" ref="messageListener" />
<property name="errorHandler" ref="sendMessageResponseErrorHandler" />
</bean>

<int-jms:inbound-gateway id="sendMessageInboundGW"
                       container="messageListenerContainer"
                       request-channel="sendMessageJmsResponseChannel"
                       request-destination="sendMessageResponseQueue"
                       correlation-key="JMSCorrelationID" />

我对这个解决方案也有同样的问题——自定义MessageListener正在被覆盖。

不使用自定义MessageListener，我得到以下错误：

org.springframework.messaging.core。DestinationResolutionException：没有可用的输出通道或replyChannel标头

我做错了什么？

任何帮助都将不胜感激。

Answer 1

使用Spring集成时，消息侦听器是入站网关。这就是您的侦听器bean被覆盖的原因。

有几种解决方案

>

不是将侦听器连接到容器中，而是配置一个

完全消除入站网关，自己处理消息-使用MessageListenerAdapter，将类设为POJO，适配器将路由回复。

如果您不想使用MessageListenerAdapter，您的MessageListener负责路由回复，但我建议使用上面的第一种解决方案。