如何在Spring AMQP中發送＆使用對象？

Question

我想使用Spring AMQP發送和使用下面的自定義對象。

生產者代碼

記錄記錄=新記錄（ 「MESSAGE1」，新的日期（））;
rabbitTemplate.convertAndSend（record）;

任何人都可以提供spring amqp @configuration設置來發送和使用消息，如上所述。謝謝！！！

Answer 1

你應該看看Sample Applications;其中一些使用@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); 
    } 
} 

編輯：

I added a Gist here的XML版本。