Suchergebnisse für Anfrage "amqp"
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"/> ...
Was ist der "Zustellmodus" in AMQP?
Ich verstehe, dass 2 Optionen zur Verfügung stehen: "Nicht persistent""Hartnäckig"Aber was heißt das eigentlich? "Nicht persistent" wie in: Die AMQP-Struktur versucht, die Nachricht zu übermitteln, wenn keine Konsumenten vorhanden sind. Wird ...
Warten auf alle rabbitmq-Antworten bei einem Fanout-Austausch?
Ich habe einen Rabbitmq-Fanout-Austausch namens "ex_foo"für eine RPC - Auslastung. Wenn Clients eine Verbindung zum Server herstellen, erstellen sie ihre eigene nicht dauerhafte RPC - Empfangswarteschlange und stellen mit einem BasicConsumer eine ...
In welchen Domänen ist nachrichtenorientierte Middleware wie AMQP nützlich?
Welches Problem löst MOM (Message Oriented Middleware)? Skalierbarkeit? Integration? In welcher Domäne werden sie typischerweise verwendet und in welchen Domänen sind sie typischerweisenicht benutzt? Verwendet Google beispielsweise eine solche ...
So fordern Sie Nachrichten in RabbitMQ an
Nachdem der Verbraucher eine Nachricht erhalten hat, führt der Verbraucher / Arbeitnehmer einige Überprüfungen durch und ruft dann den Webdienst auf. Wenn in dieser Phase ein Fehler auftritt oder die Validierung fehlschlägt, soll die Nachricht ...
Gibt es eine Möglichkeit, mit RabbitMQ (Java-Client) festzustellen, ob die Netzwerkverbindung während des Verbrauchs geschlossen wird?
Ich verwende RabbitMQ auf RHEL 5.3 mit dem Java-Client. Ich habe 2 Knoten (Maschinen). Knoten1 verbraucht Nachrichten aus einer Warteschlange auf Knoten2 mithilfe der Java-Hilfsklasse QueueingConsumer. QueueingConsumer consumer = new ...
RabbitMQ: Was ist der Standardwert für x-message-ttl?
Ich konnte in der RabbitMQ-Dokumentation den Standardwert x-message-ttl nicht finden, der mit der Installation geliefert wird. Ich kann es auf einen gewünschten Wert einstellen, bin aber neugierig, den Standardwert zu kennen.
Connection Azure-Dienstbus über Java-Client
Ich versuche, den Azure-Service-Bus vom Java-Client mit dem AMQP-Protokoll zu verbinden. Ich folge den Anweisungen unter folgendem ...
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 ...
AMQP-Abonnent in der Rails-App
Ist es möglich, einen AMQP-Abonnenten mit meiner Rails-App zu starten? Möglicherweise durch einen Initialisierer oder so. Ich möchte, dass es gleichzeitig läuft und auch mit Rails-Modellen interagiert. Unten ist ein Pseudocodebeispiel für das, ...