activemq

    0

    1答えて

    メッセージがアクティブなmqに送信される待機値を動的に設定する方法はありますか? Active mqのキューに送信する前にメッセージを待つ必要があるという要件があります。私はその待機値の設定を変数から動的にできるようにする必要があります。 私はgroovyにメッセージを使用することができますが、いくつかの例を見たことがありますが、これを行うにはgroovyまたはsleep()やハックを使用したくあ

    -1

    1答えて

    Javaを使用してプロキシサーバーを構築しています。このアプリケーションはドッキング・コンテナ(複数のインスタンス)にデプロイされています 以下は私が作業している要件です。 クライアントは、私のプロキシサーバ プロキシサーバにHTTPリクエストを送信することが宛先ノードサーバに受信順にこれらの要求を転送します。 宛先に到達できない場合、プロキシサーバーはこれらの要求を格納し、将来利用可能になると転

    1

    1答えて

    耐久性のあるトピックのjmsトピックサブスクライバを書くときにclientIdとサブスクリプション名を設定する必要があることを理解しています。 しかし、TOPICを公開するときにclientIDを設定する目的は何ですか?私は人々が出版社/消費者のためにクライアントIDを設定しているのを見ましたが、なぜそれが必要なのか誰も説明しませんでした。 ConnectionFactory conFactory

    -1

    1答えて

    このコードでは、パブリッシャ側からのキューに1秒の有効期限切れのメッセージに対してsetJMSExpiration(1000)を使用しています。しかし、Consumer Sideからは、nullではなく1秒後に適切にメッセージが返されます。 public class RegistrationPublisher extends Thread{ public void run() {

    0

    1答えて

    activemqはスプリング4.3.6と互換性がありません。そして私は春のバージョンを変更することはできません。私は4.3.9にActiveMQのショーの依存関係は、私はまた、4.1.9への依存を持っ5.14.4を試してみました <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jm

    0

    1答えて

    私の英語は良くありません。しかし、私はactivemqキューページにアクセスすると問題に遭遇します。 私がhttp://MY-IP:8161/admin/queues.jspにアクセスしたときに、ウェブページが私に返信しました: エラー! このリクエストの処理中に例外が発生しました。ログで詳細を確認してください。 そして、私は、ログのバックエンドを見て、そしてそれが示した後: 2017-11-02

    0

    1答えて

    以下のコンソール出力から、私の見る限り、組み込みActiveMQが正しく初期化され、61616ポートで応答しています。 以下のテストを実行すると、行ごとにデバッグできるため、simpleSend()とsendMessage()の両方が実行されていることがわかります。 私はonMessageが2回トリガーされていることを期待していましたが、実際には発生していません。そのブローカーと埋め込みのActi

    0

    1答えて

    私はActiveMQの5.3.0を実行していると私は彼らにメッセージや 消費者を持っていなかったキューを削除するには、私の設定を取得するために、ここで説明 https://cwiki.apache.org/confluence/display/ACTIVEMQ/Delete+Inactive+Destinations に従ってみました。 しかし、activemq.xmlファイルを更新しましたが、a

    1

    2答えて

    私が知っているように、ActiveMQには実際にメッセージが受信されたことをプロデューサに知らせるAUTO Acknowledgeと呼ばれる機能があります。 ActiveMQまたはRabbitMQのコンシューマからプロデューサに肯定応答を送信できるかどうかを知りたい。プロデューサで確認応答メッセージを処理し、確認応答を受信しない場合は、メッセージを再度コンシューマに送信します。

    0

    1答えて

    ActiveMQのトピックの恒久サブスクライバを作成しましたが、activeMQサーバを再起動するたびに恒久サブスクライバを作成するためにJavaサービスを再起動する必要があります利用可能です。 activemqの再起動が起こるたびに加入者を自動的に利用できるようにする方法はありますか? 以下は、私が使用しているサンプルコードです。 @Bean public ConnectionFactory