|
对于最新的稳定版本,请使用 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按原样,无需急于获取其内容。
有关更多信息,请参阅邮件接收通道适配器。