2

我有以下 xml,我想用@Configuration类替换这个烦人的 xml

<int:gateway id="someActionGateway "
        service-interface="x.y.z.SomeActionGateway"
        default-request-channel="some-action-channel-raw" />

 <int:channel id="some-action-channel-raw" />

 <int:header-enricher input-channel="some-action-channel-raw" output-channel="some-action-to-json-channel">
        <int:header name="someAction" value="sendSomething"/>
 </int:header-enricher>

    <int:channel id="some-action-to-json-channel" />

    <int:object-to-json-transformer
        input-channel="some-action-to-json-channel" output-channel="some-action-outbound-channel"
        content-type="text/x-json" />

    <int:channel id="some-action-outbound-channel" />

    <int-amqp:outbound-channel-adapter
        channel="some-action-outbound-channel" exchange-name="some-action-exchange"
        routing-key="someAction.routing.key" amqp-template="amqpTemplate"
        mapped-request-headers="*">
    </int-amqp:outbound-channel-adapter>

    <rabbit:direct-exchange name="some-action-exchange"
        auto-delete="false" durable="true">
        <rabbit:bindings>
            <rabbit:binding queue="some-action-queue" key="someAction.routing.key" />
        </rabbit:bindings>
    </rabbit:direct-exchange>

和我的网关:

public interface SomeActionGateway {

    @Gateway
    public void sendSomething(@Payload SomeDto dto);

}

我已经在为 spring-amqp 使用配置注释类,它工作得很好。我怎样才能对 Spring Integration 配置做同样的事情?

PS:我正在使用 Spring 3.2 和 Spring integration 3.0

4

1 回答 1

4

很抱歉您发现 XML 配置“烦人”。

我们正在努力改进@ConfigurationSpring Integration 的 JavaConfig ( ) 体验。

您现在可以使用 JavaConfig 连接任何端点,但这并不漂亮;端点可以用MessageDrivenConsumer(或PollingConsumer)与适当的MessageHandler. 您必须深入ConsumerEndpointFactoryBean研究 XML 解析器以获取完整的详细信息;大多数组件需要多个 bean 定义。

就像我说的,我们正在努力;我们目前有一个开放的网关请求请求,并且扩展存储库中有一个 Java DSL 正在进行中,但它是一个正在进行中的工作,Scala 和 Groovy DSLs 也是如此。

编辑:

Spring Integration 4.0 使它更易于使用@Configuration

请参阅最近的网络研讨会

于 2014-02-19T01:32:39.860 回答