Fügen Sie die Standardmethode vor dem Aufruf von onMessage hinzu, wenn MessageListener von Spring Amqp

Question

Ich muss einige Standardfunktionalität hinzufügen, die auf einen Wert aus Nachrichtenheader in Spring Amqp vor dem Aufrufen der Funktion MessageMessage der implementierenden Klasse auswählen.

Eg

class TestListener implements MessageListerner { 

public void onMessage(Message message){ 
// some logic 
    } 
} 

Von oben Beispiel ich brauche etwas maßgeschneiderte Funktionalität mit Message-Objekt aufrufen, bevor onMessage genannt wird.

Gibt es eine elegante Möglichkeit, das gleiche in SpringAmqp

Answer 1

Sie könnten zu erreichen schaffen nur eine einfache Wrapper-Klasse um die Zuhörer.

public void onMessage(Message message) { 
    // process 
    myListener.onMessage(message) 
} 

Oder der Hörer Behälter hat eine Eigenschaft afterReceivePostProcessors genau diesem Grund ...

/** 
* Set {@link MessagePostProcessor}s that will be applied after message reception, before 
* invoking the {@link MessageListener}. Often used to decompress data. Processors are invoked in order, 
* depending on {@code PriorityOrder}, {@code Order} and finally unordered. 
* @param afterReceivePostProcessors the post processor. 
* @since 1.4.2 
*/ 
public void setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) { ... }