如何在 Spring Boot Messaging 上添加 MessageConverter

Question

如何使用 Spring Boot 为目标定义 MessageConverter？我已经定义了我的消息代理和 JMS 侦听器。

@JmsListener(destination = "new.clinic.queue")
public void receiveNewClinic(MyCustomDTO message) {

}

和我的消息代理

@Bean
public BrokerService broker() throws Exception {
    BrokerService broker = new BrokerService();
    broker.setBrokerName(brokerName);
    broker.addConnector(brokerAddress);
    return broker;
}

如何为 MyCustomDTO 添加自己的消息转换器

Answer 1

您需要创建一个JmsMessageContainerFactory 并进行相应的配置。 Spring Boot 会为您创建一个实例，但您可以使用自己的自定义项创建任意数量的实例，并使用 @JmsListener 注释的 containerFactory 引用它们。

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(
        ConnectionFactory connectionFactory) {
  DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
  factory.setConnectionFactory(connectionFactory);
  factory.setMessageConverter(yourMessageConverter());
  // .. other settings
  return factory;
}

注意这里的bean名称是默认名称，所以不需要指定connectionFactory属性。

Spring Boot 1.4 将 auto-detect your MessageConverter 并将其分配给它为您自动创建的默认工厂。