message-queue

0熱

1答えて

私は真実であると確信しています。私がWindows SendMessage()を使用するとき、これは決まった他のメッセージによって先取りされる可能性があるので、確定的でないPostMessage()とは対照的に、即座に実行される（メッセージが処理されるまで返されない）その瞬間のキュー（実際にはメッセージループに当たるまで実行されません）。これは公正な評価ですか、それとも不足していますか？

1熱

3答えて

生存時間のあるメッセージキュー

特定の時間（つまり10秒）まで最大Nの要素を格納するキューを探します。満杯の場合は最も古い値を廃棄する必要があります。生存時間の面を見逃しているApache Collections（CircularFifoQueueJavaDoc）に同様のキューが見つかりました。完全なメッセージブローカーは私の小規模プロジェクトのオーバーヘッドのようです。私はこれをどのように実装すべきかというヒントを教えてく

0熱

1答えて

rabbitMQに一連のジョブを送信する方法はありますか？

A, B, C, Dという名前のjobsがあります。ジョブBは、ジョブAが完了した後に開始する必要があります。したがって、仕事の順序は、A->B->C->Dのようになります。私はA、B、CおよびDの労働者の数を無制限に縮尺したいと思います。 RabbitMQを使用してこれを実装する方法はありますか、基本的にはseriesをjobsに作成する方法を探しています。私の現在の設計は、次のようになりま

0熱

2答えて

どのように私は、次のコードを起動するたびに、私のchannel.basicConsumeメッセージ

を待ちませんしています。代わりに、すぐに停止します。次のように私はそれはいくつかの時間を消費することができます唯一の方法は、ループでchannel.basicConsumeを置き換えることです： DateTime startedAt = new DateTime(); DateTime stopAt = startedAt.plusSeconds(60); long i=0;

0熱

1答えて

差分b/w JMSホストおよびJMSサーバ

JMSホストおよびJMSサーバ（ブローカ）です。または、それらは同じものを表しますJMSサーバ？

2熱

1答えて

Tibco EMSプロトコル

node.jsを使用してTibco EMSサーバと接続しようとしています。これが完全にオープンソースのソリューションをnode.jsだけで使用できるのであれば興味があります。私はTibcoのWeb Messagingソリューションを使用したくありません。これで、Tibco EMSはAMQPのような標準プロトコルを話すのですか？私は生のTCPソケットを介してそれに話すことができますか？メッセージル

0熱

1答えて

AWS SQSキューに登録されているものを確認することはできますか？

私はAmazon SQSキューにメッセージを送信するコードをリバースエンジニアリングしています。私はキューの名前を知っていて、AWSコンソールで見つけることができます。しかし、キューに登録されているものがわかりません。私はメッセージがどのように処理されているかを見たいと思います。それを見つける簡単な方法はありますか？私はコンソールやCLIで何も見ることができません...私はrabbitmqctlに

3熱

1答えて

Flask Appでは、セロリはどこでインスタンス化されるべきですか？

私はFlaskアプリケーションを持っています。これは、POSTハンドラといくつかのDB挿入を持つ非常に基本的なアプリケーションです。 DB挿入はCeleryを使用してタスクとして設定されます。私のセロリインスタンスの作成とタスクの定義をtasks.pyファイルに入れて、私のmain.pyファイル（Flaskアプリケーションの作成も含む）から関数を呼び出すと、out of context error

0熱

1答えて

うさぎのMQコンシューマーはどのように機能しますか？

私はRabbitMQの消費者（受信機）に関する2つの質問している：1、消費者がメッセージダウンしている場合ように、どのように私は、特定のキューに登録されている消費者は何をしている（静的キューから）を定義することができますその消費者が再び起きた後も引き続き配送されるか、これを達成するための他の方法がありますか？消費者はまだ作成されていないキューに接続しますが、rabbitmqチュートリアルではプ

0熱

1答えて

RabbitMQ内の既存のキューのルーティングキーを変更する

Javaクライアントを使用してRabbitMQ内の既存のキューのルーティングキーを変更することはできますか？