新增功能
对于那些已经熟悉 Spring 集成的人来说,本章简要概述了 6.5 版的新功能。
如果您对早期版本中引入的更改和功能感兴趣,请参阅更改历史记录。
一般更改
以前已弃用的org.springframework.util.concurrent.ListenableFuture
已被删除,取而代之的是CompletableFuture
.
以前弃用的基于 SPEL 的 Control Bus 组件已被删除,以支持ControlBusCommandRegistry
.
这<control-bus use-registry="">
属性现在已弃用,无需替换,因为只有ControlBusCommandRegistry
功能可用。
The Java DSLcontrolBusOnRegistry()
Operator 已弃用,取而代之的是 restoredcontrolBus()
它现在完全基于ControlBusCommandRegistry
.
请参阅 Control Bus 了解更多信息。
这AbstractCorrelatingMessageHandler
不会抛出IllegalArgumentException
作为MessageGroupProcessor
.
相反,此类集合被包装到单个回复消息中。
有关更多信息,请参阅 Aggregator。
这discardIndividuallyOnExpiry
Correlation Handlers 的选项
聚合器和重新排序器现在可以通过设置discardIndividuallyOnExpiry
自false
.
有关更多信息,请参阅 ReleaseStrategy。
这LockRegistry
在MessageStore
这AbstractMessageGroupStore
现在可以配置LockRegistry
以原子方式执行一系列持久化作。
有关更多信息,请参阅使用 LockRegistry。
千分尺观测变化
这SourcePollingChannelAdapter
端点现在启动CONSUMER
kind 观察收到的消息。
这MessageReceiverContext
现在区分handler
,message-source
和message-producer
的值spring.integration.type
low cardinality 标签。
有关更多信息,请参阅千分尺观测。
可选的 Paho MQTT 依赖项
这org.eclipse.paho:org.eclipse.paho.client.mqttv3
的依赖项spring-integration-mqtt
现在也是可选的,因为org.eclipse.paho:org.eclipse.paho.mqttv5.client
一直都是。
有关更多信息,请参阅 MQTT 支持。
Apache Kafka 支持更改
这KafkaMessageSource
和KafkaMessageDrivenChannelAdapter
现在生成MessageHeaders.ID
和MessageHeaders.TIMESTAMP
headers 作为其余的 Spring Integration 通道适配器。
通过注入MessagingMessageConverter
使用默认设置。
有关更多信息,请参阅 Apache Kafka 支持。