Filterung basierend auf Objekttyp

Question

Ich nehme Nachrichten aus einer Warteschlange und nach einer gewissen Verarbeitung muss ich die Nachrichten an verschiedene Dienste weiterleiten.

Queue -> Service (Aktivator) -> Router

Derzeit eine Kette mit Service-Aktivator und Nutzlast basierten Router Ich verwende. Das Problem ist, dass der Router nur an einen Kanal senden kann, aber ich möchte, dass ein anderer Dienst verwendet wird.

Answer 1

Wenn ich Ihre Anforderung richtig verstehe, müssen Sie publish-subscribe-channel statt router nach Ihrer service-activator verwenden.

Queue -> Service-Aktivator -> Publish-Subscribe-Channel-> Ihre Dienste

Beispiel hier: publish-subscribe-channel example