Frühling Integration Java DSL: Geben Sie benutzerdefinierte Deserializer

Question

Ich habe Objekt, das über JMS auf ein Bauteil übertragen wird, die über den Kanal-Adapter in die Warteschlange hört:

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

Doch diese Art von Setup gibt nur eine Möglichkeit ObjectMessage jedoch zu erhalten Ich möchte einen benutzerdefinierten Deserializer zur Verfügung stellen, der auch BytesMessage akzeptiert. Das gewünschte Setup sieht so aus:

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

Vielen Dank im Voraus.

Answer 1

Die Deserialisierung Logik ist ein Teil von org.springframework.jms.support.converter.MessageConverter, die Sie als eine angeben:

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

Ich verstehe Ihren Wunsch, dass mit dem Lambda zu machen, aber ich sehe Grund nicht zusätzliche Logik einzuführen, wenn das kann mit einer vorhandenen Abstraktion erreicht werden.