Spring RabbitMq - 应用自定义负载转换器

Question

如何在 MessagingMessageConverter 中应用自定义 payloadConverter。它默认为 SimpleMessageConverter class.

我可以轻松地将 messageConverter 应用到 rabbitTemplate，但它只会影响外发消息。

MessagingMessageConverter属于MessagingMessageListenerAdapter.

我是否需要创建 containerFactory 才能应用 payloadConverter？

Answer 1

是的，你在容器工厂上设置了转换器；您可以定义自己的 bean 或修改由 Boot 创建的 bean。我假设您正在使用引导，否则您将不得不定义一个工厂。

@Component
class ContainerCustomizer {

    public ContainerCustomizer(AbstractRabbitListenerContainerFactory<?> factory) {
        factory.setMessageConverter(...);
    }

}

Spring RabbitMq - 应用自定义负载转换器

Spring RabbitMq - Apply custom payload converter

spring-amqp

spring-rabbit