新增功能
对于那些已经熟悉 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。
这discardIndividuallyOnExpiryCorrelation Handlers 的选项
聚合器和重新排序器现在可以通过设置discardIndividuallyOnExpiry自false.
有关更多信息,请参阅 ReleaseStrategy。
这LockRegistry在MessageStore
这AbstractMessageGroupStore现在可以配置LockRegistry以原子方式执行一系列持久化作。
有关更多信息,请参阅使用 LockRegistry。
千分尺观测变化
这SourcePollingChannelAdapter端点现在启动CONSUMERkind 观察收到的消息。
这MessageReceiverContext现在区分handler,message-source和message-producer的值spring.integration.typelow 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.TIMESTAMPheaders 作为其余的 Spring Integration 通道适配器。
通过注入MessagingMessageConverter使用默认设置。
有关更多信息,请参阅 Apache Kafka 支持。