侦听器中的 Spring RabbitMQ 自定义消息转换器

Question

我正在使用带有 Spring 集成的 RabbitMQ。 我想为这样的消息监听器注册一个消息转换器：

<rabbit:listener-container
        connection-factory="gesbRabbitmqConnectionFactory"
        acknowledge="auto"
        channel-transacted="true"
        transaction-manager="rabbitTxManager"
        task-executor="gesbSyncExecutor"
        concurrency="1"
        max-concurrency="2"
        requeue-rejected="false"
        message-converter="gesbDataMessageConverter">
    <rabbit:listener
            ref="gesbListenerBean"
            queue-names="${gesb.partyid.queue}" />
</rabbit:listener-container>

当应用程序启动时，我在 setMessageConverter 中放置了一个断点，并且我的消息转换器 gesbDataMessageConverter 设置正确。 但是在运行时消息到达时消息转换器是 SimpleMessageConverter 而不是我的。 有什么想法吗？

作为一种解决方法，我将转换器注入侦听器并再次调用 setMessageConverter，它似乎可以工作，但我不知道为什么最初它没有。监听对象只有一个，set方法只调用一次。

Answer 1

诀窍在于结合使用 Spring AMQP 和 Spring Integration。 AmqpInboundGateway 有自己的MessageConverter 属性，并从原始MessageListener 使用它。

我的意思是您应该将您的自定义 gesbDataMessageConverter 完全提供到 <int-amqp:inbound-gateway> 而不是容器中。