Warteschlangengröße im Spring AMQP Java-Client

Abrufen der Anzahl nicht bestätigter Nachrichten in der RabbitMQ-Warteschlange von Java / Spring

Wie wird die Parallelität in Spring AMQP Listener Container implementiert?

Meine Container-XML-Konfiguration: <rabbit:listener-container connection-factory="myConnectionFactory" acknowledge="none" concurrency="10" requeue-rejected="false"> <rabbit:listener ref="myListener" queues="myQueue"/> ...

Spring-Integration mit Rabbit AMQP für "Client sendet Nachricht -> Server empfängt und sendet Nachricht in Rückgabewarteschlange -> Client erhält korrelierte Nachricht"

Ich kann ein Java-Programm mit der Rabbit Java-API schreiben und dabei Folgendes tun: Client sendet Nachricht über Rabbit MQ-Austausch / Warteschlange mit Korrelations-ID (sagen Sie UUID - "348a07f5-8342-45ed-b40b-d44bfd9c4dde"). Server ...

Spring AMQP: BlockedListener für Verbindung registrieren

Ich versuche, blockierte Listener mit RabbitTemplate of Spring AMQP in RabbitMQ zu implementieren. In meinem Code verwende ich die JAR-Datei der Version Spring-amqp 1.1.3, wobei ich mir auch die Version 1.3.1 angesehen habe und diese auch in ...

Dateien über RabbitMQ senden

Ist es eine gute Idee, Dateien mit einer Größe von etwa 1 MB über RabbitMQ zu senden? Ich möchte eine Nachricht im JSON-Format mit Binärfeldern senden, die den Dateien entsprechen. Und wie geht das richtig mit spring-amqp? Nur durch das ...

Spring amqp with RabbitMq: Nachricht wird nicht zurück in die Live-Warteschlange eingekreist, nachdem sie aus der Dead Letter-Warteschlange gefallen ist

Ich versuche zu erreichenDie [http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2013-April/026489.html]. Es gibt so viele widersprüchliche Antworten, um zu wissen, ob dies möglich ist oder nicht. Nach vorherigem Link ist dies nicht möglich. ...

Spring AMQP v1.4.2 - Problem mit der Wiederverbindung von Kaninchen bei Netzwerkausfall

Ich teste das folgende Szenario in Spring AMQP v1.4.2 und es kann nach einer Netzwerkstörung keine erneute Verbindung hergestellt werden: Starten Sie die Frühlingsanwendung, die Nachrichten asynchron mit rabbit: listener-container und rabbit: ...

RabbitMQ Integrationstest und Threading

Ich habe einen RabbitMQ-Consumer geschrieben, indem ich die MessageListener-Schnittstelle implementiert und einen SimpleMessageListenerContainer eingerichtet habe. Es funktioniert gut, wenn ich es manuell teste. Jetzt möchte ich einen ...

SimpleMessageListenerContainer Fehlerbehandlung

Ich benutze einSimpleMessageListenerContainer als Basis für das Remoting über AMQP. Alles läuft reibungslos, vorausgesetzt, der RabbitMQ-Broker ist beim Start des Prozesses erreichbar. Wenn es jedoch aus irgendeinem Grund nicht erreichbar ist ...