这个问题是 4 个月前提出的。
https://stackoverflow.com/posts/16241300/edit
任何人?
“我在 mule flow 中编写了一个石英代码,每 5 分钟消耗一次队列中的所有消息。
<quartz:inbound-endpoint jobName="abc" cronExpression="0 0/1 * * * ?" doc:name="Quartz">
<quartz:endpoint-polling-job>
<quartz:job-endpoint ref="jmsEndPoint" />
</quartz:endpoint-polling-job>
</quartz:inbound-endpoint>
但是即使队列中有 5 条消息,上面的代码一次也只消耗一条消息。
我的要求是每 5 分钟运行一次作业并消耗队列中的所有消息。
另一个要求是使用消息有效负载中的唯一标识符过滤掉重复消息。
任何帮助将不胜感激。"
编辑:JMS 端点
<jms:endpoint name="jmsEndPoint" queue="MyQueue" connector-ref="connector"/>