Suchergebnisse für Anfrage "message-queue"
Wie kann ich parallel Nachrichten aus einer Warteschlange lesen?
SituatioWir haben eine Nachrichtenwarteschlange. Wir möchten Nachrichten parallel verarbeiten und die Anzahl der gleichzeitig verarbeiteten Nachrichten begrenzen. Unser unten stehender Testcode verarbeitet Nachrichten parallel, startet ...
Python führt Threads nach Reihenfolge aus
Ich habe den folgenden Code: import threading def send_to_server(lst): #Some logic to send the list to the server. while 1: lst = [] for i in range(1000): lst.append(i) task = threading.Thread(target=send_to_server,args(copy(lst),)) ...
Ist Apache Kafka für die Verwendung als ungeordnete Task-Warteschlange geeignet?
Kafka teilt eingehende Nachrichten entsprechend der vom Produzenten zugewiesenen Partition in Partitionen auf. Nachrichten von Partitionen werden dann von Verbrauchern in verschiedenen Verbrauchergruppen konsumiert. Diese Architektur macht es ...
Azure Service Fabric und Message Queues
äre es in Verbindung mit Azure Service Fabric ein Anwendungsfall, auch eine separate Warteschlangenlösung wie Windows Service Bus zu verwenden? Die Nachteile wären wahrscheinlich ein neuer Single Point of Failure, aber gibt es auch Vorteile? ...
Viele Verbraucher in der SQS-Warteschlange verwenden
Ich weiß, dass es möglich ist, eine SQS-Warteschlange mit mehreren Threads zu belegen. Ich möchte garantieren, dass jede Nachricht einmal verbraucht wird. Ich weiß, dass es möglich ist, das Sichtbarkeitszeitlimit einer Nachricht zu ändern, z. B. ...
Wie kann ich eine Nachricht in RabbitMQ zurückziehen?
Ich habe so etwas wie eine Job-Warteschlange über RabbitMQ und möchte auf die Aufforderung hin, einen Job abzubrechen, die noch nicht verarbeiteten Tasks zurückziehen (deren Nachrichten wurden noch nicht bestätigt), was entspricht Zurückziehen ...
Tibco EMS-Protokoll
Ich versuche, mit node.js eine Schnittstelle zu einem Tibco EMS-Server herzustellen, und bin gespannt, ob dies mit Open-Source-Lösungen nur in node.js möglich ist. Ich möchte die Web Messaging-Lösung von Tibco nicht verwenden. So dann bringt ...
MSMQ v Datenbanktabelle
Ein vorhandener Prozess ändert das Statusfeld eines Buchungsdatensatzes in einer Tabelle als Reaktion auf Benutzereingaben. Ich muss einen anderen Prozess schreiben, der für Datensätze mit einem bestimmten Status asynchron ausgeführt wird. Es ...
Warum benötigen Sie eine Nachrichtenwarteschlange für einen Chat mit Web-Sockets?
Ich habe im Internet viele Beispiele für Chats mit Web-Sockets und RabbitMQ gesehen https: //github.com/videlalvaro/rabbitmq-cha [https://github.com/videlalvaro/rabbitmq-chat]) Ich verstehe jedoch nicht, warum es eine Nachrichtenwarteschlange für ...