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(...)
 )

我理解您希望使用 Lambda 实现这一点，但如果可以通过现有抽象来实现，我认为没有理由引入额外的逻辑。