Springからバックグラウンドで観測可能なRxJavaを購読する

Question

Webアプリケーションのバックグラウンドで処理したいRxJava Observableがあります。これは、サービスがメッセージキューのイベントに反応できるようにするためです。このObservableを直接購読することができるSpringの設定はありますか？

Spring TaskExectorのようなものは、バックグラウンドスレッドがObservableイベントを処理できるようにします。しかし、私はスレッドを生きて保持する必要がないだろう少し洗練された何か。

Answer 1

Observableを作成して@PostConstructメソッドでサブスクライブするSpringサービスがあり、@PreDestroyのサブスクライブ解除があります。これにより、JMXを介して公開されているカウンターや並列処理のようなものが可能になり、JMXやサービスメソッドを介してオブザーバブルを停止/再開することさえできます。