spring - 在 Spring Integration 的发布订阅 channel 上指定 ServiceActivator 的顺序(使用 javaConfig)

Question

我目前正在 integration-context.xml 文件中指定服务激活器和相关的发布订阅 channel 。像这样的东西(删节版):

<int:publish-subscribe-channel id="notificationChannel" task-executor="executor" />

<int:gateway service-interface="com.integration.gateway.RestClientGateway" default-request-channel="notificationChannel" async-executor="executor"/>

<int:service-activator ref="restClient" method="sendRequest" **order="1"** input-channel="notificationChannel"/>
<int:service-activator ref="actionPersistor" method="persistNotification" **order="2"** input-channel="notificationChannel"/>

现在我需要指定一个自定义执行程序类(用于 MDC 日志记录)，所以我开始尝试将其移动到基于注释的方法。类似的东西:

@Bean
@Description("PubSub channel for notification")
public MessageChannel notificationChannel() {
    return new PublishSubscribeChannel(mdcTaskExecutor());
}

@Bean
public TaskExecutor mdcTaskExecutor() {
    return MDCThreadPoolTaskExecutor.newWithInheritedMdc(10, 20, 25);
}

@MessagingGateway(name = "restClientGateway", defaultRequestChannel = "notificationChannel", asyncExecutor = "mdcExecutor")
public interface RestClientGateway {

    Future<Message<String>> sendRequest(Message<BlEvent> message);
}

@ServiceActivator(inputChannel = "notificationChannel")
public Message<String> sendRequest(Message<BlEvent> message) {

@ServiceActivator(inputChannel="notificationChannel")
public void persistNotification(Message<BlEvent> message) {

我的问题是，是否有任何方法可以指定 @ServiceActivators 从发布订阅 channel 接收消息的顺序，类似于我在 integration-context.xml 中定义它的方式。

非常感谢您的帮助。如果这比设置属性太简单，请提前道歉，因为我似乎无法找到它。

Answer 1

是的，您只需添加 @Order以及那些消息注释。

我猜我们在引用手册中有一个遗漏没有提到。

随时就此事提出 JIRA 票!