給RabbitMQ發送消息時,設置請求頭Header。


消費者的請求頭

生產者設置請求頭 

由於消費者那里,@Payload是接受的消息體,使用了@Header注解,需要請求頭,生產者這邊就要設置請求頭,然后rabbitTemplate再調用convertAndSend方法發送,如下代碼:

 

這是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);
    }

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM