message-queue

5熱

2答えて

私のプロジェクトにStorm（see here）を統合しようとしています。私はトポロジー、スパウト、ボルトの概念を突き止めました。しかし、今、私はいくつかの実際の実装を理解しようとしています。 A）私は、JavaとClojureを使用する多言語環境を使用しています。私のJavaコードは、ストリーミングデータを起動するメソッドを持つコールバッククラスです。これらのメソッドにプッシュされたイベントデー

6熱

2答えて

Erlangでメモリバウンドメッセージキューを作成するにはどうすればよいですか？

私は非同期メッセージの速度を望んでいますが、まだフロー制御があります。 Erlangでこれをどのように達成できますか？

19熱

2答えて

ノードJSの労働者 - それらのための必要性はありますか？

私の無知を許しても、Django/Pythonのバックグラウンドから来ているので、Webインターフェイスができるだけ早く更新されている間に、セロリのキューをバックグラウンドで処理するという大きな利点があります。ただし、非同期で動作するノードでは、キューシステムの使用例が大幅に減少していますか？例えば： 1 - サイトへのユーザーのポスト何か、 2 - サイトが応答するには、[管理者にメールし。

9熱

2答えて

スレッドセーフな非同期メッセージキューが必要です

私は、非同期の「ブロードキャストスタイル」メッセージングを管理するために、Pythonクラス（好ましくはサードパーティライブラリではなく標準言語の一部）を探しています。メッセージをキューに入れるスレッド（putMessageOnQueueメソッドはブロックする必要がありません）と、メッセージを待っている他の複数のスレッドがあり、おそらくいくつかのブロッキング 'waitForMessage'関数

6熱

3答えて

nodejsのワーカーキュー？

ノードのクラスタAPIとmongooseを使用して、ノードのワーカーキューを書き始めています。私は、既にこれを行うが、redisとフォークを使用して、多くのlibsが存在することに気付きました。クラスターAPIを使用するのと比べて、フォークするのが良い理由はありますか？を編集していますが、これもわかります：https://github.com/xk/node-threads-a-gogo -

6熱

2答えて

WCFを使用しないMSMQでの再試行メカニズムの作成

System.Messaging API経由でMSMQを使用してメッセージを送受信する既存のアプリケーションが複数あります。キューは一般的に非トランザクションで、MSMQ 3と4が混在しています。受信アプリケーションは、最初に何らかの例外が発生したときにメッセージが手動介入のためにエラーキューに入れられる。しかし、手動介入の大部分は、成功した時点で別の試行のためにメッセージをメインキューに戻すだ

6熱

1答えて

メッセージキューの内容はどこに保存されていますか？

私が気付いたPOSIXメッセージキューを使用している間に、キューを作成していた名前のFileシステム上にいくつかのファイルが作成されていました。私の質問： Q1。メッセージキューは、RAMではなくハードディスク上のメッセージをキューに入れますか？ Q2。もしそうなら、これはHardDiskに関連するので、実装が非常に遅いのではないでしょうか？編集：私は本The Linux Programmin

10熱

2答えて

MessageQueueとAsync/Await

メッセージを非同期メソッドで受信したいだけです。私のUIがフリーズしています public async void ProcessMessages() { MessageQueue MyMessageQueue = new MessageQueue(@".\private$\MyTransactionalQueue"); MyMessageQueue.Formatt

103熱

7答えて

JMSとAMQP - RabbitMQ

どのようなJMSとそれがどのようにAMQPの用語に関連しているのか理解しようとしています。私はJMSがAPIであり、AMQPがプロトコルであることを知っています。ここでは私の仮定（との質問にも）のRabbitMQはAMQPプロトコルを使用している/利用RabbitMQの Javaクライアントが接続するためにAMQPプロトコルのクライアントライブラリを使用する必要があります（むしろAMQPプロ

10熱

1答えて

ZeroMQの予想されるパフォーマンスは？

私はプロセス間通信を手伝っています。目的は、いくつかの計算を実行し、その結果を制御プロセスに返すワーカープロセスを持つことです。私はzeromq.nodeをインストールし、シンプルなリクエスタとレスポンダをcoffeescriptで設定しました。依頼者： # requester.coffee zmq = require 'zmq' context = new zmq.Co