消费者
由于消费者那里,@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
时间: 2024-11-10 13:13:16