spring-rabbitmq

0Hitze

1Antwort

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

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

0Hitze

1Antwort

Wiederverwenden von Annotationen durch Erstellen von Meta-Annotationen

Ich frage mich nur, ob wir eine Meta-Annotation erstellen und sie überall wiederverwenden können. Zum Beispiel habe ich eine Anmerkung wie folgt: Ich muss es an mehreren Orten verwenden. Ich möchte nu

2Hitze

2Antwort

Wie X-Death-Header einer RabbitMQ Nachricht mit Dead-Lettern mit Spring Boot lesen?

Ich versuche, das Umleiten von Nachrichten mit Leads zu implementieren, wie in dieser answer beschrieben. Ich verwende Spring-Konfiguration. Ich habe keine Ahnung, wie man die Header liest, um den urs

0Hitze

1Antwort

SimpleMessageListenerContainer wird nicht mehr erholen, nachdem stoping es

Wenn ein bestimmtes Ereignis eintrifft, stoppe ich meine rabbitmq listner mit container.stop(); und nach der benötigten Arbeit erledigt ist, ich starten Sie ihn mit container.start(), aber wenn ein ne

5Hitze

2Antwort

Versuchen, von <rabbit:> XML-Namespace-Konfiguration zu einem Java zu konvertieren @Configurable kann nicht replizieren

Ich versuche, von XML Spring amqp config in eine Java-Annotation basierend zu migrieren, weil es "einfacher" ist. Nicht sicher, was ich falsch mache, die XML-Konfiguration funktioniert gut, aber das J

7Hitze

3Antwort

Ausnahmen in rabbitmq mit Federverschluß

Ich erhalte die folgende Ausnahme wiederholt, wenn ich meine Feder Boot-Anwendung mit rabbitmq starten. Der gesamte Ablauf funktioniert auch mit den folgenden Ausnahmen einwandfrei. hat es mit dem aut

0Hitze

1Antwort

Einen Dienst in die RabbitMQ einfügen - die ConfirmCallback-Klasse funktioniert nicht

Ich habe eine separate Callback-Klasse erstellt, die die ConfirmCallback-Schnittstelle implementiert und die confirm() überschreibt. Corrlation Daten und ack funktioniert gut. Aber ich habe mit @Autow

2Hitze

1Antwort

RabbitListener Verhalten mehrerer Warteschlangen

Was ist das Verhalten bei Verwendung des folgenden Konstrukts (neueste Version von Spring). Ich kann es in der Dokumentation nicht finden. @RabbitListener(queues = {"q1", "q2", "q3"}) public class My

0Hitze

1Antwort

Wie kann man einen benutzerdefinierten org.springframework.amqp.support.converter.MessageConverter mit RabbitListener-Annotation verwenden?

Ich benutze Spring 4.2 und spring-amqp 1.5.5 und ich habe meine eigene org.springframework.amqp.support.converter.MessageConverter implementiert. Dieser Nachrichtenkonverter soll zwischen einem org.sp