問題タブ [spring-messaging]

Springメッセージング@MessageMappingアノテーション付きメソッドにメッセージを送信するにはどうすればよいですか? 私は次のコードを持っています:

そして、私はメッセージを送信しようとしています:

デフォルトで Spring を作成するタイプ org.springframework.messaging.simp.SimpMessagingTemplate の messagingTemplate 。

しかし、働かないでください。メッセージのタイプは org.springframework.messaging.Message です

Spring 4.x の DefaultJmsListenerContainerFactory を使用して、ActiveMQ キューに接続し、@JmsListener を使用してそのキューからのメッセージを処理し、メッセージを同じ ActiveMQ ブローカーのトピックにプッシュします。

コンシューマ/リスナーとプロデューサの両方に単一のキャッシング接続ファクトリを使用しており、コンシューマではなくプロデューサをキャッシュできるように、キャッシュ コンシューマを false に設定しています。また、同時実行数を 1 ～ 3 に設定しました。これにより、アプリケーションの起動時にキューに少なくとも 1 つのコンシューマーが存在すると予想されます。メッセージが増加すると、コンシューマーの数は 3 に達します。メッセージが減少すると、コンシューマーの数も 1 に戻ると予想していました。しかし、スレッド (defaultmessagelistenercontainer-2/3) を見ると、それらは待機状態にあり、シャットダウンしていません。負荷が低下すると、多くのコンシューマーもシャットダウンすることが予想されるというのは、予想される動作ではないでしょうか? 以下の私の設定を見てください。

ApplicationContext.java

アプリケーションのプロパティ

ある種の文字列文字列を返す関数が1つあります文字列は静的ではなく動的です

そして、言語を変更するために春のメッセージタグを使用しています

静的文字列を渡すと正常に動作します

しかし、varの動的な値を保存したいので、var 'error_msg'を使用しています

jspページで例外を与える

SUBSCRIBE リクエストを受け入れる Spring Websocket Stomp アプリケーションがあります。

アプリケーションには、SUBSCRIBE のハンドラーがあります。つまり、

サブスクリプションを検証するために使用します。

onApplicationEventで何かをチェックし、この関数から STOMP ERROR メッセージをクライアントに送り返します。

このレシピを見つけましたSpring WebSocketでエラーメッセージをSTOMPクライアントに送信する方法は? しかし、outboundChannel を取得する方法を理解する必要があります。

次のコードも試しました：

そして、トピックをサブスクリプショントピックと /queue/error トピックにしようとしました。ただし、メッセージがクライアントに伝播することはありませんでした。

クライアントでは、次を使用します。

私の目標は、STOMP ERROR を送信したときに function(error) を呼び出すことです。

Outboundchannel を取得するなどして、適切な STOMP ERROR を正確に送信する方法を教えてください。

SQS spring-boot:spring-cloud を使用しています。パラメーターを外部化し、アクティブなプロファイルに基づいて値を取得したい

この問題を解決する方法はありますか？

何かのようなもの

DefaultSubscriptionRegistry のデフォルトの動作を拡張したいと考えています。XML でカスタム SubscriptionRegistry を設定するように SimpleBrokerMessageHandler を構成するにはどうすればよいですか?