Tag: amqp

AMQP ist ein offenes messaging-standard. Es definiert ein-Draht-Protokoll-Ebene und semantischer Rahmen für Hochleistungs-enterprise-messaging. Wenn Sie mit einem bestimmten broker (ex: [rabbitmq]), dann wird das AMQP-tag können redundant sein. AMQP sollte nicht verwechselt werden mit Apache[ActiveMQ]

Sellerie und benutzerdefinierte Verbraucher

Anzahl der Antworten 3 Antworten
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

Set-message-header in rabbitmq beim senden

Anzahl der Antworten 1 Antworten
Möchte ich set message header beim senden einer Nachricht an Kaninchen. Ich verwende folgenden code, aber verwirrt, wie man set-message-header in es. public static <T> void sendMessage(String routingKey,final Object message,Class<T> type){ DefaultClassMapper typeMapper = new DefaultClassMapper(); typeMapper.setDefaultType(type);

Pika Arbeiter wirft exception beim ausführen Kanal.declare_queue

Anzahl der Antworten 3 Antworten
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

rabbitmq amqp - hören ack-Nachrichten von Verbrauchern

Anzahl der Antworten 1 Antworten
Habe ich ein Produzent und Makler, die auf der gleichen Maschine. Der Produzent sendet die Nachrichten etwa so: channel = connection.createChannel(); //Create a durable queue (if not already present) channel.queueDeclare(merchantId, true, false, false, null); //Publish message onto

rabbitmq mehrere Verbraucher, die in einer Warteschlange - nur kriegt die Nachricht

Anzahl der Antworten 1 Antworten
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.

AMQP 0-9-1 vs 1-0

Anzahl der Antworten 1 Antworten
Ich bin auf der Suche für einen messaging-Dienst für ein neues Projekt, an der Schnittstelle einige C# - Anwendungen einige Java-Anwendungen. Ich wirklich wie RabbitMQ, weil es scheint, um beeindruckende Unterstützung für beide Technologien. Ich sehe in

Gibt es irgendwelche MQ-Server ausgeführt werden können, eingebettet in eine Java-Prozess?

Anzahl der Antworten 2 Antworten
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

RabbitMQ-Verbindung über Nginx

Anzahl der Antworten 4 Antworten
Ich bin versucht, setup-rabbitmq es von extern erreichbar ist (nicht localhost) durch nginx. nginx-rabbitmq.conf: server { listen 5672; server_name x.x.x.x; location /{ proxy_pass http://localhost:55672/; } } rabbitmq.conf: [ {rabbit, [ {tcp_listeners, [{"127.0.0.1", 55672}]} ] } ] Standardmäßig

Wie lade ich das testen einer RabbitMQ-server (Entweder mit JMeter, python oder anderen Tools..)?

Anzahl der Antworten 2 Antworten
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

Sellerie Speicher nicht freigegeben werden

Anzahl der Antworten 4 Antworten
Sieht es aus wie Sellerie Speicher nicht freigegeben werden, nachdem Aufgabe beendet. Jedes mal, wenn eine Aufgabe abgeschlossen ist, es wäre 5m-10m-memory-Leck. So mit tausenden von Aufgaben, bald wird es zu verwenden, bis alle Speicher. BROKER_URL =

RabbitMQ: Was ist der Standard-x-message-ttl-Wert

Anzahl der Antworten 1 Antworten
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

Schlösser und batch-Holen von Nachrichten mit RabbitMq

Anzahl der Antworten 3 Antworten
Ich versuche, RabbitMq in einer eher unkonventionellen Weg (obwohl an dieser Stelle kann ich wählen Sie eine andere message-queue-Implementierung, wenn nötig). Anstatt Kaninchen push-Nachrichten an meine Verbraucher, der Verbraucher eine Verbindung zu einem queue und holt einen

RabbitMQ: Wie requeue-Nachricht mit Zähler

Anzahl der Antworten 2 Antworten
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 -

Erholt von der zmq.Fehler.ZMQError: Address already in use

Anzahl der Antworten 3 Antworten
Drücke ich Strg-C während der Ausführung eines PAIR Muster (non-blocking client-Server) Verbindung mit der ZMQ. Später, wenn ich versuchte, läuft der REQ-REP (Blockierung client-single server-Verbindung) Muster, ich bekomme die Address already in use Fehler. Ich habe versucht

Service-Orientierte Architektur - AMQP oder HTTP

Anzahl der Antworten 2 Antworten
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.

Konvertieren von Nachricht von RabbitMQ in string/json

Anzahl der Antworten 1 Antworten
Ich bin derzeit kämpfen hart mit einem fairen einfaches problem. Ich möchte eine Nachricht erhalten, die von RabbitMQ und haben, umgewandelt in einen string (oder später ein json-Objekt). Aber alles was ich bekomme ist Byte. Den Nachricht

Wie selektives löschen von Nachrichten aus einem AMQP (RabbitMQ) - Warteschlange?

Anzahl der Antworten 4 Antworten
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

Lächerlich langsam gleichzeitige veröffentlichen/konsumieren rate mit RabbitMQ

Anzahl der Antworten 2 Antworten
Ich bin der Bewertung RabbitMQ und während der Allgemeine Eindruck (von AMQP als solche, und auch RabbitMQ) ist positiv, ich bin nicht sehr beeindruckt von dem Ergebnis. Versuche ich zu veröffentlichen und konsumieren von Nachrichten gleichzeitig und

Mit Spring Integration mit RabbitMQ

Anzahl der Antworten 1 Antworten
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

HAProxy schließt langlebige TCP-verbindungen zu ignorieren TCP-keepalive

Anzahl der Antworten 2 Antworten
Habe ich konfiguriert HAProxy (1.5.4, aber ich versuchte auch 1.5.14), um die balance im TCP-Modus können zwei server auszusetzen AMQP-Protokoll (WSO2 Message Broker) 5672-port. Die clients erstellen und verwenden einer ständigen Verbindung mit dem AMQP-Server, über HAProxy.

Das Lesen von mehreren Warteschlangen, RabbitMQ

Anzahl der Antworten 2 Antworten
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 {

PHP Fatal error: Class 'AMQPConnection' nicht gefunden

Anzahl der Antworten 1 Antworten
Ich habe schon gesehen,diese Frage. Es deutet darauf hin, dass AMQP PECL-Erweiterung ist nicht installiert. Allerdings habe ich erfolgreich installiert, sowohl RabbitMQ sowie integrierte PECL AMQP-extension. Das folgende ist die Ausgabe von phpinfo(). Kann man deutlich sehen,

Warten auf eine Einzel-RabbitMQ-Meldung mit einem timeout

Anzahl der Antworten 5 Antworten
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

Verschieben von Nachrichten zwischen Warteschlangen rabbitMQ

Anzahl der Antworten 3 Antworten
Ich bin auf der Suche, um in der Lage sein, um Nachrichten zwischen Warteschlangen (manuell), Kaninchen. Beispiel: first-queue has messages ['a','b','c','d','e','f'] second-queue has messages ['x','y'] Ich möchte in der Lage sein, sich zu bewegen zum Beispiel Meldung

Ausnahme 'Der AMQP-Vorgang wurde unterbrochen' (code=406) vorkommt .NET-Client-Programmierung

Anzahl der Antworten 1 Antworten
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

REST-API für rabbitmq

Anzahl der Antworten 3 Antworten
Gibt es einen Weg, wie kann ich Daten senden, RabbitMQ von $.ajax? Meine Anwendung besteht aus mehreren tausenden von web-clients (geschrieben auf js) und WCF-REST-Dienst, und jetzt versuche ich, herauszufinden, wie kann ich erstellen Sie eine skalierbare

Wie man Spring-RabbitMQ zum erstellen einer neuen Warteschlange?

Anzahl der Antworten 3 Antworten
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

RabbitMQ verbrauchen Sie eine Nachricht, wenn vorhanden und beenden

Anzahl der Antworten 1 Antworten
Ich bin das ausführen von code auf python-senden und empfangen von RabbitMQ Warteschlange aus einer anderen Anwendung, wo ich kann nicht erlauben, dass threading. Dies ist sehr newbie-Frage, aber gibt es eine Möglichkeit nur überprüfen, ob die

Eingebettet AMQP Broker-Java

Anzahl der Antworten 5 Antworten
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

Ack-oder Nack in rabbitMQ

Anzahl der Antworten 2 Antworten
Ich bin mit rabbitMQ, ich nehme jede Nachricht aus der Warteschlange mit basic_get ohne automatisch durch ACK bestätigt Verfahren, was bedeutet, dass die Nachricht verbleibt in der Warteschlange bis ich auf ack oder nack der Nachricht. Manchmal

RabbitMQ neue Verbindung abgelehnt aufgrund SocketException

Anzahl der Antworten 3 Antworten
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:

Wie man RabbitMQ Warteschlangen failover?

Anzahl der Antworten 3 Antworten
RabbitMQ unterstützt clustering standardmäßig, aber Warteschlangen nicht repliziert werden und sind an den Knoten, auf dem Sie geschaffen sind. Ich bin nun auf der Suche nach Möglichkeiten, um RabbitMQ hoch verfügbar andere als die DRBD-Lösung, die Sie

RabbitMQ: Nachrichten bleiben "Unbestätigten"

Anzahl der Antworten 2 Antworten
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

Wie würden Sie Kodieren eine Map<String, Object> mit Protocol Buffers?

Anzahl der Antworten 1 Antworten
Ich versuche, Protocol Buffers für die Nachricht-Serialisierung. Meine message format enthalten sollte, Map< String, Object > Einträge ... aber wie Schreibe ich das .proto definition? Soweit ich weiß, Protocol Buffers nicht über einen build-in-Karte-Typ. Ich könnte das

Gibt es irgendwelche guten alternativen zu RabbitMQ für low-end-setups?

Anzahl der Antworten 3 Antworten
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

Verbrauchen nicht anerkennen Nachrichten von RabbitMq

Anzahl der Antworten 2 Antworten
Habe ich ein einfaches erstellen Verleger und Verbraucher, die ein Abonnent in der Warteschlange mit basic.consume. Meine Verbraucher erkennt die Nachrichten, wenn der job läuft, ohne eine Ausnahme. Wann immer ich eine Ausnahme ich nicht der ack-Nachricht

RabbitMQ: schnell Produzent und Verbraucher langsam

Anzahl der Antworten 5 Antworten
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

RabbitMQ Benutzer die Berechtigung format

Anzahl der Antworten 2 Antworten
Ich versuche das konfigurieren von Benutzer-Berechtigungen in RabbitMQ mit rabbitmqctl. Der RabbitMQ-Dokumentation http://www.rabbitmq.com/man/rabbitmqctl.1.man.html gibt ein einfaches Beispiel für die Einstellung konfigurieren, schreiben und Lesen Berechtigungen: rabbitmqctl set_permissions -p /myvhost tonyg "^tonyg-.*" ".*" ".*" aber geben nicht mehr

AMQP vs Websphere MQ

Anzahl der Antworten 2 Antworten
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

Mit RabbitMQ gibt es eine Möglichkeit zu schauen, queue-Inhalte ohne eine dequeue?

Anzahl der Antworten 3 Antworten
Als ein Weg, um zu lernen, RabbitMQ und python ich arbeite an einem Projekt, das mir erlaubt, zu verteilen, h264 kodiert, die zwischen einer Anzahl von Computern. Die Grundlagen sind getan, ich habe einen daemon, der läuft

RabbitMQ AMQP.BasicProperties.Builder-Werte

Anzahl der Antworten 3 Antworten
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

In welchen Domänen sind message-oriented middleware wie AMQP nützlich?

Anzahl der Antworten 4 Antworten
Problem, was tun, MOM (Message Oriented Middleware) lösen? Skalierbarkeit? Integration? In welchem Bereich sind Sie in der Regel verwendet und in welchen Domänen sind Sie in der Regel nicht verwendet? Zum Beispiel sagen, Google ist mit so

Wie stoppe ich den RabbitMQ Server auf localhost

Anzahl der Antworten 3 Antworten
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:

RabbitMQ - Wie viele Warteschlangen kann RabbitMQ auf einem einzelnen Server verwalten?

Anzahl der Antworten 2 Antworten
Möchte ich wissen, wie viele maximale Warteschlangen RabbitMQ verarbeiten kann auf einem einzelnen server? Hängt es ab, RAM? Es tut hängt davon ab, erlang Prozesse? InformationsquelleAutor der Frage Raj Sf | 2014-04-10

Wie kann ich Warteschlangen in einem RabbitMQ-Austausch mithilfe von Python auflisten oder erkennen?

Anzahl der Antworten 7 Antworten
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

Wo sind die Implementierungen von AMQP 1.0? Wäre es sinnvoll zu warten?

Anzahl der Antworten 6 Antworten
Ich mache Marktforschung, um herauszufinden, was die messaging-Lösung, die sich auf für unsere zukünftigen Produkte und ich kann nicht wirklich diese Figur ein. Es gibt eine Reihe von AMQP 0.9.1-Implementierungen (RabbitMQ, Apache Qpid, OpenAMQ, um ein paar

RabbitMQ: persistente Nachricht mit Themenaustausch

Anzahl der Antworten 2 Antworten
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

Was ist der "Liefermodus" in AMQP?

Anzahl der Antworten 2 Antworten
Ich verstehe, dass 2 Optionen stehen zur Verfügung: "Non-persistent" "Persistent" Aber was bedeutet das eigentlich? "Non-persistent" - wie in : die AMQP-Stoff wird versuchen, die Nachricht zu übermitteln, wenn es nicht Verbraucher sind, wird die Nachricht gelöscht

amqp vs amqplib - welche Node.js amqp Client-Bibliothek ist besser?

Anzahl der Antworten 6 Antworten
Was sind die Unterschiede zwischen den amqp-client-Bibliotheken? Welches ist die am meisten empfohlene? Was sind die großen Unterschiede? InformationsquelleAutor der Frage Javier del Saz | 2013-11-21

RabbitMQ-Nachrichtengröße und -typen

Anzahl der Antworten 2 Antworten
Welche Nachrichten gespeichert werden können in RabbitMQ-Warteschlangen? Nur strings? Oder kann ich auswählen, welche Art möchte ich speichern: int, binary, string, etc..? Was ist die maximale Größe für eine Nachricht? Wie viele Warteschlangen oder Umtausch erstellt werden