activemq

0熱

1答えて

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

0熱

1答えて

複数のコンシューマーでのApache ActiveMQの異常動作

私はJboss-fuse-6.3と外部Apache-activemq-5.15.2を使用しています。私はキューに50人のコンシューマをバインドしており、アクティブなコンシューマのページにあるActive MQポータルでは、50人のコンシューマがすべてバインドされているが、キュー上のメッセージの配信は同じではないことに気付きました。スクリーンショットが添付されています。セッションIDが「1」の場

0熱

1答えて

メッセージはActiveMQで固定されています

私はを外部に使用していますApache-activemq-5.15.2.私はキューに50人のコンシューマをバインドしています。アクティブなコンシューマページのActive MQポータルでは、そのメッセージはキューに入れられませんが、別のメッセージが到着した場合、そのメッセージは簡単にデキューされます。パージを試みても、次のエラーが表示されます。エラー：以下activemq.logのログです

0熱

1答えて

クライアントでstomp.jsを使用するときにstomp protocalを設定するにはどうすればよいですか？

以下は、私がhttps://dzone.com/articles/easy-messaging-stomp-overからgoogledしたWebクライアントのサンプルコードです。 <script type="text/javascript"> var client = Stomp.client("ws://localhost:61614/stomp", "v11.stomp"); clien

1熱

2答えて

ActiveMqでファイル文字列を送受信する5.15.2

ActiveMQで巨大なファイルを送信する必要があります。そのために、for Large messageのドキュメントに従っていますが、にファイルを投げています。私の質問があるは、のpom.xml BytesMessage message = session.createBytesMessage(); FileInputStream fileInputStream = new

0熱

1答えて

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

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

0熱

1答えて

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

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

1熱

1答えて

メッセージを送信した直後に、メッセージを使用せずにJMSヘッダーを取得します。

メッセージを送信した後にJMSメッセージヘッダーを取得する方法はありますか？これはコード jmsTemplate.convertAndSend(que, text, message -> { LOGGER.info("setting JMS Message header values"); message.setStringProperty(RequestContex

0熱

1答えて

Camel intercept/marshal jms reply

私はラクダで要求/返信jmsコンシューマを取得しようとしています。受信メッセージが受信されましたが、ラクダも応答を送信してもメッセージはマーシャリングされません。私はActiveMQのからとするすべてのメッセージをマーシャリングするインターセプタを使用していますは OsdrDataFormat osdrDataFormat = new OsdrDataFormat(); intercept

0熱

1答えて

要求が一時トピックベースの要求/応答スキームで処理される前に、応答のサブスクリプションが確立されていることが保証されていますか？

私は、次の部分では、要求/応答パターンを実装したいと思います：サーバー：WebSocketを以上stompjsと JavaScriptの私が欲しい：ActiveMQのクライアントと Springboot httpリクエストのような動作リクエストを送信し、対応する応答を取得します。私はある私は3つのメッセージ手順を送る一時的なチャンネルでこれをやろう：はtemproraryチャネル