如何用Spring Integration DSL配置StepExecutionListener

Question

我试图配置一个Spring Batch侦听器，以便为StepExecution事件向Spring Integration Gateway发送消息。

下面的链接解释了如何使用XML配置

有没有更简单的方法使用DSL，避免这种变通？是否有某种方法可以像使用XML配置那样将批处理侦听器直接连接到网关？

干杯，门诺

Answer 1

首先，SI DSL只是现有SI Java和注释配置的扩展，因此它可以与任何其他Java配置一起使用。当然，XML@import也是正确的。

DSL中没有网关配置，因为它的方法不能与线性IntegrationFlow连接。需要为每种方法提供下游流。

因此，@messaginggateway是一个正确的方法：

@MessagingGateway(name = "notificationExecutionsListener", defaultRequestChannel = "stepExecutionsChannel")
public interface MyStepExecutionListener extends StepExecutionListener {}

另一方面，@MessagingGateway解析以及 标记解析最终得到GatewayProxyFactoryBean定义。因此，如果不想引入新类，只需声明该bean：

@Bean
public GatewayProxyFactoryBean notificationExecutionsListener(MessageChannel stepExecutionsChannel) {
    GatewayProxyFactoryBean gateway = new GatewayProxyFactoryBean(StepExecutionListener.class);
    gateway.setDefaultRequestChannel(stepExecutionsChannel);
    return gateway;
}

@Bean
public IntegrationFlow gatewayFlow() {
        return IntegrationFlows
               .from(MyGateway.class, g -> 
                                         g.method("save", f -> f.transform(...)
                                                                .filter(...))
                                          .method("delete", f -> f.handle(...)))
               .handle(...)
               .get();                            
}

然而，我不确定它是否会简化生命周期，因为任何嵌套的Lambda只会增加更多的噪声，并可能破坏松散耦合原则。