如何在 Spring 集成中使用 Java DSL 创建 ws 入站网关？

Question

我有以下 ws 入站网关。如何使用 Spring Integration Java 8 DSL 进行此配置？

<int-ws:inbound-gateway id="ws-inbound-gateway"
                        request-channel="ws-request-channel"
                        reply-channel="ws-response-channel"
                        error-channel="ws-error-channel"/>

Answer 1

不幸的是，我没有找到对这种入站网关的一级支持，但是您可以按如下方式修复此问题：

@Configuration
@EnableIntegration
public class IntegrationConfiguration {

    @Bean
    public SimpleWebServiceInboundGateway SimpleWebServiceInboundGateway() {
            SimpleWebServiceInboundGateway simpleWebServiceInboundGateway = new SimpleWebServiceInboundGateway();
            // your inbound configurtion
            .....

            return simpleWebServiceInboundGateway;
        }

    @Bean
    public IntegrationFlow integrationFlow(){
            return IntegrationFlows.from(SimpleWebServiceInboundGateway())
            // your pipeline
            .....
                    .get();
        }   
    }

在你的 Maven pom 中不要忘记这个依赖

<dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-java-dsl</artifactId>
            <version>1.1.2.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-ws</artifactId>
            <version>4.2.5.RELEASE</version>
        </dependency>

我希望这可以帮助你