Spring集成Java DSL：指定自定义反序列化器

Posted 2023-03-10

【中文标题】Spring集成Java DSL：指定自定义反序列化器

【英文标题】：Spring integration Java DSL: specify custom deserializer

【发布时间】：2016-10-18 11:40:56

【问题描述】：

我有通过 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
                )

非常感谢。

【参考方案1】：

反序列化逻辑是org.springframework.jms.support.converter.MessageConverter 的一部分，您可以将其指定为：

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

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

【讨论】：

非常感谢您的快速回复。小问题：我不指定的时候，是不是用了org.springframework.jms.support.converter.SimpleMessageConverter？

+1：ChannelPublishingJmsMessageListener：github.com/spring-projects/spring-integration/blob/master/…