Frühling JmsTemplate - füge individuelles Objekt

Question

Ich bin mit dem JmsTemplate Frühling API und MappingJackson2MessageConverter (Version: spring-jms-4.3.4.RELEASE.jar) -Nachrichten Thema zu einem ActiveMQ zu veröffentlichen, wie im folgenden Code dargestellt.

Topicpublisher Klasse:

@Component 
public class TopicPublisher { 

    @Autowired 
    private JmsTemplate jmsTemplate; 

    @Autowired 
    private MessageConverter messageConverter; 

    public void send() { 
     Product product = new Product(); 
     product.setName("abcd"); 
     product.setPrice(10); 

     jmsTemplate.setMessageConverter(messageConverter); 
     jmsTemplate.convertAndSend("product.topic", product); 
    } 
} 

MappingJackson2MessageConverter Klasse:

@Configuration 
public class JMSTextMessageConverter { 

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

Jetzt möchte ich einige benutzerdefinierte Header an die JMS-Nachricht auf dem Thema veröffentlicht. Ich googelte und konnte kein Beispiel finden, das dies tut. Kannst du helfen ?

Answer 1

Sie können durch das Senden MessagePostProcessor benutzerdefinierte Eigenschaften unter Verwendung convertAndSend Methode von JmsTemplate hinzufügen, wie unten dargestellt:

jmsTemplate.convertAndSend("product.topic", product, new MessagePostProcessor() { 
     @Override 
     public Message postProcessMessage(Message message) throws JMSException { 
      message.setStringProperty("my_property", "my_value"); 
      return message; 
     } 
    }); 

Answer 2

so etwas wie dieses Versuchen:

@SendTo("product.topic") 
public Message<Product> send() { 
    Product product = new Product(); 
    product.setName("abcd"); 
    product.setPrice(10); 

    return MessageBuilder 
      .withPayload(product) 
      .setHeader("code", 1234) // custom header name and value 
      .build(); 
} 

Referenz: https://spring.io/blog/2014/04/30/spring-4-1-s-upcoming-jms-improvements