2016-08-18 8 views
0

私はActiveMQトピックを使用しています。 私のアプリケーションはいくつかのトピックを作成し、これらのトピックについてプロデューサとコンシューマを作成します。プロデューサがトピックに送信されたメッセージを受信できないようにするにはどうすればよいですか?

プロデューサが何かを送信すると、同じトピックのこのトピックのコンシューマもあるため、メッセージが返されます。

各アプリケーション専用のトピック(実行している別のコンピュータ用の異なるコード)があり、メッセージを処理するために各トピックを結合する主な中心コアプロセスがあり、要求メッセージ投稿されました。

いくつかのトピックは「一般的な」トピックで、一部のメッセージには返信はありませんが、多くのプロセスが考慮されます。

プロデューサが送信した内容を受信できないようにするActiveMQには何かがありますか?

編集:私はActiveMQのとはかなり初心者ですので注意してください、私は、非常に基本的な設定ではないので、ずっと前にそれを使用していないしています:なし持続性を、などの簡単なアプリケーション・バス

+0

私は、あなたのコンテキストで何がプロデューサーとコンシューマーを呼んでいるのかを明確にする必要があると思います。 – Antoniossss

+0

@Antoniossss ActiveMQ Java APIのプロデューサとコンシューマ。最初のメッセージを送信する方法です、送信は、メッセージを受信するために使用されます –

+1

あなたは誰もが知っている何かを説明しました。誰も知らないものはあなたの消費者とプロデューサーであり、なぜ彼らを同じエンティティと同じように提示しているのですか?これは、別のプロセス(differenマシンなど)、同じアプリケーションなどのいくつかのクラスの単純なインスタンスにすることができます。 – Antoniossss

答えて

1

は、あなたがcreate your consumerするときに指定することができますmessage selectorを使用して、プロデューサの一意のIDを持つメッセージを除外します。あなたのプロデューサーはメッセージを作成するときにそのIDをmessage propertyに設定することができます。

+0

ホー!素晴らしいニュース、私は現在自分のコードの前にいませんが、これはまさに私が探しているものです!ありがとう。 –

+0

私はプロデューサーでIDを設定し、 "!ID"のようなセレクターで消費者に伝えることができます。すばらしいです。 –

+0

心配しないで、すぐに私はそれをテストすることができます、私は;)チップをありがとう。 –

関連する問題