spring-jms

1熱

1答えて

4人のサブスクライバを持つトピックにメッセージ（特定のの相関ID）を配置するアプリケーションがあります。メッセージが配置されると、メッセージは4人のサブスクライバによって消費され、応答を出していますキューと同じ相関ID（reply = 4messages）を持っています。メッセージがの重複相関IDを持っていると疑いがあります。要求に相関IDが含まれているメッセージを検索しているときにどのメッセージ

0熱

1答えて

スプリングDMLCポーラー周波数変更

DefaultMessageListenerContainerのポーラー周波数OOTBを変更することは可能ですか？もしそうなら、動的構成ですか？

1熱

1答えて

Spring IntegrationメッセージがerrorChannelに移動したときのJTAロールバック

Atomikosを介したJTAサポートとSpringインバウンドとアウトバウンドの異なるWebshpere MQにバインドされたJMSを使用しています。フローは以下である： JMSインバウンド・チャネル・アダプタが出力キューエラーが発生に JMSアウトバウンド・チャネル・アダプタをメッセージを受信いくつかの変換、errorChannelは、メッセージを受信例外タイプルータは、未処理エラーを

0熱

2答えて

メッセージ再配信ibm mq

IBM MQからメッセージを読み取るシステムがあります。このキューから、ときどきデータが破損することがあります。メッセージが次に読み込まれたときに失敗した場合、リスナーは5分待ってから処理を進めます。メッセージが3回失敗すると、メッセージはバックオフキューに入れられます。 JMSContainerFacotryは、パラレルでmax 10を実行するように設定されています。つまり、大量の破損メッセージ

0熱

1答えて

Camelのjmsリスナーが正しいメッセージを受け取っていない

Usecase：httpエンドポイントからメッセージを取り出し、それらをjmsエンドポイントにルーティングしたいとします。マイルート設定は以下のようになります。 from("jetty:http://0.0.0.0:9080/quote") .convertBodyTo(String.class) .to("stream:out") .to(InOut,

0熱

1答えて

sessionTransacted = trueからの非トランザクション・コールの呼び出しDefaultMessageListenerContainer

IBM MQ用にDefaultMessageListenerContainerが構成されています。 sessionTransactedプロパティがtrueに設定されています。リスナ内からJMSTemplateを使用して別のMQサービスを呼び出しますが、sessionTransactedがtrueに設定されているため、JMSTemplateコールは最後まで実行されないため、応答が得られません。私がこ

0熱

1答えて

JMSメッセージは、生成されたノード上でのみ受信されます。

私は、ActiveMQキューからメッセージを受信するためにSpringのDefaultMessageListenerContainerを使用しています。このアプリケーションは、このキューへのメッセージの唯一のプロデューサです。アプリケーションがクラスタ化されているので、2つのインスタンス（instance1,instance2）がある場合、instance1から生成され、キューに送信されたメッセー

0熱

1答えて

パフォーマンスの向上：単一のJMSトピックにswitch文を使用するか、個々のトピックを使用するか？

私は、1つ以上のJMSトピックをリッスンするSpringブートアプリケーションを作成しています。私たちは、JMS実装のためにActiveMQを選択しました。主な懸念事項は、パフォーマンスとスケーラビリティです。毎秒何千ものメッセージが到着する可能性があります。単一のトピックと単一の@JmsListenerメソッドを使用します。リスナーの内部では、JMSプロパティを調べて、メッセージを処理するた