java - 相当于 的 Spring Integration DSL

Question

什么是 Spring Integration DSL 创建等价物的方式

<int:gateway service-interface="MyService" default-request-channel="myService.inputChannel"/>

// where my existing interface looks like
interface MyService { process(Foo foo); }

我无法在 org.springframework.integration.dsl 中找到工厂，并且 IntegrationFlows.from(...) 的参数列表都没有帮助 self 发现。

感觉好像我缺少了一些东西，比如来自 https://github.com/spring-projects/spring-integration-java-dsl/wiki/Spring-Integration-Java-DSL-Reference#using-protocol-adapters 的 Java 协议(protocol)适配器。 .

// I imagine this is what I can't find
IntegrationFlows.from(Java.gateway(MyService.class)
    .channel("myService.inputChannel")
    .get();

我唯一遇到的事情是在一篇旧博客文章中，但它似乎需要用 @MessagingGateway 和 @Gateway 注释界面，我我想避免。参见 https://spring.io/blog/2014/11/25/spring-integration-java-dsl-line-by-line-tutorial

Answer 1

我们最近在 Spring Integration 5.0 中做到了这一点。有了它，你真的可以做到这一点:

@Bean
public IntegrationFlow controlBusFlow() {
    return IntegrationFlows.from(ControlBusGateway.class)
            .controlBus()
            .get();
}

public interface ControlBusGateway {

    void send(String command);
}

查看最新blog post中的更多信息.

现在您别无选择，除非在接口(interface)上声明 @MessagingGateway 并从该网关定义的请求 channel 启动流程。