Tag: message-queue
„Message queue“ ist ein design-pattern oder software-engineering-Komponente, die definiert, Disziplin oder API für die Kommunikation zwischen zwei oder mehr miteinander verbundenen Prozesse oder Systeme. Die message queue erzwingt asynchrone Verarbeitung und lose Kopplung. Je nach der Implementierung können Sie bieten auch Lieferung und Bestellung garantiert der Nachrichten. Die Message-Verarbeitung Garantien werden ausdrücklich ausgeschlossen von der Gestaltung.
Tun Nachrichten in der dead letter-Warteschlange in der Azure-Service-Bus ablaufen?
2 Antworten
Tun Nachrichten in der dead letter-Warteschlange in der Azure Service Bus ab? Eine Erklärung Ich habe diesen queue-Einstellungen: var queueDescription = new QueueDescription("MyTestQueue") { RequiresSession = false, DefaultMessageTimeToLive = TimeSpan.FromMinutes(1), EnableDeadLetteringOnMessageExpiration = true, MaxDeliveryCount = 10 };
Error-Implementierung von posix message queue - Funktion "nicht implementiert"
1 Antworten
Schreibe ich diesen code, um ein posix message queue. Aber ich erhalte eine Fehlermeldung "Funktion nicht implementiert". Q1. Ist es ein Plattform-bezogene Frage ? [Bin mit Ubuntu 10.10] ich habe irgendwo gelesen, dass ich wiederherstellen müssen, dass
Wie zu erkennen, wenn eine Aufgabe bereits in der Warteschlange im django-celery?
3 Antworten
Hier ist mein setup: django 1.3 Sellerie 2.2.6 django-celery 2.2.4 djkombu 0.9.2 In meinem settings.py Datei habe ich BROKER_BACKEND = "djkombu.transport.DatabaseTransport" d.h. ich bin nur mit der Datenbank in die Warteschlange Aufgaben. Nun zu meinem problem: ich
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
Memcache-basierten message-queue?
5 Antworten
Arbeite ich an einem multiplayer-Spiel, und es muss eine message queue (d.h., Nachrichten, Nachrichten, keine Duplikate oder gelöschte Nachrichten vorausgesetzt es gibt keine unerwarteten cache-Verdrängungen). Hier sind die memcache-basierte Warteschlangen ich bin mir dessen bewusst: MemcacheQ: http://memcachedb.org/memcacheq/
Ist es möglich leer eine job-Warteschlange auf einem Gearman-server
3 Antworten
Ist es möglich leer eine job-Warteschlange auf einem Gearman-server? Ich bin mit dem python-Treiber für Gearman, und die Dokumentation keine Informationen über die Entleerung von Warteschlangen. Ich könnte mir vorstellen, dass diese Funktion vorhanden sein sollte, evtl.
Warteschlangen gegen den Tabellen-messaging-Systeme
5 Antworten
So wie es momentan steht, diese Frage ist nicht eine gute Passform für unsere Q&A-format. Wir erwarten Antworten auf Tatsachen gestützt, Referenzen und know-how, aber diese Frage wird wahrscheinlich werben Debatte, Argumente, polling, oder erweiterte Diskussion. Wenn
Senden komplexe Datenstruktur über boost message queue
2 Antworten
Ich habe die folgende Datenstruktur: typedef struct { short id; string name; short age; } person_struct; Mit boost message queue, ich habe versucht, das senden dieser Daten-Struktur an die message queue Empfänger in einem anderen Prozess. Aber,
MSMQ-v-Datenbank-Tabelle
11 Antworten
Einen bestehenden Prozess ändert sich das Feld status einer Buchung Datensatz in einer Tabelle, in Reaktion auf Benutzereingaben. Habe ich einen anderen Prozess zu schreiben, dass wird asynchron ausgeführt für Datensätze mit einem bestimmten status. Es Lesen
JBoss JMS-Warteschlange Remote?
2 Antworten
Will ich Nachrichten senden, um remote-queue ? welche Schritte soll ich tun ich cant finden alle Unterlagen dazu ? wer kann helfen ?? ? InformationsquelleAutor Taha Yusuf | 2009-12-14
RabbitMQ Exchange Type-Vergleich: Thema vs. Kopf
1 Antworten
Wir bauen für Sie unser message-queue-system. Zwar werde über die RabbitMQ-exchange-Typen, die ich bemerkte, gibt es zwei mögliche Lösungen zur Umsetzung der multi-cast-Art der Weiterleitung von Nachrichten. Thema Exchange. Durch die Einrichtung ein Thema exchange-und eine routing-Schlüssel
Dynamisch erstellen asynchrone message queues in Java
5 Antworten
Muss ich erstellen, asynchrone message queues dynamisch in Java. Mein use-case ist das versenden von E-Mails über mehrere SMTP-Server: ich brauche, um zu erzwingen, dass E-Mails an den gleichen SMTP-server sind Prozesse, die sequentiell, aber E-Mails an
Wie kann ich suchen Sie eine Websphere MQ message, ohne es zu entfernen?
4 Antworten
Ich Schreibe ein .NET Windows Forms-Anwendung, mit der post eine Nachricht auf einem Websphere MQ-Warteschlange und dann poll eine andere Warteschlange für eine Antwort. Wenn eine Antwort zurückgegeben wird, wird die Anwendung teilweise Prozess der Reaktion in
Message Queue Ausnahme : die Warteschlange ist nicht vorhanden, oder Sie verfügen nicht über ausreichende Berechtigungen zum ausführen des Vorgangs
6 Antworten
In dieser Codezeile erhalte ich die Fehlermeldung wie ich bereits erwähnt Erklärte ich MSMQ_NAME als string wie folgt private const string MSMQ_NAME = ".\\private$\\ASPNETService"; private void DoSomeMSMQStuff() { using (MessageQueue queue = new MessageQueue(MSMQ_NAME)) { queue.Send(DateTime.Now); //Exception
Empfehlungen für C/C++ remote message queues
6 Antworten
Arbeite ich an einem Projekt, das beinhaltet mehrere C++ - Programme, die jeder der Eingaben und die Ausgabe generieren. Die Daten (Tausende von bytes, wahrscheinlich JSON) im wesentlichen fließt (asynchron) in eine Richtung, und die Programme müssen
Gibt es irgendwelche MQ-Server ausgeführt werden können, eingebettet in eine Java-Prozess?
2 Antworten
Ich bin die Erforschung queuing-Lösungen für eines meiner Teams-apps. Idealerweise würden wir gerne etwas, das kann so konfiguriert werden beide als eine leichte, in-process-broker (für geringen Durchsatz von Nachrichten zwischen threads) und als externe broker. Gibt es
Multithreaded single-reader single-writer-fifo-Warteschlange
4 Antworten
Brauche ich eine Warteschlange für die Weitergabe von Nachrichten von einem thread (a) zu Einer anderen (B), aber ich habe nicht in der Lage gewesen, einen zu finden, der wirklich das macht, was ich will, da Sie
Ist Apache Kafka geeignet für den Einsatz als ungeordnete task queue?
4 Antworten
Kafka teilt eingehende Nachrichten bis in Partitionen, nach der partition zugeordnet, die von den Produzenten. Nachrichten von Partitionen, dann Holen Sie sich verzehrt, indem Sie die Verbraucher in den verschiedenen Verbrauchergruppen. Diese Architektur macht mich vorsichtig bei
Was sind die Unterschiede zwischen pipes und message queues?
5 Antworten
Was sind die Unterschiede zwischen pipes und message queues? Bitte erklären, beide von vxworks & unix Perspektiven. Ich denke die pipes sind unidirektional, aber message queues nicht. Aber nicht Pfeifen intern verwenden die message-queues, dann kommen wie
IBM MQ für Datei-transfer
5 Antworten
Sind wir mit einer Entscheidung für die Verwendung mit IBM MQ über SFTP für den Dateitransfer. Ich habe gehört, die Vorteile solcher Ansatz, aber ich habe nie zu sehen, jemand tatsächlich Verwendung für große Dateien. Also wichtigste
Zentrales Netzwerk-logging - syslog-und alternativen?
6 Antworten
Bei der Arbeit, wir bauen eine verteilte Anwendung (womöglich über mehrere Maschinen im LAN, eventuell später über mehrere Kontinente hinweg auf einem WAN+VPN). Wir nicht wollen, dass log-Dateien lokal auf jeder Maschine (die füllen Ihre Festplatte und
Ist es empfehlenswert, leichte pubsub service/Bibliothek?
3 Antworten
Bin ich den Aufbau eines kleinen Systems, das enthält viele Teile, und ich will eine Nachricht pub/sub - Dienst für die Kommunikation zwischen teilen. Las ich über einige Nachrichten queue services wie RabbitMQ und ZeroMQ, aber ich
Count Anzahl der Nachrichten in einer JMS-queue.
2 Antworten
Was ist der beste Weg zu gehen über eine JMS-Warteschlange und erhalten Sie alle Nachrichten darin? Wie kann die Anzahl der Nachrichten in einer Warteschlange? Dank. Sie können mithilfe der jmx-in einigen Fällen (hängt von JMS-Implementierung) ich
Was ist der Sinn von Kafkas Schlüssel/Wert-paar-basierten messaging?
1 Antworten
Alle Beispiele von Kafka | Hersteller zeigen die ProducerRecord's Schlüssel/Wert-paar, wie nicht nur der gleiche Typ (alle Beispiele zeigen <String,String>), aber die gleichen Wert. Zum Beispiel: producer.send(new ProducerRecord<String, String>("someTopic", Integer.toString(i), Integer.toString(i))); Aber in die Kafka-docs, ich kann
Schlösser und batch-Holen von Nachrichten mit RabbitMq
3 Antworten
Ich versuche, RabbitMq in einer eher unkonventionellen Weg (obwohl an dieser Stelle kann ich wählen Sie eine andere message-queue-Implementierung, wenn nötig). Anstatt Kaninchen push-Nachrichten an meine Verbraucher, der Verbraucher eine Verbindung zu einem queue und holt einen
Einstellung einer langen timeout für RabbitMQ ack-Nachricht
1 Antworten
Ich Frage mich, ob dies möglich ist. Ich möchten, ziehen Sie eine Aufgabe aus einer Warteschlange und haben einige arbeiten, die potenziell überall von 3 Sekunden oder länger (möglicherweise) Minuten, bevor ein ack gesendet wird, zurück zum
Unterschied zwischen Apache Thrift und ZeroMQ
3 Antworten
Ich verstehe, dass Apache Thrift und ZeroMQ sind softwares, die zu verschiedenen Kategorien, und es ist nicht einfach zu tun, ein Vergleich, da es ist ein Apfel-orange-Vergleich. Aber ich weiß nicht, warum Sie gehören zu verschiedenen Kategorien.
Was ist der Unterschied zwischen einem message channel und message queue selbst?
3 Antworten
Was ist der Unterschied zwischen einem message channel und message queue selbst? Sie sind zwei verschiedene Dinge. Die Warteschlange tatsächlich enthält Nachrichten, die verarbeitet werden (geschoben in den Hörer) in FIFO-Weise. Ein Kanal ist ein medium, durch
Wann deleteLater
5 Antworten
Vorausgesetzt, ich habe Folgendes snippet, ist es sicher zu nennen, deleteLater in qto der Destruktor für andere QT-Objekte, die es möglicherweise verwalten? int main(int argc, char *argv) { QApplication a(argc, argv); MyQTObject qto; qto.show(); return a.exec(); }
Asynchrone vs. synchrone Web Services Praktiken?
1 Antworten
Ich wage zu behaupten, dass die meisten, aber nicht alle web-services sind heute synchron. Eine grundlegende design-Entscheidung, die bestehenden zu implementieren, wenn die asynchrone Verarbeitung. Ist es Wert in die Implementierung einer Verarbeitungs-Warteschlange-system für asynchrone web services?
OnTimer-Methode funktioniert nicht im MFC
1 Antworten
Erstellte ich eine MFC-Dialogfeld-basierten Anwendung in VS2010, und wollte noch hinzufügen-timer zu aktualisieren, ein Bild-controller, alle 3 Sekunden. Aber die OnTimer-Methode noch nie gearbeitet. Benutzt habe ich Sie Klasse Assistenten zum hinzufügen von WM_TIMER in die message-queue,
JBoss AS 7 einfache "hello world" - Anwendung
2 Antworten
Ich versuche einen einfachen JMS-Anwendung "Hello world" ausführen. Ich möchte versuchen, es auf JBoss Application Server 7, aber ich bin nicht in der Lage, um es auszuführen. Jboss HornetQ als embedden und ich begann ihn mit dem
C - Problem mit message passing zwischen threads mithilfe von Warteschlangen
3 Antworten
Ich versuche, die passieren Nachrichten zwischen 2 threads mit einer Warteschlange, aber ich habe nicht bekommen, keine Ergebnisse bisher. Wenn ich drucken Sie den Inhalt der Nachricht, nachdem Sie es empfangen, und bevor es gesendet wird, es
message queue makefile-Fehler: undefined reference to `mq_open'
2 Antworten
Obwohl ich gelinkt habe -lrt in meinem Makefile, wie Sie unten sehen können, ich bin noch immer undefined reference to 'mq_open'. Bitte um Hilfe!! all:get1 iserv1 get: get1.c gcc -Wall -o get1 get1.c -lrt iserv: iserv1.c gcc
message queue in C: Umsetzung 2-Wege-comm
1 Antworten
Ich bin ein student und ein begineer in C. ich möchte zu implementieren, 2-Wege-Kommunikation über message-queue in C linux. Brauche ich zwei Warteschlangen oder nur eine, um dies getan? Ich würde auch gerne wissen, kann ich Daten
Message queue: msgsnd failed : Invalid argument
1 Antworten
Kann jemand bitte helfen mir zu zeigen, wie was ist der Fehler in meinem Programm? Vielen Dank im Voraus, kingsmasher1 #include <stdio.h> #include <unistd.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <string.h> #include <errno.h> typedef struct msgbuf
Wie selektives löschen von Nachrichten aus einem AMQP (RabbitMQ) - Warteschlange?
4 Antworten
Ich würde gerne selektives löschen von Nachrichten aus einem AMQP-Warteschlange ohne auch Sie zu Lesen. Das Szenario ist wie folgt: Versenden Seite will expire Nachrichten des Typs X basiert auf einer Tatsache, dass neue Informationen vom Typ
Fehler "falsche Adresse" beim Lesen von message queue auf Linux
1 Antworten
Habe ich-Zuordnung beim schreiben brauche ich einfach mal server und einen client mit Linux-message-queue. Der server öffnet eine message-queue und der client sendet eine Anfrage mit seiner PID (Nachricht mit Typ-1) und der server liest die Nachricht
Wie kann ich die Bereinigung der IPC-message-queue?
4 Antworten
Ich bin mit msgget() Funktion in meinem IPC-basierte Anwendung. Wie kann ich das bereinigen der Warteschlange gefüllt mit alten message queues? InformationsquelleAutor AJ. | 2009-10-12
Ausführen eines Delegierten in den ui-thread (mit message-Pumpe)
5 Antworten
Habe ich einen hintergrund-thread, der die Kommunikation mit einem externen Dienst. Jedes mal, wenn der hintergrund-thread eine Nachricht empfängt, die würde ich gerne an den UI-thread für die weitere Verarbeitung (Anzeige Benutzer). Derzeit habe ich eine thread-sichere
Holen Sie sich Haupt-thread message queue handler und
3 Antworten
Wie bekomme ich die message queue des main Threads aus einem anderen thread? Looper.getMainLooper() wird der Haupt-thread ' s "looper" aber ich bin nicht in der Lage, einen Weg zu finden, um die MessageQueue für einen anderen
mq_open: Invalid argument
1 Antworten
Ich versuche, führen Sie das Beispiel-Programm für POSIX message queues gefunden in der Mann Seite für mq_notify. Ich bin als ./mq '/bla' und es gibt mir die Fehlermeldung mq_open: Invalid argument. Dies ist die Zeile in der
Veröffentlichen Sie mehrere Nachrichten zu RabbitMQ aus einer Datei
5 Antworten
Publishing einzelnen Nachrichten zu einem RabbitMQ Warteschlange kann leicht getan werden mit der Benutzeroberfläche, indem Sie die Nachricht in der Benutzeroberfläche und klicken auf "Nachricht Veröffentlichen" - button. Wie veröffentlichen Sie einen Stapel von Nachrichten? Ich habe
Planen von E-Mails zu versenden
5 Antworten
Verwendung von PHP, ich habe eine Frage, das geht über meine DB suchen für anstehende Aufgaben mit Erinnerung auslöst, zu bestimmten Zeiten des Tages. Ich habe ein cronjob läuft alle 10 Minuten und prüft die DB für
Was passiert, wenn eine Meldung wird zurückgesetzt, im MQ?
3 Antworten
Erhalte ich eine Nachricht von einer WebSPhere MQ-Warteschlange. Ich versuche zu verarbeiten und wenn ich bekomme einige Ausnahmen, an die ich zurücksetzen möchten Sie die Nachricht an die MQ-Warteschlange. Ich habe keine Probleme in das gleiche tun.
Befehl zum prüfen des status der message-queue und shared memory unter linux?
1 Antworten
Sorry für so eine dumme Frage stellen als ich bin noob auf unix. was sind die unix-Befehle zu finden, shared memory und message-queue und wie Sie zu töten ? InformationsquelleAutor zishan | 2013-09-13
ActiveMQ - löschen/purge all-queue über die Kommandozeile
5 Antworten
Gibt es eine Möglichkeit zu löschen /purge alle Warteschlangen in ActiveMQ über die Kommandozeile (win/linux)? Ich konnte nur die Befehle für eine bestimmte queue. Oder vielleicht gibt es eine Möglichkeit, dies zu tun über die activeMQ-admin? Wieder
worker-Warteschlange für nodejs?
3 Antworten
Ich bin in den Prozess von Anfang an zu schreiben, ein worker-Warteschlange für Knoten mit Knoten - cluster-API und mongoose. Ich bemerkt, dass eine Menge libs vorhanden sind, die dies bereits tun, aber mit redis und Verzweigung.
Android-Handler Message-und ListView
1 Antworten
Hier ist mein Fehler: *** Uncaught remote exception! (Exceptions are not yet supported across processes.) android.util.AndroidRuntimeException: { what=1008 when=368280372 } This message is already in use. at android.os.MessageQueue.enqueueMessage(MessageQueue.java:171) at android.os.Handler.sendMessageAtTime(Handler.java:457) at android.os.Handler.sendMessageDelayed(Handler.java:430) at android.os.Handler.sendMessage(Handler.java:367) at android.view.ViewRoot.dispatchAppVisibility(ViewRoot.java:2748) Was
Warum muss der SetWindowsHookEx verwendet werden, die mit einer windows-message queue
2 Antworten
Ich versuche schon einige Dinge mit Haken, und ich verstehe nicht, warum die Haken müssen verwendet werden, mit einer message queue hook = SetWindowsHookEx(WH_KEYBOARD_LL, KeyboardProc, NULL, 0); MSG msg; while(GetMessage(&msg, NULL, 0, 0) > 0) { TranslateMessage(&msg);