1

如何配置 Spring 集成以使用消息驱动的消费者。使用以下配置，我的消费者正在轮询消息，我无法弄清楚如何使其事件驱动而不是轮询..

 <bean id="dataQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg name="name" value="${jms.data.queue.name}" />
    </bean>

    <jms:message-driven-channel-adapter channel="dataInputChannel" destination="dataQueue"  />
    <int:channel id="dataInputChannel" />    
    <int:channel id="persistDataChannel" />
    <int:channel id="processDataChannel" />

    <int:recipient-list-router id="customRouter" input-channel="dataInputChannel" timeout="10000" ignore-send-failures="true" apply-sequence="true">
        <int:recipient channel="persistDataChannel"/>
        <int:recipient channel="processDataChannel"/>
    </int:recipient-list-router>
4

1 回答 1

1

我不确定你的意思；它是事件驱动的。线程阻塞在客户端库的代码中，直到消息到达，或发生接收超时。如果您担心底层侦听器容器在 TRACE 调试下看到的活动，只需增加其 receiveTimeout。

于 2012-11-13T15:34:45.990 回答