Spring JMS json消息转换器

Question

我在使用spring-jms模块转换来自RabbitMQ的消息时遇到了一些问题。以前，我使用Rest APIendpoint发送消息，该endpoint将消息发送到RabbitMQ队列，并使用@JMSListener方法处理它。

在内部，这种行为添加了一个字段来确定Java类型，由Spring库管理。但是，现在我想避免Rest API调用，因为它不是必需的，而且我可以直接将消息发送到RabbitMQ。

   @Bean
   public MessageConverter jacksonJmsMessageConverter() {
      MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
      converter.setTargetType(MessageType.TEXT);
      converter.setTypeIdPropertyName("_type");
      return converter;
   }

侦听器示例代码：

 @JmsListener(concurrency = "listener.concurrency", destination = "queue.name", containerFactory = "container.factory")
 public void processFile(MyDtoClass dto) {
    ....
 }

Answer 1

子类化转换器并重写getJavaTypeFormessage()以返回所需类型...

/**
 * Determine a Jackson JavaType for the given JMS Message,
 * typically parsing a type id message property.
 * <p>The default implementation parses the configured type id property name
 * and consults the configured type id mapping. This can be overridden with
 * a different strategy, e.g. doing some heuristics based on message origin.
 * @param message the JMS Message to set the type id on
 * @throws JMSException if thrown by JMS methods
 * @see #setTypeIdOnMessage(Object, javax.jms.Message)
 * @see #setTypeIdPropertyName(String)
 * @see #setTypeIdMappings(java.util.Map)
 */
protected JavaType getJavaTypeForMessage(Message message) throws JMSException {