rabbitmq - Spring amqp : How can I read MessageProperties in MessageListenerAdapter

Question

如果我在handleMessage方法的签名中添加MessageProperties，它不会从队列中获取消息。如果没有 MessageProperties，它可以正常工作。

如何获取MessageListenerAdapter的handleMessage中的MessageProperties？

public class EventMessageAdapter {

  public void handleMessage(MessageProperties messageProperties, Event event)    {
  ...
  String id = messageProperties.getHeaders().get("key");
}

Answer 1

您无法使用监听器适配器来做到这一点。

使用更新样式的@RabbitListener机制docs here .

您可以使用各种签名...

@RabbitListener(queues = "foo")
public void foo(Event event, @Header("foo") String fooHeader, 
           @Header("bar") Integer barHeader) {...}

或

@RabbitListener(queues = "bar")
public void bar(Event event, Message message) {...}

在第二种情况下，您可以通过以下方式获取所有消息属性message.getMessageProperties()。

您需要一个 container factory 。如果启动器位于类路径上，Spring Boot 会自动为您创建一个。