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]
1
Antworten
ich bin mit dem node.js als client jms-topic.Es sind zwei Protokolle verfügbar, um die Verbindung zum Thema. Thesen sind Stomp und AMQP. Ich lese kurz über Sie http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol und http://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocol. Beides scheint zu sein, wire-Protokoll-Ebene ich.e Daten,
1
Antworten
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
1
Antworten
manchmal fand ich Folgen Eintrag in meine log-Datei. Ich habe keine Ahnung, was das problem ist. Meine Vermutung ist, zum einstellen einer niedrigeren Anforderung Herzschlag. Irgendwelche anderen Ideen? Darüber hinaus hatte ich die Situation, dass nach einem
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
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);
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
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
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.
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
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
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
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
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 =
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
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
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 -
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
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.
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
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
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
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
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.
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 {
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,
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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