给RabbitMQ发送消息时,设置请求头Header。

消费者

技术分享图片

 

由于消费者那里,@Payload是接受的消息体,使用了@Header注解,需要请求头,生产者这边就要设置,如下代码:

技术分享图片

 

这是RabbitTemplate中的converAndSend(exchang,routingKey,消息体,消息头)方法。

@Override
    public void convertAndSend(String exchange, String routingKey, final Object message,
            final MessagePostProcessor messagePostProcessor) throws AmqpException {
        convertAndSend(exchange, routingKey, message, messagePostProcessor, null);
    }

 

文章来自:https://www.cnblogs.com/theRhyme/p/9724091.html
© 2021 jiaocheng.bubufx.com  联系我们
ICP备案:鲁ICP备09046678号-3