amqp

1Hitze

1Antwort

RabbitMQ: Nachrichten an Threads routen

Ich habe eine Anwendung geschrieben in Ruby, die mehrere Threads hat, die jeweils Anforderungen an Remote-AMQP-Endpunkte senden. Diese Threads werden von Zeit zu Zeit erzeugt, wenn neue Aufgaben ausge

ruby rabbitmq amqp 2016-07-30

---

0Hitze

1Antwort

Frühling Wolke Stream-Konflikte mit Hystrix

Ich habe ein RestController mit Hystrix und Frühling Wolke Stream- Kanäle: @RestController @RequestMapping(value = "/api/products") @EnableBinding(ProductProcessor.class) public class ProductUiCont

java amqp microservices hystrix spring-cloud-stream 2016-08-03

---

0Hitze

1Antwort

Die Verbindung wurde zurückgesetzt mit RabbitMQ

Helo, Ich bin wirklich neu bei rabbitmq. Ich habe versucht, einen Rabbitmq Router einzurichten und ihm eine HelloWorld in Python mit Pika zu schicken. In Terminal ich Sudo Rabbitmq-Server starten. Ich

python rabbitmq amqp pika rabbitmqctl 2016-08-04

---

0Hitze

1Antwort

RabbitMQ: Ich nehme immer nur eine Nachricht aus mehreren Warteschlangen auf

Ich versuche, mit mehreren Warteschlangen in RabbitMQ verbunden zu bleiben. Jedes Mal, wenn ich eine neue Nachricht aus einer dieser Warteschlangen aufrufe, möchte ich einen externen Prozess erstellen

python rabbitmq amqp pika 2016-08-08

---

0Hitze

1Antwort

RabbitMq direkte Warteschlange, die nicht in "Bereit" Zustand ansammelt?

Ich würde eine Warteschlange benötigen, die nicht in "Bereit" Zustand ansammelt. Das heißt, wenn ein Teilnehmer der Warteschlange ist, übergeben Sie die Nachrichten von der Vermittlungsstelle direkt a

rabbitmq amqp 2016-08-08

---

0Hitze

1Antwort

Consumer nicht zur Kenntnisnahme Nachricht

Ich habe eine channel.basic_ack jedoch, wenn ich in der Rabbitmq Admin UI eincheck, bleibt es unplugged eher als acked. Hier ist mein Code die Nachricht def handle_payload(self, channel, method, prope

python-2.7 rabbitmq message-queue amqp pika 2016-06-29

---

4Hitze

1Antwort

Camel RabbitMQ Verbindung mit Kamel amqp

Ich versuche, mit Kamel-amqp (Version 2.17) -Komponente auf meinem Kamel Route zu Rabbitmq verbinden. ich konfiguriert haben es wie folgt: @Bean CachingConnectionFactory jmsCachingConnectionFacto

rabbitmq apache-camel amqp 2016-07-08

---

0Hitze

1Antwort

Warum zeigt ein Sellerie-Backend nicht auf eine IP, die nicht lokal arbeitet?

from celery import Celery app = Celery('tasks', backend='amqp://[email protected]', broker='amqp://[email protected]//') @app.task() def add(x, y): return x + y Ich bin erfolgreich in der

python rabbitmq task celery amqp 2016-07-08

---

0Hitze

1Antwort

Einstellung der `max_frame_size` der Verbindung in Qpid Proton AMQP 1.0 Client-Bibliothek

Ich möchte einfach eine AMQP 1.0-Verbindung mit einer bestimmten max_frame_size unter Verwendung der Apache Qpid Proton client library öffnen. Dies ist in einer Testsuite, keine reale Anwendung. Die J

java amqp qpid 2016-07-11

---

0Hitze

1Antwort

Objekt kann nicht deserialisiert werden, das LocalDate von AMQP messaging enthält

Ich versuche, ein Objekt über AMQP messaging (RabbitMQ) zu senden, aber wenn ich die Nachricht erhalte, löst der Konverter eine JsonMappingException aus, da die Nachricht nicht deserialisiert werden k

java json serialization jackson amqp 2016-07-13

---