我有一个非常基本的Spring Boot
应用程序,它使用headers
交换将两条消息发布到RabbitMQ
。exchange
和queue
都被创建,但是消息没有到达队列。我也没有看到任何异常。
我在谷歌上搜索了一下,但没有找到任何与此相关的例子。
基本应用程序.java
@SpringBootApplication
public class BasicApplication {
public static final String QUEUE_NAME = "helloworld.header.red.q";
public static final String EXCHANGE_NAME = "helloworld.header.x";
//here the message ==> xchange ==> queue1, queue2
@Bean
public List<Object> headerBindings() {
Queue headerRedQueue = new Queue(QUEUE_NAME, false);
HeadersExchange headersExchange = new HeadersExchange(EXCHANGE_NAME);
return Arrays.asList(headerRedQueue, headersExchange,
bind(headerRedQueue).to(headersExchange).where("color").matches("red"));
}
public static void main(String[] args) {
SpringApplication.run(BasicApplication.class, args).close();
}
}
生成器.java
@Component
public class Producer implements CommandLineRunner {
@Autowired
private RabbitTemplate rabbitTemplate;
@Override
public void run(String... args) throws Exception {
MessageProperties messageProperties = new MessageProperties();
//send a message with "color: red" header in the queue, this will show up in the queue
messageProperties.setHeader("color", "red");
//MOST LIKELY THE PROBLEM IS HERE
//BELOW MESSAGE IS NOT LINKED TO ABOVE messageProperties OBJECT
this.rabbitTemplate.convertAndSend(EXCHANGE_NAME, "", "Hello World !");
//send another message with "color: gold" header in the queue, this will NOT show up in the queue
messageProperties.setHeader("color", "gold");
this.rabbitTemplate.convertAndSend(EXCHANGE_NAME, "", "Hello World !");
}
}
2条答案
按热度按时间rt4zxlrg1#
您所创建的
MessageProperties
没有被使用,这是正确的。尝试在
MessageConverter
的帮助下构建一个利用MessageProperties
的Message
。示例:
vuktfyat2#
从Java 8开始,您还可以使用MessagePostProcessorCallback,如下所示: