0

spring-rabbit を使用して、RabbitMQ 経由でメッセージを送信する必要がある 2 つの別個の Java アプリがあります。プロデューサーであるアプリでは、キューに送信される前に Java オブジェクトを JSON メッセージに変換するJsonMessageConverterためのメッセージ コンバーターとして使用しています。RabbitTemplate

コンシューマーである他のアプリでは、JSON メッセージを Java オブジェクトに変換したいと考えています。SimpleMessageListenerContainerカスタムで使用してみましたが、キューから sMessageListenerを取得できますが、Messageそれらを JSON から Java オブジェクトに変換する方法がわかりません。

JsonMessageConverterRabbitMQ から非同期でメッセージを消費する場合、どのように使用すればよいですか?

4

1 に答える 1

5

最終MessageListenerAdapter的に をカスタム デリゲート オブジェクトとともにJsonMessageConverterとして使用することになりましたMessageConverter。そのようです：

SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer();
listenerContainer.setMessageListener(new MessageListenerAdapter(new EventHandler(), new JsonMessageConverter()));

私EventHandlerのクラスには、逆シリアル化された JSON オブジェクトを渡す handleMessage というメソッドが 1 つあります。

于 2013-06-19T15:51:40.363 に答える