Wie implementiere ich Header-Austausch in RabbitMQ mit Java?

7

Ich bin ein Neuling, der versucht, Header-Austausch in Java-Client zu implementieren. Ich bin mir bewusst, dass dies das "x-match" -Bindungsargument ist. Wenn das Argument "x-match" auf "any" gesetzt ist, ist nur ein übereinstimmender Header-Wert ausreichend. Wenn Sie "x-match" auf "all" setzen, müssen Sie alle Werte miteinander vergleichen. aber kann mir jemand einen Skelettcode zum besseren Verständnis zur Verfügung stellen.

    
user2857129 08.10.2013, 06:07
quelle

2 Antworten

20

Um einen Header-Austausch zu verwenden, müssen Sie Ihren Austausch nur als Header-Typ deklarieren:

%Vor%

Dann müssen Sie eine Warteschlange definieren, die das endgültige Ziel der Nachrichten ist, bevor ein Konsument sie konsumiert:

%Vor%

Jetzt müssen wir den Austausch an die Warteschlange binden, die eine Bindung deklariert. In dieser Deklaration legen Sie fest, welche Header Sie für das Weiterleiten von Nachrichten von Ihrem Exchange an Ihre Warteschlange verwenden möchten. Ein Beispiel könnte sein:

%Vor%

Dies wird die Bindung mit HeaderName # 1 und HeaderName # 2 erstellen. Ich hoffe, das hilft!

    
hveiga 23.10.2013 06:41
quelle
0

Erklären Sie zuerst den Austausch mit den Kopfzeilen: -

%Vor%

Deklarieren Sie dann die Warteschlange: -

%Vor%

Definieren Sie jetzt den Header und binden Sie ihn an die Warteschlange: -

%Vor%

Überprüfen Sie dies: - Ссылка

    
lalitbhagtani 10.02.2017 11:27
quelle

Tags und Links