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 流出站通道适配器。
可再生锁登记处
引入了可再生锁注册表,以允许续租分布式锁。 有关更多信息,请参阅 JDBC 实现。
ZeroMQ 支持
ZeroMqChannel
,并已被介绍。
有关更多信息,请参阅 ZeroMQ 支持。ZeroMqMessageHandler
ZeroMqMessageProducer
一般更改
单向消息传递网关(方法返回类型)现在在标头中显式设置一个,以忽略任何可能的下游回复。
有关详细信息,请参阅设置默认回复通道。void
nullChannel
replyChannel
此外,网关方法调用程序 () 现在提供托管 Bean 名称,作为网关代理 Bean 名称和方法签名的组合。
例如:。
这会影响为网关方法调用公开的消息历史记录和指标,并在应用程序上下文的启动和关闭期间提供精细的日志。GatewayProxyFactoryBean.MethodInvocationGateway
sampleGateway#echo(String)
聚合器(和重排序器)现在可以使孤立的组(持久性存储中的组)过期,在应用程序重新启动后没有新消息到达。 有关详细信息,请参阅聚合器过期组。
已被千分尺取代的旧指标已被删除。
线程屏障现在有两个单独的超时选项:和 。requestTimeout
triggerTimeout
AMQP 更改
出站终结点现在具有用于处理发布者确认和返回的新机制。 有关详细信息,请参阅发布者确认和返回的替代机制。
新的 .
有关详细信息,请参阅入站通道适配器。BatchMode.EXTRACT_PAYLOAD_WITH_HEADERS
AmqpInboundChannelAdapter
邮件更改
现在可以按原样生成,而无需急切地获取其内容。
有关详细信息,请参阅邮件接收通道适配器。AbstractMailReceiver
MimeMessage