message-queue

    0

    1答えて

    私のプロジェクトでは、メッセージ仲介システムとしてWSO2 Message Brokerを使用しています。 作成したキューの数、キュー内のメッセージの数などの情報を取得したいと思っています。これを行うために、私はJavaクラスでメッセージブローカーapiを呼び出す必要があります。 JavaクラスでメッセージブローカーAPIを呼び出すことはできますか?はいの場合、私はどこで私のJavaコードで使用で

    0

    1答えて

    RabbitMQデフォルト交換を使用してキューにメッセージを送信するJavaクライアントがいくつかあります。 私はキュー内のメッセージを分析できます(明らかに消費されていない場合)。メッセージの送信者を特定し、そのキューにメッセージを送信します。私が知りたいのですがどのようなので、RabbitMQの持つ新しいです は次のとおりです。 それがRabbitMQのヘッダとしてクライアントIDを追加するこ

    2

    1答えて

    私はプロジェクトでメッセージ仲介システムとしてwso2メッセージブローカーを使用しています。 WSO2メッセージブローカを使用する前に、私はWSO2メッセージブローカー・キュー/トピックに関連する例外的なケースを探求したい - 消費者がダウンしていると出版社が継続的/トピックをキューにメッセージを送信している場合は、キュー/トピックを保存することができますどのように多くのメッセージ? キュー/トピ

    1

    1答えて

    私はいくつかのJavaクライアントがダイレクト交換に公開しているメッセージを送信しています。 それぞれのクライアントは、IDをルーティングキーとして(またはヘッダー交換として変更できるヘッダーとして)公開することができます。そのルートキーを使用してキューにバインドされている場合は、グローバルキューにパブリッシュするキューに発行します。 私の質問は、キューからルート設定キー/ヘッダーをキューに入れる

    0

    1答えて

    私はWSO2メッセージブローカーでプロジェクトのメッセージブローカーシステムとして使用しています。キュー情報(wso2mbサーバーで作成されたすべてのキューを取得するような情報、各キュー内のメッセージ数など)を取得するには、AndesAdminServics WSDLからクライアントを生成し、apiからgetAllQueues()APIを呼び出しようとしました。毎回が要求されたターゲット例外の有効

    0

    1答えて

    を解放することはできません削除、メッセージのいくつかの種類が以下のようにRabbitMQのキューを介して送信されている: if(!con.isConnected()){ log.error("Not connected !!!"); return false; } con.getChannel().basicPublish("",queueName, MessageP

    0

    1答えて

    http://redis.io/commands/rpoplpush (ブロッキングバリアントまたはBRPOPLPUSH)」RPOPLPUSHは、この問題を回避するための方法を提供しています:消費者がメッセージをフェッチし、同時に処理リストにそれをプッシュそれが使用されます。メッセージが処理されると処理リストからメッセージを削除するためのLREMコマンド。 この信頼性の高いキューパターンを推奨しま

    0

    2答えて

    私はユーザーが登録できるWebアプリケーションを持っています。 確認メール(そして最終的にはsms)を送信する必要があります。この場合、BeanstalkワーカープロセスまたはSNSでSQSを使用する方が良いでしょうか? 2つ以上の利点はありますか?

    0

    1答えて

    私はRabbitMQのfirehoseトレーサを使用しています。 この例では、電卓というキューがヘッダー交換にバインドされています。 Javaクライアントを使用して、ログを読むために、私はこのコードを使用してログ・ファイルを読み取るためのHTTP APIを使用しています: URL url = new URL("http://127.0.0.1:15672/api/trace-files/calcu