activemq

    0

    1答えて

    私は始めて、ActiveMQにいくつかの問題が発生しました。私は、単純なパブリッシャーアプリ @Component public class VirtualTopicSender { @Autowired private JmsTemplate jmsTemplate; public void send() { Topic topic = new A

    0

    1答えて

    ヒューズログでエラーが発生しました。それを解決するために、私はdb-32.logファイルに許可を与えることを考えましたが、このファイルの許可を変更することはできません。代わりに、私は警告 が を「DB-32.logのプロパティを変更することはできません」取得エラーログ 07:17:20,163 | INFO | AMQ-1-thread-1 | ActiveMQServiceFactory | 1

    0

    1答えて

    ActiveMQブローカからElasticsearchにドキュメントをインデックスする必要があります。私は、JMS入力プラグイン(jriver-jmsをベースにしています)を使って、その目的のためにlogstashを使用しています。 ActiveMQブローカーのトピックに格納されているすべての文書がElasticsearchに確実に届くようにするために、logstashを使用して永続的なサブスクリ

    1

    1答えて

    activemqのリスナーコードが複数のブローカーからのメッセージを聞くべき解決策を見つけるのが難しいです。例として、4つのサーバー(A、B、C、D)でホストされているユーザーにメッセージを提供する4つのブローカー(1,2,3,4)があります。 consumerAは、broker1,2,3 &からの応答メッセージをリッスンする必要があります。4.メッセージが見つかると、consumerAはメッセー

    2

    1答えて

    iscsiターゲットを使用してActivemqマスター/スレーブ設定を処理する予定です。この場合、iscsiプロトコルを使用して2台の仮想マシンにSANストレージボリュームをマウントし、2台のVMは同じマウント(SANから)を共有します。したがって、問題は、ファイルロックがこのアプローチで適切に機能するかどうかです。そして、このデザインの問題を予期できますか? NFSとしてマウントするには、SAN

    0

    1答えて

    camel-activemq依存関係を使用して、activemqキューをリッスンしているサービスを設定しようとしています。私はもっ​​ぱらラクダのルートに接続を設定しようとすると、私が使用しているエンドポイントは、次のとおりです。 「ActiveMQの:?のmailqユーザ名=管理&パスワード=パスワード& trustAllPackages =真& concurrentConsumers = 10

    0

    1答えて

    私はActiveMQについての新機能です。 http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html public class Server implements MessageListener { private static int ackMode; private

    1

    1答えて

    ソースコードの代わりに詳しい説明を書かない限り、私はこの質問を投稿できません。だからこそ私はちょっとだけテキストを書いているだけです。 私は以下のクラスを持っています。私の目標は、このプラグインを設定してBrokerServiceを保護することです。 public class Server{ private static int ackMode; private stati

    0

    1答えて

    リンクあたりとして からhttp://activemq.apache.org/activemq-message-properties.html メッセージは、メッセージ・プロパティのためにjconsoleからチェックすると、「JMSXDeliveryCountは、」メッセージ を送信するために試行回数のために使用されている必要があり、それは他ものの欠けています& "JMSXGroupSeq" "J

    0

    1答えて

    ActiveMQ NMSコンシューマ(C#)は古いメッセージを受信できません。受信したメッセージで動作するwhileループになります。 私は、メッセージが必要なときにNMSコンシューマ接続を確立し、受信したメッセージを操作します。 問題は、私のプログラムの最初の接続試行の後に投稿されたメッセージをプログラムを起動するたびにダウンロードして使用することができます。 ただし、メッセージが流入していない