Tag: amqp

Ich versuche zu verstehen, einige Aspekte des AMQP-Protokoll. Derzeit habe ich ein Projekt mit RabbitMQ und Nutzung von python-pika-Bibliothek. Also Frage ist im Hinblick auf die Anerkennung und die Nachricht prefetching. Betrachten wir eine Warteschlange mit nur

Meines Wissens Sellerie wirkt sowohl als Produzent und konsument von Nachrichten. Dies ist nicht das, was ich erreichen will. Ich will Sellerie zu handeln, wie der Verbraucher ist, nur, um Feuer zu bestimmten Aufgaben auf der Grundlage

Ich Schreibe ein python-client für die Aufnahme einer Arbeit, die Nachrichten aus einer RabbitMQ-broker und verarbeiten die Aufträge, für die Rückgabe der Ergebnisse auf einen anderen server. Mein script sendet Nachrichten an den RabbitMQ-broker startet gut, aber

Implementiert habe ich mehrere Verbraucher, die das abrufen von Nachrichten aus einer Warteschlange, ich mache das mit etwas ähnlich dieses Beispiel, außer, dass ich das Tue basic.Holen Sie sich in eine unendliche Schleife für die Abfrage an.

Ich bin die Erforschung queuing-Lösungen für eines meiner Teams-apps. Idealerweise würden wir gerne etwas, das kann so konfiguriert werden beide als eine leichte, in-process-broker (für geringen Durchsatz von Nachrichten zwischen threads) und als externe broker. Gibt es

Ich habe Zugang zu einem RabbitMQ-server zu tun, eine Last test auf Sie zu. Ich bin ganz neu auf Server und AMQ Protokoll. Ich habe schon online recherchieren, um zu sehen, was sind einige verschiedene Methoden. Bisher

Konnte ich nicht finden im RabbitMQ-Dokumentation die Standard-x-message-ttl-Wert kommt mit der installation. Ich wissen, wie es auf einen gewünschten Wert, aber ich bin neugierig zu wissen, den default-Wert. InformationsquelleAutor Martin Chen | 2014-07-25

Gibt es eine Möglichkeit zu zählen wie viel Zeit ein Auftrag requeued (über Ablehnung oder Nak), ohne manuell requeu den job? Ich muss versuchen einen job für 'n" - Zeit und dann legen Sie es nach -

Ein wenig hintergrund. Sehr großen monolithischen Django-Anwendung. Alle Komponenten nutzen die gleiche Datenbank. Wir müssen gesonderte Leistungen für so können wir unabhängig upgrade werden einige Teile des Systems, ohne den rest. Verwenden wir RabbitMQ als broker Sellerie.

Ich würde gerne selektives löschen von Nachrichten aus einem AMQP-Warteschlange ohne auch Sie zu Lesen. Das Szenario ist wie folgt: Versenden Seite will expire Nachrichten des Typs X basiert auf einer Tatsache, dass neue Informationen vom Typ

Ich bin in den Prozess der Entwicklung einer messaging-Schnittstelle für eine unserer Anwendungen. Die Anwendung ist ein Dienst, welcher ausgelegt ist, zu akzeptieren, einen "Job" machen einige Verarbeitung und das Ergebnis (in form einer Datei). Die Idee

Ich bin neu RabbitMQ. Ich möchte in der Lage sein zu handhaben, Nachrichten Lesen, ohne zu blockieren, wenn es mehrere Warteschlangen (Lesen). Alle Eingänge, wie kann ich das tun? //Edit 1 public class Rabbit : IMessageBus {

Ich würde gerne eine Nachricht senden, die eine RabbitMQ-server und warten dann auf eine Antwort-Nachricht ("reply-to" - Warteschlange). Natürlich, ich will nicht ewig warten, falls die Anwendung die Verarbeitung dieser Nachrichten ist down - muss es ein

Ich habe einen 2.8.2 RabbitMQ-Server und einem 2.8.2 client dll, habe den code zum deklarieren einer Warteschlange und die Meldung erhalten, es funktioniert einwandfrei (alle Parameter korrekt sind): IModel channel=null; ConnectionFactory factory = new ConnectionFactory (); factory.HostName

In meine (begrenzte) Erfahrung mit rabbit-mq, wenn Sie einen neuen listener für eine Warteschlange, die noch nicht existiert, wird die Warteschlange automatisch erstellt. Ich versuche, das Spring AMQP-Projekt mit rabbit-mq um einen listener einrichten, und ich bekomme

Ich versuche zu erstellen, integration-test für eine Scala /Java-Anwendung, die eine Verbindung zu einem RabbitMQ-broker. Um dies zu erreichen möchte ich einen embedded-broker, spricht AMQP, dass ich starten und stoppen Sie vor jedem test. Ursprünglich wollte ich

während versuchen, um eine neue Verbindung zu rabbitmq auf einem anderen server läuft, bekam ich die folgende Fehlermeldung: java.io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:406) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533) Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason:

Meine Java-Anwendung sendet Nachrichten zu RabbitMQ exchange, dann leitet exchange Nachrichten an gebundenen Warteschlange. Ich benutze Springframework AMQP java-plugin mit RabbitMQ. Das problem: kommt die Meldung in die Warteschlange, aber es bleibt in "Uneingestandene" - Zustand, es

Habe ich mit RabbitMQ in ein paar setups jetzt, und ich kann nicht erschüttern das Gefühl, dass es etwas sein muss, das ist eher einfach eingerichtet. Trotz der Bequemlichkeiten, es ist schwer zu rechtfertigen, MQ für eine

Ich habe eine Anwendung, die verwendet RabbitMQ als message-queue zum senden/empfangen von Nachrichten zwischen zwei Komponenten: sender und Empfänger. Der sender sendet Nachricht in eine sehr schnelle Art und Weise. Der Empfänger erhält die Nachricht und macht

Wir arbeiten an einer Anwendung, die unterstützt AMQP für queuing. Einige unserer Kunden werden mithilfe von Websphere MQ. Ich Frage mich nur, auf einem hohen Niveau, wie austauschbar diese beiden Protokolle sind in Bezug auf Funktionalität. Ich

In der RabbitMQ/AMQP-Java-client, erstellen Sie eine AMQP.BasicProperties.Builderund es verwenden, um build() eine Instanz von AMQP.BasicProperties. Diese integrierten Eigenschaften-Instanz kann dann verwendet werden, um alle Arten wichtiger Dinge. Es gibt viele "builder"-Stil Methoden zur Verfügung, die auf diese

Habe ich installiert, RabbitMQ server auf OS X, und begann, es auf der Kommandozeile. Nun, ist es nicht offensichtlich, dass, wie sollte ich verhindern, dass es läuft? Nachdem ich das gemacht habe: sudo rabbitmq-server -detached Bekomme ich:

Brauche ich ein python-Programm, das entdecken von Warteschlangen auf einen Neustart RabbitMQ-server, exchange, und starten Sie eine Kunden-zum fortsetzen der Konsum von Nachrichten von jeder Warteschlange. Wie kann ich entdecken, Warteschlangen von einigen RabbitMQ-kompatiblen python-api/library? InformationsquelleAutor der

Ich bin ganz neu RabbitMQ. Ich habe ein 'Thema' exchange. Der Verbraucher kann gestartet werden, nachdem der publisher. Ich möchte die Verbraucher in der Lage sein, Nachrichten zu empfangen, die gesendet wurden, bevor Sie wurden, und das