Tag: publish-subscribe

Einem typischen Redis-chat-Beispiel wird etwa so gehen (siehe https://github.com/emrahayanoglu/Socket.io-Redis-RealTime-Chat-Example/blob/master/chatServer.js für nur ein Beispiel): io.sockets.on('connection', function (client) { //websocket connection redis1.subscribe("chat"); redis1.on("message", function(channel, message) { console.log(message); client.send(message); }); client.on('message', function(msg) { redis2.publish("chat",msg.message); }); client.on('disconnect', function() { redis1.quit(); });

Ich habe das Spiel mit Eckigen und haben versucht, einen Weg finden, um ein pub/sub-Mechanismus über die gesamte Komponente Baum. Scheint es, dass EventEmitter ist nur emittierenden eine Veranstaltung, die abonniert werden können, um eine Ebene nach

Lese ich die hornetQ-Dokumentation, verwirrt viele. Kann jemand ein genaues Beispiel erstellen Sie ein JMS-Thema in hornetQ. Ich meine die xml-Konfigurationen in hornetq-jms.xml und hornetq-configuration.xml. angenommen, wir haben ein Thema mit dem Namen top und 2 Abonnenten

Bin ich einen Auftrag erstellen, drücken Sie auf, um eine benutzerdefinierte Warteschlange, und zu versuchen, die Redis-Treiber, um dann den job zu behandeln, wenn es Sie trifft die Warteschlange, ohne Erfolg: class MyController extends Controller { public

Habe ich gebaut, dieses Beispiel: Erste Schritte Mit RabbitMQ in .net, aber aus 2 Programmen: eine-Verlag one-Abonnenten Ich bin mit BasicPublish zu veröffentlichen und zu BasicAck zu hören, wie im Beispiel. Wenn ich einen Verleger und mehrere

Ich geschrieben habe, ein system, das eine Duplex-NetTcp-Kanal mit einer callback-Funktion als publish/subscribe-server. Habe ich dir über die callback-Timeout, wenn keine Verbindung gesendet wird, nach einer Weile oder wird die callback-Rohr unbestimmte Zeit aufrechterhalten werden? InformationsquelleAutor Omar

Ich bin ein Anfänger zu Redis und Kafka. Redis kann verwendet werden, als Echtzeit-pub-sub. Aber Kafka ist auch Echtzeit-pub-sub. Ich bin verwirrt, die man zu nutzen, wenn. Jeder Anwendungsfall wäre eine große Hilfe! Danke! InformationsquelleAutor Sweta Sharma

In diesem PlunkerDemo, ich versuche, die Sendung ein Ereignis von der übergeordneten Steuerung an untergeordnete controller. Jedoch tun Sie es direkt in dem übergeordneten controller wird nicht funktionieren. Der handler nicht registriert das Ereignis. Allerdings tut es

RabbitMQ ist Channel#basicConsume Methode gibt uns die folgenden Argumente: channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback); Geben uns die Möglichkeit zu sagen, RabbitMQ genau die Warteschlange, die wir konsumieren wollen. Aber Channel#basicPublish hat keine solche äquivalenz: channel.basicPublish(exchangeName,

Wie bekomme ich ZeroMQ zu unterstützen, Themen und pattern-matching? z.B. stocks.* stocks.appl Aus meinem Verständnis ZeroMQ..das Thema wird Teil der Nachricht, also muss ich irgendwie trennen, das Thema von der eigentlichen Nachricht in den Abonnenten. Was ist

Brauchen Hilfe bei der Nutzung von Azure event hubs in das folgende Szenario. Ich denke, dass Verbrauchergruppen könnte die richtige option für dieses Szenario, aber ich war nicht in der Lage zu finden, ein konkretes Beispiel online.

Ich bin neu bei JMS.Ich habe angefangen mit " Hallo Welt, wo ich bin, die Veröffentlichung der Nachricht von der java-Anwendung zum Thema und hören Sie von der client - (node.js javascript).Ich gegangen thru http://en.wikipedia.org/wiki/Java_Message_Service. Jetzt habe

Ich versuche zu implementieren, das pub-sub-design pattern mit zeromq Rahmen. Die Idee ist, starten Sie eine Abonnenten-und danach starten die publisher. Die Teilnehmer hören zu 100 Nachrichten und die publisher veröffentlichen wird 100 Nachrichten. So weit So

Wie nennt man eine Handlung von einer anderen Handlung, wenn eingewickelt in actions in einem EmberJS-controller? Ursprünglichen code, der verwendet die jetzt veraltete Art und Weise zu definieren Aktionen: //app.js App.IndexController = Ember.ArrayController.extend({ //properties /* ... */

Socket.IO scheint zu den beliebtesten und aktive WebSocket-Bibliothek-emulation. Moloch verwendet es, um einen ganzen pub/sub-system. Faye ist auch sehr beliebt und aktiv, und hat seine eigene javascript-Bibliothek, die Ihre volle Funktionalität vergleichbar mit Juggernaut. Moloch verwendet Knoten

redis unterstützt pub-sub - zmq unterstützt auch pub-sub über einen message-broker Was wäre die architektonischen Vorteile\Nachteile für die Wahl zwischen Ihnen? Ich bin mit dem Ziel an stellen, die über das offensichtliche use-case-spezifischen performance-benchmarking, die durchgeführt werden

Vom PyPubSub: Pypubsub bietet eine einfache Möglichkeit für Ihre Python-Anwendung zu entkoppeln seine Komponenten: Teile des die Anwendung kann Nachrichten veröffentlichen (mit oder ohne Daten) und andere Teile können abonnieren/empfangen. Dies ermöglicht Nachricht "Absender" und Nachricht "Zuhörer"

Ich brauche, um eine Liste aller Tabellen, die veröffentlicht werden für die Replikation von MS-SQL-Datenbanken. Gibt es ein system gespeicherte Prozedur oder eine Abfrage, die ich ausführen könnte, um zu generieren, eine solche Liste? InformationsquelleAutor der Frage

EDIT: diese Frage, einige Antworten auf diese Fragen, und einige der Kommentare, enthalten eine Menge von Fehlinformationen. Sehen wie Meteor Sammlungen, Publikationen und Abonnements arbeiten für ein genaues Verständnis von veröffentlichen und abonnieren mehrere Teilmengen der gleichen

Wenn Umbildung socket.io/node.js und redis pub/sub in einem Versuch, erstellen Sie eine Echtzeit-web-broadcast-system, angetrieben von server-Ereignisse verarbeiten kann mehrere Transporte, scheint es drei Ansätze: 'createClient' eine redis-Verbindung und abonnieren Kanal(s). Am sockel.io-client-Verbindung, verbinden Sie den client in

Was ist der Unterschied zwischen den Observer-MusterPublish/Subscribeund Datenbindung? Suchte ich ein wenig herum auf Stack Overflow und fand keine guten Antworten. Was ich zu der überzeugung gekommen, dass die Daten-Bindung ist ein allgemeiner Begriff und es gibt

Habe ich eine einfache app einrichten, zeigt eine Liste von Projects. Ich habe entfernt die autopublish - Paket, so dass ich nicht senden Sie alles an den client. <template name="projectsIndex"> {{#each projects}} {{name}} {{/each}} </template> Wenn autopublish