spring - Spring 統合メッセージ ハンドラー: ActiveMQTextMessage

Question

spring-int アグリゲーター コンポーネントで jdbc-store を使用する際に問題に直面しています。

私のフローは次のようなものです：

ActiveMQ -> アグリゲーター -> jdbc-message-store -> ftp

しかし、メッセージを処理する際に、ActiveMQTextMessage はシリアル化できないため、java.io.NotSerializableException に直面しています。

私はsimpleMessageStore（メモリ内）を使用していたので、このソリューションは機能していましたが、今は機能しません。

ActiveMQTextMessage を適切な Serializable Message に変換するために MessageHandler の独自の実装を作成する必要がありますか、それとも何か間違っていますか?

ありがとう。

<int-jms:message-driven-channel-adapter id="inputQueueAdapter" 
                        channel="mqChannel"
                        max-concurrent-consumers="3" 
                        cache-level="3"
                        extract-payload="true"
                        connection-factory="jmsConnectionFactory"
                        destination-name="test.xdr.queue"/>


<int:aggregator         id="XDRAggegator"
                        ref="xdrAggregator"
                        input-channel="mqChannel"
                        output-channel="publishChannel"
                        message-store="jdbc-messageStore"
                />

<int-jdbc:message-store id="jdbc-messageStore" data-source="dataSource"  />