Spring Integration 5.0 第 5 个里程碑版本发布
我代表 Spring Integration 团队高兴地宣布,Spring Integration 5.0 的第五个里程碑版本(5.0.0.M5
)现已发布。
此版本包含 21 个 JIRA(以及一些 GitHub Issue),包括 Bug 修复和许多新功能。自上次宣布的 Milestone 3 以来,M4 和 M5 中的一些功能亮点如下:
-
Splitter
现在可以处理 JavaStream
和 ReactorFlux
有效载荷。如果输出通道是ReactiveStreamsSubscribableChannel
,分割支持背压。 -
引入了
ErrorMessagePublisher
和ErrorMessageStrategy
,旨在通过ErrorMessage
的初始消息提供更好的错误处理体验。Spring Kafka 2.0 和 Spring AMQP 2.0 中的MessageListenerContainer
配备了它们自己的ErrorMessageStrategy
,用于在错误处理流程中表示ErrorMessage
中的原始数据。 -
新的
MockMessageHandler
已添加到 Spring Integration 测试框架中,用于在单元测试中替换真实的 `MessageHandler`MessageHandler mockMessageHandler = mockMessageHandler() .handleNextAndReply(m -> m.getPayload().toString().toUpperCase());
this.mockIntegrationContext .substituteMessageHandlerFor("myServiceActivator", mockMessageHandler);
this.pojoServiceChannel.send(new GenericMessage<>("foo")); receive = this.results.receive(10000);
assertEquals("FOO", receive.getPayload());
…