Spring統合のJava DSL：カスタムデシリアライザを指定

Question

私は、チャネルアダプタを介してキューをリスンするコンポーネントにJMSを介して転送されるオブジェクトがあります。

IntegrationFlows 
       .from(Jms.messageDriverChannelAdapter(connectionFactory) 
         .destination(inputQueue) 
       ) 

を設定するしかし、この種だけしかしObjectMessageを受信する可能性を提供しますBytesMessageも受け付けるカスタムデシリアライザを提供したいと思います。設定は次のようになります。

IntegrationFlows 
       .from(Jms.messageDriverChannelAdapter(connectionFactory) 
         .destination(inputQueue) 
         .deserializeWith((javax.jms.Message message) -> new org.springframework.messaging.Message(){}) // Does not exist, but desired 
       ) 

ありがとうございます。

Answer 1

デシリアライゼーションのロジックはあなたのように指定することができ、org.springframework.jms.support.converter.MessageConverterの一部です：

.from(Jms.messageDriverChannelAdapter(connectionFactory) 
     .destination(inputQueue) 
     .jmsMessageConverter(...) 
) 

私はラムダとのことをするためにあなたの願いを理解し、私は場合は、余分なロジックを導入する理由が表示されませんこれは既存の抽象化で達成することができます。