Suchergebnisse für Anfrage "rabbitmq"
esten der RabbitListener-Methode in der SpringBoot-A
Code RabbitMQListener: @Component public class ServerThroughRabbitMQ implements ServerThroughAMQPBroker { private static final AtomicLong ID_COUNTER=new AtomicLong(); private final long instanceId=ID_COUNTER.incrementAndGet(); @Autowired ...
RabbitMQ C # API - ereignisbasierter Nachrichtenverbrauch
while (true) { BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); IBasicProperties properties = e.BasicProperties; byte[] body = e.Body; Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body)); ...
Wie lösche ich selektiv Nachrichten aus einer AMQP (RabbitMQ) -Warteschlange?
Ich möchte Nachrichten selektiv aus einer AMQP-Warteschlange löschen, ohne sie zu lesen. Das Szenario sieht wie folgt aus: ie sendende Seite möchte Nachrichten vom Typ X ablaufen lassen, basierend auf der Tatsache, dass neue Informationen vom ...
Wie erreicht man die Parallelität mit einem nicht threadsicheren MessageListener?
Die Antwort aufdiese Frag [https://stackoverflow.com/questions/23341811/how-is-concurrency-in-spring-amqp-listener-container-implemented] erklärt die Verwendung des Prototypbereichs mit<rabbit:listener-container/> in Spring AMQP, wenn der ...
Scheduled / Delay messaging im Frühjahr AMQP RabbitMq
Ich habe große Mühe, den Weg für geplante / verzögerte Nachrichten in Spring AMQP / Rabbit MQ zu finden. Nach höllisch vielem Suchen kann ich das im AMQP-Frühling noch nicht. Kann mir bitte jemand sagen, wie es geht x-delay im Frühjahr AMQP. Ich ...
Sellerie: Wie kann man die Anzahl der Aufgaben in der Warteschlange begrenzen und den Fütterungsvorgang beenden, wenn sie voll sind?
Ich bin sehr neu bei Sellerie und hier ist die Frage, die ich habe: Angenommen, ich habe ein Skript, mit dem ständig neue Daten aus der Datenbank abgerufen und mit Sellerie an die Mitarbeiter gesendet werden sollen. tasks.py # Celery Task ...
Unmarshaling in eine Schnittstelle {} und anschließendes Durchführen einer Typzusicherung
Ich bekomme einstring durch ein rabbitmq Nachrichtensystem. Vor dem Absenden Ich benutzejson.Marshal, konvertiere das Ergebnis instring und senden Sie durch rabbitmq. Die Strukturen, die ich konvertiere und sende, können sein: (die Namen und ...
Ob die Verbindung jedes Mal hergestellt werden soll, wenn amqp.Dial threadsicher ist oder nicht in go lang
Wie in den RabbitMQ-Dokumenten erwähnt, sind TCP-Verbindungen teuer in der Herstellung. Also wurde für dieses Konzept der Kanal eingeführt. Jetzt bin ich auf dieses @ gestoßBeispie [https://www.rabbitmq.com/tutorials/tutorial-four-go.html]. In ...
Nachrichten mit toten Buchstaben werden nach ttl @ nicht in die ursprüngliche Warteschlange eingerei
ch habe vor, die Verarbeitung von Nachrichten in der Warteschlange zu verzögern, indem ich diesen beiden Links folg link1 [http://yuserinterface.com/dev/2013/01/08/how-to-schedule-delay-messages-with-rabbitmq-using-a-dead-letter-exchange/] ...
wie man den RPC-Mechanismus mit RabbitMQ in Java implementiert
Wie implementiere ich RPC-Mechanismus (sowohl Hersteller als auch Verbraucher) mit RabbitMQ in Java? Ich besuche auch die offizielle Websitehttp: //www.rabbitmq.com/api-guide.html#rp [http://www.rabbitmq.com/api-guide.html#rpc] aber ich bekomme ...