rabbitmq

0Hitze

1Antwort

Rabbitmq: Ändern Sie Nachrichtentext vor dem Verzehr

Ich bin neu in RabbitMQ und ich möchte eine Nachricht vor dem Konsumieren von einer Warteschlange ändern. Ich habe einen Austausch, der unantastbar bleiben sollte. Der Client empfängt Nachrichten mit

java rabbitmq message-queue amqp 2016-03-21

---

0Hitze

3Antwort

Verwalten Sie benutzerdefinierte Prozessor Ausnahme mit Rabbitmq Bus

Ich habe ein benutzerdefiniertes Prozessormodul, die Ausnahme auslösen könnte gemacht. Aber wenn eine Ausnahme auftritt, kann ich den StackTrace nicht in der Protokolldatei oder in der Standardausgabe

rabbitmq spring-xd 2016-03-22

---

1Hitze

2Antwort

RabbitMQ - So konfigurieren Sie bedingte DLX?

Ich habe aktive Warteschlange, die alle Nachrichten von Publisher haben wird. Mein Consumer liest diese Nachrichten und Acks/Nacks abhängig vom Ergebnis der Nachrichtenverarbeitung. while (true) {

c# rabbitmq 2016-03-22

---

1Hitze

1Antwort

Wie zu veröffentlichen und zu konsumieren make (map [string] string) in rabbitmq go lang

Ich habe mehrere Objekte von Schlüssel-Wert-Typ, die ich an RabbitMQ senden muss und daher vorwärts sie verbrauchen würde. Also, nach dem Durchlaufen dieser RabbitMQ Verbindung. Es gibt nur die Möglic

go rabbitmq rabbitmqctl 2016-03-23

---

2Hitze

1Antwort

Ob eine Verbindung jedes Mal erstellt wird, wenn amqp.Dial threadsafe ist oder nicht in go lang

Wie in den RabbitMQ-Dokumenten erwähnt, sind TCP-Verbindungen teuer in der Herstellung. Also, für dieses Konzept des Kanals wurde eingeführt. Jetzt stieß ich auf diese example. In der main() erstellt

go rabbitmq rabbitmqctl 2016-03-23

---

-1Hitze

1Antwort

RabbitMQ Frühling Boot org.springframework.beans.factory.NoSuchBeanDefinitionException

Ich versuche RabbitMQ zu lernen, mit SpringBoot i erstellen haben zwei Klassen: Receiver.java (es ist ein POJO): Diese Klasse wird die Nachricht empfangen. public class Receiver { private CountD

java spring-boot rabbitmq spring-rabbit 2016-03-23

---

1Hitze

1Antwort

Wie wird eine periodische Aufgabe in die Warteschlange gestellt, wenn sie in Sellerie beendet wird?

Angenommen, es gibt eine periodische Aufgabe, die jede Stunde ausgeführt werden soll. Ein Mitarbeiter empfängt die Aufgaben und beginnt mit der Verarbeitung. Während der Bearbeitung der Aufgabe wird d

django rabbitmq celery 2016-03-23

---

1Hitze

2Antwort

Kann nicht bei rabbitMQ cluster: Fehler: nodedown

Ich bin neu bei RabbitMQ und Linux. Ich verfolge Clustering bei https://www.rabbitmq.com/clustering.html Ich habe drei Knoten alle CentOS 7 ausgeführt wird (auf virtuellen Maschinen mit Statik IPs). I

rabbitmq cluster-computing 2016-03-24

---

2Hitze

1Antwort

Warum bekomme ich bei der Anfrage die gleiche Nachricht von RabbitMQ?

Hintergrund Es gibt zwei Nachrichten in meiner Warteschlange: foo bar Ich habe einen Kanal, einen Verbraucher mit Qos aktiv mit einer Prefetch Zahl von 1 . Szenario Eine Nachricht Lieferung foo kommt

rabbitmq amqp 2016-03-24

---

4Hitze

1Antwort

Sellerie: socket.error timed out

Ich verwende: celery==3.1.12 kombu==3.0.19 amqp==1.4.5 Sellerie Arbeiter gestartet wurde: celery worker --without-gossip --without-heartbeat --without-mingle Sellerie setiings: CELERY_ALWAYS_EAG

python sockets rabbitmq celery kombu 2016-03-24

---