java - Spring Integration Java Config/DSL 中没有方法的服务激活器

Question

当为 service-activator 使用基于 XML 的配置时，您可以排除 method，如下所示:

<service-activator input-channel="incomingCustomerChannel" output-channel="outgoingCustomerChannel" ref="customerService" />

这将导致 SI 框架根据负载选择 customerService 中的目标方法。如何使用 DSL 和 Java 配置实现相同的功能？

目前我有以下内容:

@Bean
public IntegrationFlow customerRequestFlow(ConnectionFactory connectionFactory) {

    return IntegrationFlows.from((MessagingGateways g) -> g.jms(connectionFactory)
                                                           .correlationKey("JmsCorrelationID")
                                                           .destination("customer_incoming.queue"))
                                                           .handle("customerService", "addCustomer")
                                                           .get();
}

服务激活器定义为:

@Component
public class customerService {

    @ServiceActivator
    public AddCustomerResponse addCustomer(AddCustomerRequest addCustomerRequest) {

        // add customer
    }
}

我扩展了激活器以添加一个 deleteCustomer 方法，如下所示:

@Component
public class customerService {

    @ServiceActivator
    public AddCustomerResponse addCustomer(AddCustomerRequest request) {

        // add customer
    }

    @ServiceActivator
    public DeleteCustomerResponse deleteCustomer(DeleteCustomerRequest request) {

        // delete customer
    }
}

我不能简单地从 .handle("customerService", "addCustomer") 中删除 , "addCustomer"，因为 methodName 是必需的。是否可以在 Java 配置/DSL 中实现这一点？

Answer 1

您可以使用相同的 .handle()使用 null对于方法名称:

.handle("customerService", "addCustomer")

或以 version 1.1 开头您可以使用该方法的新版本:

@Autowired
private CustomerService customerService;
....
.handle(this.customerService)

这两种变体的功能与您使用 ref 时的功能完全相同对于 <service-activator> .