5.3 和 5.4 之间的更改
Apache Kafka 的通道适配器
独立的 Spring Integration for Apache Kafka 项目已作为 spring-integration-kafka 模块合并到此项目中。
KafkaProducerMessageHandler 的 sendTimeoutExpression 默认值已更改。
您现在可以访问底层 send() 操作的 Future<?>。
有关更多信息,请参阅 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)。这会影响为网关方法调用公开的消息历史记录和指标,并在应用程序上下文启动和关闭期间提供细粒度日志。
聚合器(和重新排序器)现在可以使孤立组过期(应用程序重启后没有新消息到达的持久存储中的组)。有关更多信息,请参阅 聚合器过期组。
已移除被 Micrometer 仪表替换的旧版指标。
线程屏障 现在有两个独立的超时选项:requestTimeout 和 triggerTimeout。
AMQP 更改
出站端点现在具有一种新的机制来处理发布者确认和返回。有关更多信息,请参阅 发布者确认和返回的替代机制。
AmqpInboundChannelAdapter 支持新的 BatchMode.EXTRACT_PAYLOAD_WITH_HEADERS。有关更多信息,请参阅 入站通道适配器。
邮件更改
AbstractMailReceiver 现在可以按原样生成 MimeMessage,而无需急切地获取其内容。有关更多信息,请参阅 邮件接收通道适配器。