用于 Spring 集成的 Java 7 DSL 表示“int-jms:message-driven-channel-adapter”

Question

我有代码可以从 IBM MQ 读取消息，并带有如下的 spring 集成配置。我需要使用 Spring 集成注释转换为 Java 7 DSL。

<bean id="inQueue" class="com.ibm.mq.jms.MQQueue" depends-on="esbQueueConnectionFactory">
    <constructor-arg value="******" />
</bean>

<int:channel id="readFromChannel">
    <int:interceptors>
        <!-- <int:wire-tap channel="logger" /> -->
    </int:interceptors>
</int:channel>

<int-jms:message-driven-channel-adapter
    id="jmsInAdapter" connection-factory="esbQueueConnectionFactory"
    destination="inQueue" channel="readFromChannel" />

<bean id="msgProcesser" class="com.gap.si.service.MessageProcessService" />

<int:service-activator id="servAct"
    input-channel="readFromChannel" ref="msgProcesser" method="processMessage" />

Answer 1

如果您想使用 Java DSL，请参阅reference manual。

使用Jms 工厂类

IntegrationFlows.from(Jms.messageDriven...)
                .handle(...)
                .get();

如果您只想使用注释，请参阅Spring Integration reference manual。

消息驱动适配器只是一个JmsMessageDrivenEndpoint 类型的@Bean，它获取一个侦听器容器和一个ChannelPublishingJmsMessageListener。