Tag: messaging
Messaging bezieht sich auf das design-Muster, wobei diskrete Nachrichten dienen der Kommunikation zwischen Objekten oder Prozessen. Nachrichten können einfache Daten, komplexe Daten-Strukturen, oder auch code. Dieses Muster wird oft für asynchron-oder parallel-computing.
2
Antworten
Entwickle ich web-Anwendung unterstützt Spring Integration. Ich bin mit der 1.0.4.RELEASE. Ich benutze CGLib-proxies. Ich habe eine transaktionale message-endpoint. Alles richtig geklappt hat, aber ich experimentierte ein wenig mit Anmerkungen. Ich benutze annotation-config, die funktioniert einwandfrei. Ich
3
Antworten
Sagen wir, es ist eine mobile Anwendung, die benötigt, um eine sync-Anfrage/Abfrage einige Daten von einem server. Die Anfrage wird an hosted JMS-client zuerst, dass das veröffentlichen einer Nachricht/Anfrage auf die externe Queue (vom partner). Jetzt ist
4
Antworten
derzeit bin ich Bewertung Sie verschiedene Messaging-Systeme. Es ist eine Frage im Zusammenhang mit Apache Kafka die ich nicht beantworten konnte, mich. Ist es möglich, für einen Kafka-producer zum erstellen von Themen und Partitionen (auf vorhandene Themen
4
Antworten
Ich habe versucht, herauszufinden, genau das, was message-oriented middleware ist, aber nicht in der Lage zu finden, alle nicht-enterprise real world Beispiele, die für mich Sinn machen. Kann mir jemand eine eindeutige und leicht verständliche Erläuterung, was
1
Antworten
Ich bin auf der Suche in den Aufbau einer Echtzeit-chat-app für das iPhone (aber diese Frage gilt für Android-und anderen Geräten auch) im Grunde möchte ich die app erhalten Sie Echtzeit-Nachrichten, während es geöffnet ist, sowie, während
3
Antworten
Ich bin auf der Suche nach einem bereits vorhandenen Django-app bietet Nutzern private Nachrichten. Ich habe gesehen, django-pm und django-Nachrichten, welche nicht erscheinen, besonders der aktiven Entwicklung. Gibt es wirklich nichts gibt? die eingebaute django contrib Nachrichten!
2
Antworten
Dies ist auf Grundlage einer vergangenen Prüfung Frage. Die Frage ist, zu Fragen, um zu beschreiben, die vier Meldungstypen zur Verfügung, mit Hilfe JMS. Das problem ist, es sagt, die vier, nicht nur vier. So nimmt es
4
Antworten
sagen, ich habe einen Prozess, der spawnt 2 threads den ersten thread hört in einer engen Schleife für Päckchen Ereignisse auf einem UDP-port. der zweite thread zum empfangen von bytes enthalten, die in das UDP-Paket und analysieren
1
Antworten
Ich bin neu RabbitMQ, und ich bin etwas verloren in der Dokumentation. Derzeit als ein Beispiel, den ich versuche zu bauen, ein kleines mailer-Dienst, der überwacht eine Warteschlange. Aber ich bin etwas stecken, wo sollte ich die
3
Antworten
Was sind Eure Erfahrungen mit ZeroMQ als general purpose messaging-middleware? Haben Sie sich in eine show-stopping bugs oder nicht-offensichtlichen "Funktionen"? E. g. 2.0 war nicht die Spülung Meldungen richtig, und die Anleitung zur Fehlerbehebung zu geben scheint
1
Antworten
Ich bin auf der Suche für einen messaging-Dienst für ein neues Projekt, an der Schnittstelle einige C# - Anwendungen einige Java-Anwendungen. Ich wirklich wie RabbitMQ, weil es scheint, um beeindruckende Unterstützung für beide Technologien. Ich sehe in
3
Antworten
Sagen, Sie haben eine JMS-Warteschlange, und mehrere Verbraucher beobachten die Warteschlange für Nachrichten. Sie möchten ein Verbraucher, um alle von einer bestimmten Art von Nachricht, so dass Sie entscheiden message-Selektoren. Beispielsweise definieren Sie eine Eigenschaft, um zu
3
Antworten
Ich versuche, einige einfache UDP-Kommunikation funktioniert auf meinem lokalen Netzwerk. Alles was ich will zu tun ist, tun ein multicast an alle Rechner im Netzwerk Hier ist mein code senden public void SendMessage(string message) { var data
2
Antworten
Weiß jemand wie ich kann das senden einer Variablen (oder eine variable) aus threadOne zu threadTwo in diesem code ohne die Verwendung einer globalen Variablen? Wenn nicht, wie würde ich betreiben eine Globale variable? Einfach definieren Sie,
1
Antworten
Ich möchte ein web-messaging-system wie facebook haben. Ich denke schon von vielen alternativen für die Struktur der Datenbank, aber nicht sicher sind, welche ist die beste übung für Sie. Ich habe zwei alternative hier, die erste ist
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
1
Antworten
Was ist die richtige Art und Weise zu verwenden Messenger Klasse ? Ich weiß, es kann verwendet werden, für die ViewModels/Blick auf Kommunikation, aber es ist ein guter Ansatz, es zu benutzen für einen technische/business-service-Schicht ? Beispielsweise
2
Antworten
Ich weiß nicht, warum bin ich eine harte Zeit zu finden, aber ich bin auf der Suche auf einigen linux-code, wo wir mit select() warten auf ein Datei-descriptor zu berichten, es ist bereit. Aus der man page
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
3
Antworten
Habe ich die Arbeit mit WebSphere MQ-seit letzten Tagen. Ich habe nur getestet, mit dem erstellen der lokalen queue-Manager und das senden/empfangen von Nachrichten aus Warteschlangen, die funktioniert gut wie erwartet. aber ich bin nicht in der
3
Antworten
Möchte ich wm_close senden, um einen anderen Prozess, mit dem ich wollen Ende, der Prozess sicher. int _tmain(int argc, _TCHAR* argv) { DWORD SetOfPID; SetOfPID = GetProcId(_T("abc.exe")); //this will return pid HANDLE h = OpenProcess(PROCESS_ALL_ACCESS,false, SetOfPID); HWND
2
Antworten
Ich versuche, die Implementierung eines messaging-system in PHP und MySQL aber ich habe einige Probleme, sich zu entscheiden, wie ich die Tabellen und Abfragen. Was wäre der beste Ansatz für ein system, das es ermöglicht für mehrere
2
Antworten
Schreibe ich dieses kleine utility-Methode zu testen, senden rohe Pakete zu einem bestimmten messaging-Netzwerk (Planung auf die Entwicklung eines client, um eine Verbindung herzustellen). Netzwerk ist die Deviantart-messaging-Netzwerk (mit chat.deviantart.com:3900; TCP). Meiner Klasse: protected void connect() throws
4
Antworten
Nur wie ein "net send" unter Windows, wenn ich daran denke, was net send funktioniert korrekt. Ich möchte nur etwas sagen wie: <command> <IP address> "Hey what's up?" und die Nachricht "Hey, what' s up?" soll zeigen,
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
3
Antworten
Ich würde gerne code schreiben zu überwachen, die queue-Größe auf Websphere 7 MQ. Dies ist der code, den ich mir ausgedacht habe MQEnvironment.hostname = "10.21.1.19"; MQEnvironment.port = 1414; MQEnvironment.channel = "SYSTEM.CDEF.SVRCONN"; MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES); MQQueueManager qMgr = new
2
Antworten
Wie kann ich das überprüfen von IBM MQ-UI, die auf eine bestimmte Warteschlange, wenn es irgendein Verbraucher vorhanden InformationsquelleAutor user275880 | 2010-05-11
1
Antworten
Hallo, ich bin neu in Tibco RV. Nach dem Lesen der Tibco Rendezvous-Konzept, ich bin immer noch verwirrt über die transport-Parameter: service, Netzwerk, daemon. So konzeptionell gibt es nur ein daemon läuft auf jeder Maschine. Also, wenn
2
Antworten
Ich bin die Entwicklung einer messaging-system basierend auf dem webBrowser-Steuerelemente, so dass ich den text formatieren, aber ich bitte. Wenn der Benutzer offline ist und gesendet-Nachrichten, die Nachrichten werden gespeichert, und ein Ereignis gesendet wird, für jede
3
Antworten
Ich bauen möchte, eine messaging-app für das web mit Google Feuerstellung. In dieser app sollte der Benutzer das senden und empfangen von Nachrichten an/von andere Benutzer. Ich überprüfte Google FB-website, aber ich habe verloren. Können Sie mir
1
Antworten
Möchte ich nutzen maschinelles lernen, um das Modell einer Benutzer-Absicht, und möglicherweise automatisieren Häufig ausgeführte Aufgaben. Dazu würde ich gerne Zugriff auf ein Feuer-Schlauch von Informationen über die Aktionen des Benutzers und der Maschine Stand. Zu diesem
3
Antworten
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,
1
Antworten
Arbeite ich mit der JMS-API (mit HornetQ) und ich bin mit spring beans message listener container und message listener: <bean id="messageListener" class="core.messaging.handler.MessageListener"> <property name="postCommandService" ref="postCommandService" /> </bean> <bean id="messageSender" class="lsn.messaging.sender.MessageSender"> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="destination"
1
Antworten
Ich Verstehe, dass diese Frage Duplikate Frage an mit rabbitmq eine Nachricht zu senden, nicht als string, sondern struct wenn dies mit der ersten Möglichkeit ersten Weise Habe ich die folgenden trace: java.io.EOFException at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2304) at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2773)
2
Antworten
Ich habe einige sehr einfache code zu tun mit Handler: Handler seconds=new Handler() { @Override public void handleMessage(Message msg) { bar.incrementProgressBy(5); tView1.setText("r:"+msg); } }; Und meinen thread: Thread seconds_thread=new Thread(new Runnable() { public void run() { try
2
Antworten
Ich habe einige Probleme mit signalR, ich kann nicht senden Sie die Nachricht an bestimmte Benutzer Von der Nabe. Ich möchte dies so tun: public void Send(string userToId, string userForId, string message) { IHubContext context = GlobalHost.ConnectionManager.GetHubContext<ChatHubs>();
3
Antworten
Ich bin auf der Suche, um in der Lage sein, um Nachrichten zwischen Warteschlangen (manuell), Kaninchen. Beispiel: first-queue has messages ['a','b','c','d','e','f'] second-queue has messages ['x','y'] Ich möchte in der Lage sein, sich zu bewegen zum Beispiel Meldung
2
Antworten
Ich bin zu versuchen, mein eigenes chrome-Erweiterung an, die auf ein bestimmtes Ereignis, eine browser-Meldung und füllt das popup mit den Daten berechnet, die in background.js Hier ist mymanifest Datei : { "name": "Dummy name", "description": "Description",
3
Antworten
Folgte ich der demo gegeben, bei http://developer.android.com/google/gcm/gs.html und bekam einen anschlagversuch, GCMTrial, um korrekt zu arbeiten. Aber, ich habe versucht, Folgen die gleichen Schritte, die auf eine vorhandene Anwendung an, aber es didnot Arbeit. Daher habe ich
4
Antworten
Lese ich die Folien von diesem Jahr UberConf und einer der Sprecher ist, macht das argument, dass der Frühling JMS fügt einen performance-overhead, um Ihre message queue system, aber ich sehe keine Beweise zu unterstützen, dass in
4
Antworten
Umsetzen wollen, eine verzögerte Verbraucher über den high-level-Verbraucher-api Grundidee: produzieren Nachrichten-Taste (jede msg enthält creation timestamp) dies stellt sicher, dass jede partition hat bestellt-Nachrichten produziert Zeit. auto.Begehen.enable=false (wird explizit commit nach jeder Nachricht-Prozess) verbrauchen eine Nachricht check
1
Antworten
Ich versuche Daten von einem popup an ein content-script, aber ich bin nicht mit Glück. Ich habe es auf der Arbeit anders herum (Inhalte -> popup -), obwohl. Alles was ich will zu tun ist, geben Sie
3
Antworten
Ich arbeite mit JMS und ActiveMQ. Alles ist Wunder. Ich bin nicht mit Feder, noch kann I. Die Schnittstelle javax.jms.MessageListener hat nur eine Methode, die onMessage. Innerhalb einer Implementierung, gibt es eine chance wird, wird eine Ausnahme
7
Antworten
Hinweis, ich würde gerne mehrere message-Listener zu verarbeiten aufeinanderfolgender Nachrichten vom Thema gleichzeitig. Außerdem würde ich gerne jede Nachricht listener zu arbeiten transaktional, so dass ein Verarbeitungsfehler in einem bestimmten message-listener führen würde, dass die Zuhörer die
3
Antworten
In meine Anwendung bin ich in der Lage, eine SMS zu versenden programmatisch zu einem bestimmten Handy-Nummer, wenn der Benutzer auf "Absenden". Dann gibt es eine Antwort-Nachricht aus, die Handy-Nummer möchte ich nun zu Lesen, dass die
2
Antworten
Was ist der grundlegende Unterschied zwischen stream-Verarbeitung und traditioneller message-Verarbeitung? Wie die Leute sagen, dass kafka ist eine gute Wahl für die stream-Verarbeitung, sondern im wesentlichen kafka ist ein messaging-framework, ähnlich ActivMQ, RabbitMQ etc. Warum tun wir
2
Antworten
Ich würde wie eine einfache message-passing - /RPC-system. Ich könnte mit einem serialisieren system, aber ich will irgendeine Art von Prüfung, um sicherzustellen, dass beide enden synchronisiert. Ich habe gesucht bei Google Protocol Buffers, aber ich bin
2
Antworten
Ist es möglich, komplexe Nachrichten über JMS? Ich kann senden Sie Textnachrichten, Nachrichten, etc .. aber wenn ich versuche zu senden, die dem benutzerdefinierten Objekt-Typ MyObject Trog send() Methode der MessageProducer bekomme ich Kompilierungsfehler. Dann habe ich
5
Antworten
möchte ich versuchen, das senden von SMS zu einem Handy in österreich. ich habe eine Kostenlose Testversion twilio-Konto, dies zu tun. aber, meine twilio-Konto scheint nicht in der Lage sein, dies zu tun. aber ich denke, es
2
Antworten
Senden Nachricht an alle client funktioniert gut, aber ich möchte, um eine Nachricht zu senden, insbesondere Benutzername. meine server.js Datei aussieht. Was es tut, ist, wenn http://localhost:8080 ausgeführt wird, wird der client-code fügt den Benutzer auf das