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.
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 };
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
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
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
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/
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.
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
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,
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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.
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
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(); }
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?
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,
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
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
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
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
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
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
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
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
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
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
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
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
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
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.
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
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
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.
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
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);