2

Mule 3.3.1 で遅延 JMS メッセージプロセッサを作成するにはどうすればよいですか? 私の目標は、特定の間隔でキューからのメッセージを処理することです...メッセージを処理するために毎分目を覚ますリスナー。

次の構成がありますが、遅延は受け入れられません。メッセージがロールバックされると、すぐに選択されて処理されます。

    <spring:bean id="MQConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
        <spring:property name="transportType" value="1"/>
        <spring:property name="hostName" value="myHost"/>
        <spring:property name="port" value="1414"/>
        <spring:property name="queueManager" value="myQmgr"/>
    </spring:bean>

<jms:connector name="queueConnector" connectionFactory-ref="MQConnectionFactory" 
            specification="1.1" username="xxx" password="yyy" 
            disableTemporaryReplyToDestinations="true"
            numberOfConcurrentTransactedReceivers="3" maxRedelivery="5">
            <service-overrides transactedMessageReceiver="com.mulesoft.mule.transport.jms.TransactedPollingJmsMessageReceiver"/>
</jms:connector>

<jms:endpoint name="someQueue" queue="osmQueue" connector-ref="queueConnector">
  <jms:transaction action="ALWAYS_BEGIN"/>          
  <property key="pollingFrequency" value="60000"/> 
</jms:endpoint>

私は多くの検索を行いましたが、適切な解決策を特定できません。より良い選択肢があれば、私はオープンです。どんな助けにも感謝します。2日たっても返事なし？私は質問を間違って言いましたか？

4

1 に答える 1

0

Quartzを使ってみましたか？この構成により、JMS インバウンドが毎分起動されます

<flow name="ftpFlow2" doc:name="ftpFlow2">
        <quartz:inbound-endpoint jobName="job1" repeatInterval="60000" responseTimeout="10000"     doc:name="Quartz">
        <quartz:endpoint-polling-job>
            <quartz:job-endpoint ref="someQueue"/>
        </quartz:endpoint-polling-job>
    </quartz:inbound-endpoint>
    </flow>
于 2013-11-29T21:24:22.550 に答える