4

我想使用 Spring AMQP 发送和使用自定义对象,如下所示。

生产者代码

记录记录 = new Record("message1", new Date());
rabbitTemplate.convertAndSend(record);

任何人都可以提供用于发送和消费消息的 spring amqp @configuration 设置。谢谢!!!

4

1 回答 1

5

您应该看一下示例应用程序;他们中的一些人使用@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 版本添加了一个要点。

于 2013-08-30T12:39:42.857 回答