Tag: rabbitmq

RabbitMQ ist eine open-source-message-broker, die ursprünglich Implementierung des AMQP-Protokoll mit zusätzlichen messaging-Protokolle unterstützt, die über eine plug-in-Architektur. Dieser tag sollte verwendet werden, mit Fragen, die die RabbitMQ-server message broker Produkt oder Fragen bezüglich des Quellcodes und die Implementierung der RabbitMQ-Produkt. Eine bestimmte Protokoll-tag wie amqp oder mqtt können ebenfalls geeignet sein, sowie das Betriebssystem und die Programmiersprache, die verwendet wird.

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

Nicht in der Lage zu Starten, rabbitmq-server in centos 7 mit systemctl

Anzahl der Antworten 3 Antworten
Ich versuche, starten Sie den rabbitmq-server in centos 7. Ich installierte erlang, wie es ist, eine Abhängigkeit zu rabbitmq-server. Paket erlang.x86_64 0:R16B-03.7.el7 .Ich habe dann Installiert rabbitmq mit dem Paket-rabbitmq-server-3.2.2-1.noarch.U /min. Installation erfolgreich war. Ich fähigen management

Sellerie Zeitplan für die Aufgabe (Sellerie, Django und RabbitMQ)

Anzahl der Antworten 6 Antworten
Ich will eine Aufgabe, die ausgeführt wird, alle 5 Minuten, aber es wird warten, für die Letzte Ausführung beendet ist, und dann zählen diese 5 Minuten. (So kann ich auch sicher sein, dass es nur eine task

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:

RabbitMQ "Hello World" - Beispiel gibt "Connection Refused"

Anzahl der Antworten 7 Antworten
II versuche zu machen, die "hello world" - Anwendung von hier: RabbitMQ Hallo Welt Hier ist der code von meinem Produzenten Klasse: package com.mdnaRabbit.producer; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; import java.io.IOException; public class App { private

RabbitMQ - Holen Sie sich die Gesamtzahl der Nachrichten in die Warteschlange eingereiht

Anzahl der Antworten 3 Antworten
Ich habe ein Java-client, der überwacht RabbitMQ Warteschlange. Ich bin in der Lage, um die Anzahl von Meldungen, die sich derzeit in der Warteschlange mit diesem code @Resource RabbitAdmin rabbitAdmin; .......... DeclareOk declareOk = rabbitAdmin.getRabbitTemplate().execute(new ChannelCallback<DeclareOk>() {

Erste Reihe von Nachrichten in einer queue RabbitMQ

Anzahl der Antworten 3 Antworten
Verwenden wir amqplib zu veröffentlichen/konsumieren von Nachrichten. Ich möchte in der Lage sein zu Lesen, die Anzahl der Nachrichten in einer Warteschlange (idealerweise beide bestätigten und unbestätigten). Dies wird mir erlauben, zu zeigen, eine schöne status-Diagramm der

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

Sellerie: Fehler bei der Verbindung zu RabbitMQ-Server

Anzahl der Antworten 2 Antworten
Bin ich angefangen zu verwenden, Sellerie, indem Sie die folgenden dieses "Erste Schritte mit Sellerie". Ich genau die tasks.py angegeben link an. Jedoch, wenn lief ich die Aufgabe mit, celery -A tasks worker --loglevel=info Bin ich immer

Warum ist RabbitMQ nicht persistenten Nachrichten auf einem dauerhaften Warteschlange?

Anzahl der Antworten 3 Antworten
Ich bin mit RabbitMQ mit Django durch Sellerie. Ich bin mit dem meisten basic-setup: # RabbitMQ connection settings BROKER_HOST = 'localhost' BROKER_PORT = '5672' BROKER_USER = 'guest' BROKER_PASSWORD = 'guest' BROKER_VHOST = '/' Ich importierte eine Sellerie

Unterschied zwischen stream-Verarbeitung und die message-Verarbeitung

Anzahl der Antworten 2 Antworten
Was ist der grundlegende Unterschied zwischen stream-Verarbeitung und traditioneller message-Verarbeitung? Wie die Leute sagen, dass kafka ist eine gute Wahl für die stream-Verarbeitung, sondern im wesentlichen kafka ist ein messaging-framework, ähnlich ActivMQ, RabbitMQ etc. Warum tun wir

rabbitmqctl Fehler: konnte keine Verbindung zum Knoten [email protected] nodedown

Anzahl der Antworten 4 Antworten
Ich bin mit RabbitMQ v3.3.5 mit Erlang OTP 17.1 auf Windows 2008 R2. Mein Dev-und QA-Umgebungen sind stand-alone. Meine staging-und Produktionsumgebungen gruppiert sind. Ich finde dies ein problem, das passiert oft, wo die RabbitMQ-Dienst ausgeführt wird, ist

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

RabbitMQ + Memory Limits

Anzahl der Antworten 1 Antworten
Ich bin gerade auf der Suche in der config-details von RabbitMQ und kam über [{rabbit, [{vm_memory_high_watermark, 0}, {disk_free_limit, {mem_relative, 1.0}} ] }] Was bedeutet diese config bedeuten? vm_memory_high_watermark auf 0 gesetzt bedeutet, dass => Block alle Verlage

Nicht aktivieren Sie die rabbitmq-management-Plug-in für Windows

Anzahl der Antworten 7 Antworten
So, das ist, was ich getan habe: Installiert Erlang auf meinem Windows x64-bit-Maschine Installierten RabbitMQ Begann RabbitMQ service In diesem Schritt habe ich keine Fehler. Wenn ich jedoch versuchen, enabe rabbitmq-management, erhalte ich einige Fehlermeldungen in der

Gibt es einen Leistungsunterschied zwischen pooling-verbindungen oder Kanäle in rabbitmq?

Anzahl der Antworten 3 Antworten
Ich bin ein Neuling mit dem Rabbitmq - (und Programmier -) also sorry im Voraus, wenn diese offensichtlich ist. Ich Schaffe einen pool teilen zwischen threads, die auf eine Warteschlange, aber ich bin mir nicht sicher, ob

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

MongoDB-Schema-Design - Echtzeit-Chat

Anzahl der Antworten 3 Antworten
Fange ich ein Projekt, von dem ich glaube, dass Sie besonders gut geeignet, um MongoDB aufgrund der Geschwindigkeit und Skalierbarkeit, die es gewährt. Dem Modul bin ich derzeit daran interessiert ist, zu tun, Echtzeit-chat. Wenn ich dies

RabbitMQ - auf eine neue version aktualisiert und bekam eine Menge von "PRECONDITION_FAILED unbekannten Lieferung-tag 1"

Anzahl der Antworten 2 Antworten
Nur ein Upgrade auf eine neue version von RabbitMQ -- 2.3.1 -- und nun tritt folgender Fehler auf: PRECONDITION_FAILED unknown delivery tag 1 ...gefolgt von der Kanal schließen. Dieser arbeitete auf einem älteren RabbitMQ mit der client-Seite

Fehlermeldung "unbekannter Lieferzeit-tag" tritt auf, wenn ich versuche ack-Nachrichten zu RabbitMQ mit pika (python)

Anzahl der Antworten 5 Antworten
Möchte ich die Verarbeitung von Nachrichten in paar threads aber ich bin immer ein Fehler während der Ausführung dieses Codes: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika import connection, credentials