此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring Integration 6.5.1! |
5.3 和 5.4 之间的更改
Apache Kafka 的通道适配器
独立的 Spring Integration for Apache Kafka 项目已合并为spring-integration-kafka
模块添加到此项目。
这KafkaProducerMessageHandler
sendTimeoutExpression
默认值已更改。
您现在可以访问Future<?>
对于基础send()
操作。
有关更多信息,请参阅 Spring for Apache Kafka 支持。
R2DBC 通道适配器
引入了用于 R2DBC 数据库交互的通道适配器。 有关更多信息,请参阅 R2DBC 支持。
Redis Stream 支持
引入了 Redis Stream 支持的通道适配器。 有关详细信息,请参阅 Redis Stream 出站通道适配器。
可续期锁注册表
引入了可续订锁注册表,以允许续订分布式锁的租约。 有关更多信息,请参阅 JDBC 实现。
ZeroMQ 支持
ZeroMqChannel
,ZeroMqMessageHandler
和ZeroMqMessageProducer
已被引入。
有关更多信息,请参阅 ZeroMQ 支持。
一般更改
单向消息传递网关(void
方法返回类型)现在将nullChannel
显式地将replyChannel
标头以忽略任何可能的下游回复。
有关详细信息,请参阅设置默认回复通道。
此外,网关方法调用程序 (GatewayProxyFactoryBean.MethodInvocationGateway
) 现在以网关代理 Bean 名称和方法签名的组合形式提供托管 Bean 名称。
例如:sampleGateway#echo(String)
.
这会影响为网关方法调用公开的消息历史记录和指标,并在应用程序上下文的启动和关闭期间提供细粒度日志。
聚合器(和重新排序器)现在可以使孤立组(持久存储中的组过期,其中应用程序重新启动后没有新消息到达)。 有关详细信息,请参阅聚合器过期组。
被千分尺仪取代的旧指标已被删除。
线程屏障现在有两个单独的超时选项:requestTimeout
和triggerTimeout
.
AMQP 更改
出站终结点现在具有处理发布者确认和返回的新机制。 有关详细信息,请参阅发布者确认和退货的替代机制。
一个新的BatchMode.EXTRACT_PAYLOAD_WITH_HEADERS
由AmqpInboundChannelAdapter
.
有关更多信息,请参阅入站通道适配器。
邮件更改
这AbstractMailReceiver
现在可以生成MimeMessage
按原样,无需急于获取其内容。
有关更多信息,请参阅邮件接收通道适配器。