Spring amqp: Wie kann ich MessageProperties in MessageListenerAdapter lesen

Question

HandleMessage-Methode ruft die Nachricht aus Warteschlange nicht ab, wenn ich MessageProperties in seiner Signatur hinzufüge. Es funktioniert einwandfrei, wenn keine MessageProperties vorhanden sind.

Wie kann ich MessageProperties in handleMessage von MessageListenerAdapter erhalten?

public class EventMessageAdapter { 

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

Answer 1

Sie können es nicht mit dem Listener-Adapter tun.

Verwenden Sie den neueren @RabbitListener Mechanismus docs here.

Sie verschiedene Signaturen verwenden können ...

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

oder

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

Im zweiten Fall können Sie alle Nachrichteneigenschaften über message.getMessageProperties() erhalten.

Sie benötigen eine container factory. Spring Boot erstellt automatisch einen für Sie, wenn der Starter im Klassenpfad ist.