jms

0熱

1答えて

私はIBM MQ経由でJMSを使用しています。私の差出人コード： @Autowired private JmsTemplate jmsTemplate; public void sendPHRq(String msg) { jmsTemplate.send(AntiFraudRq, session -> { Message message = session.creat

0熱

1答えて

JmsTemplate with CachingConnectionFactory IBM MQキューの接続回復

JmsTemplateを使用して同じクライアントから2つのIBM MQサーバーに接続しています。私はJmsTemplateのreconnectOnExceptionとIBM MQ接続ファクトリのsetClientReconnectOptionsを設定しました。のSpring Bean定義： <bean id="firstMQCachingConnectionFactory" class="or

-1熱

2答えて

ActiveMQConsumer.receive（1000）はnullを返します

ACtiveMQにメッセージを書き込んでいますが、このメソッドでサンプルプログラムを実行していますActiveMessageConsumer.receive(1000)は常にnullというメッセージを返します。キューにはメッセージがありますが、依然としてそれらのメッセージを受信できません。 url = "http：//"; http://activemq.apache.org/connectio

0熱

1答えて

Alpakka - メッセージが処理されるときのコールバック

各メッセージがJMSに正常に送信された後、または失敗した場合にコールバックを作成するにはどうすればよいですか？ val jmsSink = JmsSink.textSink( JmsSinkSettings(connectionFactory).withQueue("My_Queue") ) Source(Stream.from(1)) .map(_.toString)

0熱

1答えて

Temp Queue autoを防止するActiveMQのトピック作成

ActiveMQで一時キューを作成するRestサービスを使用して、受信応答を受信しました。すべての要求は、一時キューを作成します。私は、トピックリストに行くとき、私は次の表示：各一時キューのを、自動的にトピックを作成しています。その主な問題は、トピックには1,000のトピックに制限があることです。これを超えると、ActiveMQのアプリケーションからメッセージが受け付けられなくなります。

0熱

1答えて

Java EEアプリケーションからJava SEアプリケーションにJMSメッセージを送信する

私の問題は、誤った設定のために概念的なものか技術的なものかはわかりません。目的は、アプリケーションコンテナ（ここではWildFly）でホストされているJava EEアプリケーションと、スタンダードJMSプロトコルとトピックを使用してスタンドアロンで実行されているJava SEアプリケーションの間で双方向のメッセージを送信することです。私は同じブローカーと同じ話題を使用している限り、これは可能です

0熱

1答えて

JMSメッセージの受信時刻を取得する

JMSメッセージの受信時刻を取得するためのメソッド/ APIはありますか（配信不能、タイムスタンプを公開しない）？それとも手動でonMessage(Message msg)メソッドで修正する必要がありますか？

0熱

1答えて

JMSキューに送信されるメッセージは、単一のコンシューマだけが消費しますか？

送信者がキューにメッセージを送信している場合、たとえばmessage1などは、sender1によってキューに送信されます。今すぐconsumer1という名前のコンシューマがキューに接続し、メッセージmessage1を読み取ります。 consumer2という名前の別のコンシューマがあります。しかし、メッセージmessage1は既にconsumer1によって消費されており、consumer2では利用で

0熱

1答えて

ActiveMqのトピック内のメッセージが配信されるユーザの最大数を制限する

ActiveMqインスタンスがあり、トピックをリスンするクライアントが100人いるとします。新しいメッセージがトピックに公開されると、それを受信するサブスクライバの数を制限できますか（例10のみ）？他のメッセージングコンポーネントがこれを行うことができますか、回避策/強化されたベストプラクティスがある場合は、

0熱

1答えて

ActiveMQのベストプロトコルは、不安定な接続を介して

ユースケースを巨大なファイルを送信します。現在のところ、Activemq Artemisサーバを使用して、再試行間隔を-1にしてtcpプロトコルによる入力ストリームの助けを借りて、巨大なファイルをByteMessageとして送信します。ここでの主な問題は、消費者のエンドポイントの接続がほとんど不安定であることです。つまり、移動性のためにネットワークから切断します。ファイルをキューに入れている間