我想使用 Spring AMQP 发送和使用自定义对象,如下所示。
生产者代码
记录记录 = new Record("message1", new Date());
rabbitTemplate.convertAndSend(record);
任何人都可以提供用于发送和消费消息的 spring amqp @configuration 设置。谢谢!!!
我想使用 Spring AMQP 发送和使用自定义对象,如下所示。
生产者代码
记录记录 = new Record("message1", new Date());
rabbitTemplate.convertAndSend(record);
任何人都可以提供用于发送和消费消息的 spring amqp @configuration 设置。谢谢!!!
您应该看一下示例应用程序;他们中的一些人使用@Configuration
.
但是,本质上,您需要...
@Bean
public SimpleMessageListenerContainer container() {
SimpleMessageListenerContainer container =
new SimpleMessageListenerContainer(connectionFactory());
MessageListenerAdapter adapter = new MessageListenerAdapter(myListener());
container.setMessageListener(adapter);
container.setQueues(foo());
return container;
}
@Bean
public Object myListener() {
return new Foo();
}
听众可以是 POJO ......
public class Foo {
public void handleMessage(Record foo) {
System.out.println(foo);
}
}
编辑:
我在这里为 XML 版本添加了一个要点。