spring-jms

0熱

1答えて

JMS接続がJMSSecurityExceptionをスローしない不正なルートにメッセージを送信するとき

Javaサービスからメッセージを送信するためにSpringでApache Camelを使用しています。交換時にエラーが発生した場合、特定のイベントを処理/トリガーする必要があります。私は私の目的を達成するために以下のコードを使用しています。私は間違ったルート名broadcast.SIMULATOR.ROUTE1、エンドポイントの値を設定しテストするために try { prod

1熱

1答えて

WebSphereリバティーwasJmsServerデッドレターキュー

Liberty組み込みJMSメッセージングプロバイダーを使用して、WLSリバティープロファイルバージョン16.0.0.2でDLQを設定する際の参考資料を教えてください。私はバネのjmsリスナーで設定されたキューを持っており、メッセージリスナーがRuntimeExceptionをスローすると、メッセージは数回の再試行の後にレターキューを処理するようになります。ありがとうございました。

0熱

1答えて

耐久性のあるリスナ/コンシューマのユースケースシナリオ

したがって、コンシューマをトピック、つまり複数のリスナに作成しています。私はそれらを耐久性があるように構成しています。私は耐久消費のユースケースのシナリオを考えています @Bean public DefaultMessageListenerContainer listenerContainers() { DefaultMessageListenerContainer container

0熱

1答えて

他のサーバへのActiveMQの移行

私はアクティブなものがあります。storeUsage〜100GB、それは消耗しようとしていました。私はstoreUsageの値にしました。そして、もう一度再起動しますが、activemqサーバは起動していません。何が問題になる可能性がありますか？デバッグモードでログインするには何もありません kahaDbをバックアップし、kahaDb内のすべてのファイルを削除して再起動できますか？何をすべきか

0熱

1答えて

耐久性のある複数のリスナー。彼らは同時に働きますか？

私の構成は： @Bean public ActiveMQConnectionFactory connectionFactory(){ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); connectionFactory.setBrokerURL(DEFAUL

1熱

1答えて

異なるメッセージタイプに対してaws sqsを使用

私のプロジェクトでAWS SQSとSpring JMSを使用しています。 @JmsListener（destination = "queue_name"）を使って自分のメソッドを持っています。私はこのキューを2つの異なるタイプのメッセージに使いたいと思っています。このリスナーはこのキューに設定されているため、両方のタイプのメッセージを受信します。私が達成しようとしているのは、あるタイプのメッセー

2熱

1答えて

Sprint起動時のActiveMQのActive MQ RedeliveryPolicyを変更する

Spring起動時にActiveMQの再配信ポリシーを変更するにはどうすればよいですか？私はDefaultJmsListenerContainerFactoryでFixedBackOffを指定しようとしましたが、それは役に立たなかった。以下は、jmsファクトリBeanを初期化するために使用しているコードです。私は、キューに入ってくるメッセージを処理するメッセージコンシューマを持っています。使用でき

0熱

1答えて

MessageConversionExceptionの汎用ハンドラ

特定の形式を持ち、特定のJavaクラスにデシリアライズできるときに、キューからメッセージを処理したい。そのために、私は以下の方法を作りました。メッセージはMessageクラスのインスタンスに非直列化することはできない、と私はorg.springframework.messaging.converter.MessageConversionExceptionを得るとき @JmsListener(des