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.
wie legen Sie die grundlegenden Eigenschaften Nachricht für Nachricht in Rabbitmq?
2 Antworten
ich bin mit Rabbitmq-Java-client-API.ich möchte legen Sie die Grundlegenden Eigenschaften für die Nachricht und auch die Nachricht-Id der Nachricht.wenn möglich bitte etwas code, um die Dinge verstehen. Dank InformationsquelleAutor Sameek Mishra | 2010-11-11
AMQP: Anerkennung und prefetching
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
Richtige config mit rabbitmq als Sellerie-backend
1 Antworten
Baue ich einen Kolben app mit Sellerie, mit rabbitmq als Sellerie-backend. meine conf für Sellerie ist CELERY_BROKER_URL='amqp://localhost:5672', CELERY_RESULT_BACKEND='amqp://', CELERY_QUEUE_HA_POLICY='all', CELERY_TASK_RESULT_EXPIRES=None Dann, deklarieren eine Warteschlange produziert eine ganze Reihe von Fehler connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue=new_task_id)
Kanal-shutdown: Kanal-Fehler
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
Wie abonnieren Sie in einem RabbitMQ Warteschlange mit MQTT Paho
2 Antworten
Ich versuche eine Verbindung von meinem Android-app auf eine queue namens "Nachrichten". Den Hersteller (eines webservices unter AMQP-Protokoll) ist schon angeschlossen, kann es sein, überprüfen Sie über RabbitMQ admin-panel. Verbindung von meinem Android-Gerät bin ich die Codierung
RabbitMQ-Verbindung Fehler: "Keiner der angegebenen Endpunkte waren erreichbar"
6 Antworten
Habe ich installiert, rabbitmq-Dienst auf dem server und auf meinem system. Ich möchte die Verwendung der RPC-Muster: var factory = new ConnectionFactory() { HostName = "158.2.14.42", Port = Protocols.DefaultProtocol.DefaultPort, UserName = "Administrator", Password = "@server@", VirtualHost =
Laden rabbitmq config beim Start
1 Antworten
Wie lade ich ein rabbitmq-config beim Start, um zu bestätigen, dass die broker-Objekte (queues, exchanges, Bindungen, Benutzer, virtuelle hosts, Berechtigungen und Parameter) erstellt werden. Nach dem rabbitmq-Dokumentation es kann getan werden, über load_definitions http://www.rabbitmq.com/management.html#load-definitions Aber ich kann
Verbrauchen Sie mehrere Warteschlangen in python / pika
2 Antworten
Ich versuche zu erstellen, die Verbraucher würden abonnieren Sie mehrere Warteschlangen, und dann die Verarbeitung von Nachrichten, wie Sie ankommen. Das problem ist, dass, wenn es einige Daten, die bereits in der ersten Warteschlange verbraucht er die
Was ist eine message-orientierte middleware?
4 Antworten
Ich habe versucht, herauszufinden, genau das, was message-oriented middleware ist, aber nicht in der Lage zu finden, alle nicht-enterprise real world Beispiele, die für mich Sinn machen. Kann mir jemand eine eindeutige und leicht verständliche Erläuterung, was
C# - RabbitMQ-Client thread-Sicherheit
1 Antworten
ConnectionFactory factory = new ConnectionFactory {HostName = "localhost"}; using (IConnection connection = factory.CreateConnection()) using (IModel channel = connection.CreateModel()) { channel.QueueDeclare("hello", false, false, false, null); for (int i = 0; i < 100000; i++) { MemoryStream stream =
Queue-Größe in Spring AMQP-Java-client
2 Antworten
Bin ich mit Spring amqp version 1.1 als mein java-client. Ich habe eine Warteschlange, die rund 2000 Meldungen. Ich will einen service haben die Prüfungen dieser queue-Größe und und wenn es leer ist, sendet Sie eine Meldung
Erste Zählung der Nachrichten in einem rabbitmq Warteschlange von java-code
2 Antworten
Ich versuche, um zu überprüfen, ob eine gegebene rabbitmq Warteschlange leer ist oder nicht. Für die, die ich versuche zu verwenden: channel.queueDeclarePassive(queueName).getMessageCount(). Mit diesem bin ich immer 0 als Antwort, unabhängig von der Anzahl der angezeigten Nachrichten
Sollte ich in der Nähe der Kanal/Anschluss nach jeder veröffentlichen?
1 Antworten
Ich bin mit amqplib in Node.js und ich bin nicht klar über die besten Praktiken in meinem code. Im Grunde meinem aktuellen code ruft die amqp.connect() wenn Sie den Node-server gestartet wird, und dann verwendet einen anderen
RabbitMQ und C#
1 Antworten
Mit RabbitMQ gibt es einen Weg, es zu benutzen, ähnlich MSSMQ wo kann man pop 1000 Nachrichten aus der Warteschlange, dann machen Sie Ihre Einsätze, um die Datenbank und von dort aus weiter. Ich kann nicht scheinen
RabbitMQ und round-robin-Thema Austausch
1 Antworten
Ich bin auf der Suche nach einer beraten, wie man am besten konfigurieren Sie meine rabbitMQ Austausch. Ich versuche, ein Thema exchange in einer round-robin-Methode. Jeder Verbraucher hat seine eigenen (eindeutigen) namens-Warteschlange angefügt, um ein Thema exchange.
Kann nicht starten, RabbitMQ
3 Antworten
Ich habe Gegoogelt so viel, und nicht bekam keine richtige Antwort.So , ich bin Entsendung diese Frage für das bessere Ergebnis. Habe ich schon getötet, die RabbitMQ server-Prozess . Nun, wenn ich versuche ihn neu zu starten,
RabbitMQ Verbraucher als windows-Dienst
3 Antworten
Ich habe einen rabbitmq-consumer-Anwendung implementieren "publish/subscribe-pattern .net, das läuft perfekt, wie eine Konsole-Anwendung, aber wenn ich bereitstellen, die als windows-Dienst scheint es nicht zu sein, die Speicherung der Daten in mongodb. protected override void OnStart(string args) {
rabbitmq mehrere Verbraucher und mehrere publisher
2 Antworten
Wissen wollen, das Verhalten von rabbitmq mehrere publisher und Verbraucher. Tut rabbitmq-server gibt eine Nachricht an einen der Verbraucher zu einer Zeit, und andere Verbraucher sind ideal in dieser Zeit? ODER Verbraucher wählen Sie eine unbeaufsichtigte Nachricht
Unit-test auf rabbitMQ
2 Antworten
Ich habe eine Anwendung veröffentlicht, die Veranstaltung zu RabbitMQ und einem Verbraucher verbraucht der Veranstaltung. Meine Frage ist gibt es eine Möglichkeit zum schreiben eines unit-Tests testen die Funktionalität der Verbraucher. Nur zum hinzufügen dieser, der Verbraucher
Sellerie hat nicht gut funktionieren, weil der Fehlercode 104
2 Antworten
Ich habe ein problem mit der Ausführung Sellerie auf rabbitmq-server. Ich suchte und fand ein link, aber es hilft mir nicht. Mein env ist ubuntu 14.04, python 2.7.6, Sellerie 3.1.15, Django 1.7. Referenzierung ein link, die ich
RabbitMQ Warteschlange order management
2 Antworten
Ich bin derzeit auf der Implementierung rabbitMQ für ein tracking-system mit mehreren front-Produzenten schreiben auf der gleichen Warteschlange. Im Grunde habe ich zwei Arten von Nachrichten in der Warteschlange, als die tracking-workflow besteht aus zwei Schritten :
Wie installiere ich eine bestimmte version von erlang?
5 Antworten
Ich habe geerbt ein Projekt mit einer Puppe/Landstreicher/Virtual box-setup. Der Landstreicher Bestimmung brechen um meine erlangs umliegenden rabbitmq-server. den Fehler: ==> default: err: /Stage[main]/Rabbitmq::Install/Package[rabbitmq-server]/ensure: change from purged to present failed: Execution of '/usr/bin/apt-get -q -y -o DPkg::Options::=--force-confold
Wie zu Fragen, RabbitMQ zu wiederholen, wenn business-Ausnahme tritt im Frühjahr Asynchrone MessageListener Anwendungsfall
1 Antworten
Ich habe eine Spring AMQP message-listener läuft. public class ConsumerService implements MessageListener { @Autowired RabbitTemplate rabbitTemplate; @Override public void onMessage(Message message) { try { testService.process(message); //This process method can throw Business Exception } catch (BusinessException e) {
Sellerie und benutzerdefinierte Verbraucher
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
RabbitMQ Warten, bis eine Meldung mit einem timeout
4 Antworten
Ich würde gerne eine Nachricht senden, die eine RabbitMQ-server und warten dann auf eine Antwort-Nachricht (auf eine "reply-to" - Warteschlange). Natürlich, ich will nicht ewig warten, falls die Anwendung die Verarbeitung dieser Nachrichten ist down - muss
Sellerie: Wenn Sie wählen sollten, Redis als message-broker über RabbitMQ?
1 Antworten
Mein grobes Verständnis ist, dass Redis ist besser, wenn Sie die in-memory key-value-store-Funktion, jedoch bin ich nicht sicher, wie das zu tun hat mit der Verteilung von Aufgaben? Heißt das, wir sollten verwenden Redis als message-broker, WENN
Spring Boot konnte nicht autowire und ausführen
1 Antworten
Ich bin nicht in der Lage zu führen Sie die befestigt Spring-Boot-Anwendung sampler. Es verfügt über einen AMQP-starter, erfordern RabbitMQ. Grundsätzlich ist es eine einfache Anwendung, die nur sendet eine Nachricht an einen RabbitMQ-Austausch mit einer queue
Nicht-Anmeldung im RabbitMQ-Management web-Konsole
1 Antworten
Habe ich installiert RabbitMQ Server installiert CentOS 6.6 und hab ich auch installiert und aktiviert-Management-plugin. Wenn ich den Befehl ausführen rabbitmq-plugins list dies ist es, was ich in der Konsole: Configured: E = explicitly enabled; e =
Frühjahr: Nachricht senden, um websocket-clients
1 Antworten
Baue ich ein webchat mit Spring Boot, RabbitMQ und WebSocket als POC, aber ich bin stucked ein letzter Punkt: WebSockets Ich möchte meine ws-clients die Verbindung zu einem bestimmten Endpunkt, wie /room/{id} und wenn eine neue Nachricht
Ist es möglich, mehr als eine rabbitmq-Instanz auf einem Rechner?
4 Antworten
Ich bauen will ein RabbitMQ-cluster in meine dev-Maschine (windows). Grund ist, dass ich möchte, um zu testen und zu untersuchen. Ist es möglich, mehr als eine rabbitmq-Instanz auf einem Rechner? Ich vermute, ich muss: Ändern Sie den
Set-message-header in rabbitmq beim senden
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);
Wie kann ich die in die Warteschlange eingereiht Aufgaben in RabbitMQ?
4 Antworten
Ich bin mit RabbitMQ als meine message broker und meine Arbeiter sind Sellerie Aufgaben. Ich bin versuchen, um ein Problem zu diagnostizieren, wo ich bin enqueue Aufgaben zu RabbitMQ aber Sellerie nicht abholen, dann nach oben. Gibt
Pika Arbeiter wirft exception beim ausführen Kanal.declare_queue
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 - Wie um zu prüfen, ob queue leer ist?
2 Antworten
Ich habe eine web-service-Schnittstelle, die abstracts ein RabbitMQ-server (fragt mich nicht warum, ich weiss es ist ein unnötiger Schritt, aber ich muss). Das ist, ich Umfrage die Nachrichten aus der Warteschlange über einen web-service aufrufen, nicht direkt
pika.Ausnahmen.ProbableAuthenticationError, wenn Sie versuchen, um Nachricht zu senden, um remote-queue
1 Antworten
Ich versuche zu laufen RabbitMQ Python-tutorial aber mit Absender auf der virtualbox-host-Maschine und-Empfänger und die Warteschlange auf der virtualbox-Gast-Maschine. Also modifizierte ich erwähnt send.py code nur ersetzt localhost mit 192.168.1.5. Wenn ich es laufen lasse, erhalte ich
RabbitMQ asynchrone Unterstützung
3 Antworten
Macht die RabbitMQ .NET-client haben irgendeine Art von asynchroner support? Ich möchte in der Lage, eine Verbindung herstellen und konsumieren Nachrichten asynchron, aber habe noch keinen Weg gefunden, um zu tun, entweder so weit. (Für das konsumieren
Wie eine Verbindung zu RabbitMQ mit RabbitMQ JMS-client aus einer vorhandenen JMS-Anwendung?
3 Antworten
Habe ich eine generische standalone-JMS-Anwendung, die arbeitet mit folgenden JMS-Provider WebSphere, HornetQ und ActiveMq. Ich pass Kontext.INITIAL_CONTEXT_FACTORY und Kontext.PROVIDER_URL, die als Parameter an meine Anwendung, und erstellen Sie ein naming context, aus Ihnen etwas zu tun, wie
RabbitMQ: die Injektion der Verbindung Fabrik
2 Antworten
Ich bin versuchen, RabbitMQ für ein paar Windows-Dienste, die ich Schreibe, zur Erleichterung der Kommunikation zwischen Ihnen auf eine schnelle und zuverlässige Art und Weise. Allerdings bin ich im laufen in ein problem, wenn die versuchen, die
rabbitmq amqp - hören ack-Nachrichten von Verbrauchern
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 mit benutzerdefinierten Header zu speichern message-Parameter
1 Antworten
Ich bin neu RabbitMQ, und ich bin etwas verloren in der Dokumentation. Derzeit als ein Beispiel, den ich versuche zu bauen, ein kleines mailer-Dienst, der überwacht eine Warteschlange. Aber ich bin etwas stecken, wo sollte ich die
rabbitmq mehrere Verbraucher, die in einer Warteschlange - nur kriegt die Nachricht
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.
RabbitMQ ** WARNUNG ** Mnesia ist überlastet
4 Antworten
RabbitMQ-Cluster ist nicht zu akzeptieren, neue verbindungen! Die Anzahl der Steckdosen angeschlossen ist niedrig, die einzige Nachricht in Rabbitmq Protokoll: * * * ACHTUNG * * Mnesia ist überlastet Was bedeutet das? Wie kann ich es lösen?
In Pika oder RabbitMQ, Wie kann ich überprüfen, ob alle Verbraucher sind derzeit in Anspruch genommen?
2 Antworten
Ich würde gerne überprüfen, ob eine Verbraucher/Arbeitnehmer anwesend ist, um zu konsumieren, ein Nachricht ich bin zu senden. Wenn es keine Arbeiter, würde ich anfangen, einige Arbeiter (sowohl die Konsumenten als auch Publisher sind auf einer einzigen
Frühjahr SimpleMessageListenerContainer für RabbitMQ ist Abbruch auf ungültige Nachricht
1 Antworten
Ich bin mit Federn SimpleMessageListenerContainer zu konsumieren-Nachrichten von einem RabbitMQ Warteschlange. Alles funktioniert gut, aber wenn eine ungültige Nachricht an die Warteschlange gesendet wird (z.B. ungültige json) den Hörer einfach abgebrochen wird, ist das Herunterfahren des Arbeitnehmers
AMQP 0-9-1 vs 1-0
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
Wie kann ein RabbitMQ-Client sagen, wenn es verliert die Verbindung zum server?
2 Antworten
Wenn ich bin immer in Verbindung zu RabbitMQ und das warten auf Ereignisse mit einem EventingBasicConsumer, wie kann ich feststellen, ob ich schon vom server getrennt? Ich weiß, es ist ein Shutdown-event, aber es hat nicht Feuer,
Verbindung geschlossen rabbitmq aus irgendeinem Grund nach einiger Zeit
3 Antworten
Bin ich mit pika-python-Bibliothek, um eine Verbindung zu rabbitmq-server auf localhost. class BaseRabbitSender(MessageSender): __metaclass__ = ABCMeta def __init__(self, host): self.node = BaseMessagingNode(host) self.connection = pika.BlockingConnection(pika.ConnectionParameters( host=host)) self.channel = self.connection.channel() @abstractmethod def send_message(self, message): pass def close_connection(self): self.connection.close()
Wie entfernen, Rabbitmq, damit ich neu installieren kann
3 Antworten
Ich hatte Schwierigkeiten, also ging ich in die registry und entfernt den service-Eintrag für rabbitmq. Wenn ich jetzt versuche neu zu installieren, es sagt, es ist bereits vorhanden aber es startet nicht (da habe ich es entfernt)
Sellerie - call-Funktion auf die Aufgabe
1 Antworten
Ich bin mit Sellerie mit django und rabbitmq zum erstellen einer message queue. Ich habe auch ein Arbeiter, der ursprünglich aus einer anderen Maschine. In einem django, das ich beginne einem Prozess wie diesem: def processtask(request, name):
Was bedeutet MassTransit hinzufügen RabbitMQ?
1 Antworten
Was ist der nutzen von Gebäude oben auf MassTransit im Vergleich zu Gebäude direkt auf RabbitMQ? Ich glaube, dass der Vorteil von MassTransit ist " Typ " exchange (das publish-subscribe-interface /Typ), damit der Inhalt der Nachricht strukturiert