message-bus

0熱

1答えて

私はliferay 6.1で働いていたときに、メッセージを受け取ったアプリケーションを作成しました。 Javaクラス： public class MailMessageBus implements MessageListener \ SRC \メイン\のWebアプリケーションの\ WEB-INF \ SRC \ META-INF \メッセージング・spring.xmlファイル： <beans

12熱

1答えて

メディエータのないZeroMQ Pub-Sub + Dynamic Discovery

私は、中規模システムの場合、ZeroMQをPub-Sub（サービスバススタイル）インフラとしてテストしています。私たちは約50のノードを持っています。それらはすべてパブリッシャーとサブスクライバーでなければなりません。ネットワークはスタートポロジのようなものですが、エッジはお互いに「話し合っています」。ダイナミックディスカバリ（参加者のネットワークアドレスをハードコードする必要はありません）

3熱

3答えて

STL複数の値を格納するためのコンテナ？

私はメッセージバスで使用しているMessage構造を持っていて、メッセージでデータを送信したいと思います。問題は、データの種類が異なることです。多分1つのメッセージのために私はただ1つのintを送るつもりですが、別のもののために、私はいくつかのint、文字列、多分オブジェクトへのポインタさえ送るでしょう。私はこのような何か行うことができます： struct Message { std::

2熱

2答えて

RxJSを使用してangularjsモジュール間の通信にMessageBusを実装する

angulajsアプリケーション内でRxJSを使用してpub/subメッセージメッセージキューを作成できますか？私は例として2つのモジュールを持っています： ModuleA ModuleB それらは別々のnpmパッケージとして存在しますが、ModuleCで接続されています。これはメインシェルです。私はModuleDとして依存関係を作成し、モジュール間の緊密な結合を作りたくありません。だから私の考

1熱

1答えて

メッセージバスとしてのスプリングステートマシン

現在、カスタムサービスバスの実装としてスプリングステートマシンをチェックしています。私は2つの質問があります：時間はモデルに基づいてタイマーに基づいて設定します。たとえば、モデルのオブジェクトの開始時刻である時間にメッセージ配信を遅延させたい場合（異なるメッセージで異なる可能性がある場合）スケジューリングを自分で実装することはありません。私はAPIが好きでしたが、いくつかの状況では数百（また

0熱

1答えて

MessageBus.callbackIntervalは本番環境では動作しません

私はwebsocketソリューションのより簡略化された方法として、数ヶ月間message_bus gemを使用してきました。デフォルトのMessageBus.callbackIntervalは広すぎますので、それを絞りたいと思います。私はこれを私の開発環境でうまくやった。生産に展開するときしかし、以下の二行は無視されるようだ： MessageBus.start(); MessageBus.cal

1熱

1答えて

Rubyメッセージバスの宝石はありますか？

私は現在、レールプロセスと、（オブジェクトの作成のような）特定のイベントを通知する必要がある複数のワーカープロセスを備えたアーキテクチャを構築しています。プロセス（API、労働者、デーモンは、...）だけで、メッセージバスに加入し、ブロックが時にメッセージと呼ばれている間、私は、次の class Article after_creation do MessageBus.send

0熱

1答えて

ActiveMQのメッセージバスのロギング・ハンドラのpython

、私はloggingにハンドラを追加する必要があります。これを行うには、他のpythonic方法はありますか？

1熱

1答えて

メッセージバスとdバスの違い：低レベルでは何が起こっていますか？基本的に同じこと？

私は正直に驚いています。私は以前これについて議論していませんでした。私の印象は、Redisはサーバーとの通常のインターネットパケット交換を使用して結果を戻しますが、d-busはUNIXソケット（パイプ）を使用し、配布システムを重ね合わせることです。どちらが速いのかという通常の質問があると思いますが、どちらのメッセージでも実際に何が起こっているのか本当に知りたいです。おそらくどちらかに利点があるだ

2熱

1答えて

NotImplementedErrorは、（部分的にしかハイジャックがサポートされています。）message_bus

私はちょうどgemfileに宝石を追加し、JSコンソールに書いて使用して： MessageBus.subscribe('/my_channel', function(data){ alert(data); }); それはスロー： Started POST "/message-bus/4700f3c66b254e31875de6caeba011df/poll" for 127.0.0