17

I want to set message header while sending a message to rabbit. I am using below code, but confused how to set message header in it. 

public static <T> void sendMessage(String routingKey,final Object message,Class<T> type){
    DefaultClassMapper typeMapper = new DefaultClassMapper();
    typeMapper.setDefaultType(type);

    Jackson2JsonMessageConverter converter = new Jackson2JsonMessageConverter();
    converter.setClassMapper(typeMapper);

    RabbitTemplate template = new RabbitTemplate(getConnectionFactory));
    template.setMessageConverter(converter);

    template.convertAndSend(routingKey, message);
}

In above method i am simply arguementing java POJO object and its type to send. I want to know where should i set message header here.

How to listen the message properties at listener end?

Alex44
  • 3,597
  • 7
  • 39
  • 56
Rajat Goyal
  • 465
  • 1
  • 5
  • 20

1 Answers1

37

Java 8:

template.convertAndSend(routingKey, message, m -> {
    m.getMessageProperties().getHeaders().put("foo", "bar");
    m.getMessageProperties().setPriority(priority);        
    return m;
});

Java 6,7:

template.convertAndSend(routingKey, message, new MessagePostProcessor() {

    @Override
    public Message postProcessMessage(Message m) throws AmqpException {
        m.getMessageProperties().getHeaders().put("foo", "bar");
        m.getMessageProperties().setPriority(priority);        
        return m;
    }

});
Gary Russell
  • 166,535
  • 14
  • 146
  • 179
  • Don't put code in comments; as you can see, it's unreadable. Edit your question instead, and show all your configuration. Priority is a message property, not a message header. Use `m.getMessageProperties().setPriority(priority)`. – Gary Russell Oct 04 '16 at 17:16
  • 3
    It's not necessary to call `getHeaders()` first. Could simplify to `m.getMessageProperties().setHeader("foo", "bar");` – Denis.Kipchakbaev Oct 04 '21 at 11:22