消費者的請求頭
生產者設置請求頭
由於消費者那里,@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); }