设置骡队jms队列的轮询频率

我有一个要求，我希望每5分钟轮询一次JMS队列并消耗jms队列中的所有消息。我想这样做是骡子如下：设置骡队jms队列的轮询频率

 <jms:inbound-endpoint queue="jmsqueue" exchange-pattern="one-way" > 
      <properties> 
        <spring:entry key="pollingFrequency" value="100000" /> 
      </properties> 
     </jms:inbound-endpoint>

上面的代码工作，但它忽略了pollingFrequency属性。

有人能帮助我如何设置穆勒JMS队列的轮询频率？

上述问题已解决。但随着我的修复，我得到以下异常：

WARN 2013-05-01 15:04:05,268 [jmsConnector.receiver.14] com.mulesoft.mule.transport.jms.TransactedPollingJmsMessageReceiver: Error in TX notification handler. 
javax.jms.IllegalStateException: The session is closed. 
    at progress.message.jimpl.Session.getJMSObjectClosedException(Session.java:3341) 
    at progress.message.jimpl.Session.commit(Session.java:1022) 
    at progress.message.jimpl.Session.commit(Session.java:1008) 
    at progress.message.jimpl.Session.commit(Session.java:969) 
    at com.mulesoft.mule.transport.jms.TransactedPollingJmsMessageReceiver$2.onNotification(TransactedPollingJmsMessageReceiver.java:314) 
    at com.mulesoft.mule.transport.jms.TransactedPollingJmsMessageReceiver$2.onNotification(TransactedPollingJmsMessageReceiver.java:298) 
    at org.mule.context.notification.Sender.dispatch(Sender.java:40) 
    at org.mule.context.notification.Policy.dispatch(Policy.java:122) 
    at org.mule.context.notification.ServerNotificationManager.notifyListeners(ServerNotificationManager.java:249) 
    at org.mule.context.notification.ServerNotificationManager.fireNotification(ServerNotificationManager.java:200) 
    at org.mule.DefaultMuleContext.fireNotification(DefaultMuleContext.java:435) 
    at org.mule.transaction.AbstractTransaction.fireNotification(AbstractTransaction.java:144) 
    at org.mule.transaction.AbstractTransaction.commit(AbstractTransaction.java:83) 
    at org.mule.transaction.AbstractSingleResourceTransaction.commit(AbstractSingleResourceTransaction.java:79) 
    at org.mule.transaction.TransactionCoordination.resolveTransaction(TransactionCoordination.java:222) 
    at org.mule.execution.BeginAndResolveTransactionInterceptor.resolveTransactionIfRequired(BeginAndResolveTransactionInterceptor.java:77) 
    at org.mule.execution.BeginAndResolveTransactionInterceptor.execute(BeginAndResolveTransactionInterceptor.java:59) 
    at org.mule.execution.ResolvePreviousTransactionInterceptor.execute(ResolvePreviousTransactionInterceptor.java:48) 
    at org.mule.execution.SuspendXaTransactionInterceptor.execute(SuspendXaTransactionInterceptor.java:54) 
    at org.mule.execution.ValidateTransactionalStateInterceptor.execute(ValidateTransactionalStateInterceptor.java:44) 
    at org.mule.execution.IsolateCurrentTransactionInterceptor.execute(IsolateCurrentTransactionInterceptor.java:44) 
    at org.mule.execution.ExternalTransactionInterceptor.execute(ExternalTransactionInterceptor.java:52) 
    at org.mule.execution.RethrowExceptionInterceptor.execute(RethrowExceptionInterceptor.java:32) 
    at org.mule.execution.RethrowExceptionInterceptor.execute(RethrowExceptionInterceptor.java:17) 
    at org.mule.execution.TransactionalErrorHandlingExecutionTemplate.execute(TransactionalErrorHandlingExecutionTemplate.java:113) 
    at org.mule.execution.TransactionalErrorHandlingExecutionTemplate.execute(TransactionalErrorHandlingExecutionTemplate.java:34) 
    at com.mulesoft.mule.transport.jms.TransactedPollingJmsMessageReceiver.poll(TransactedPollingJmsMessageReceiver.java:110) 
    at org.mule.transport.AbstractPollingMessageReceiver.performPoll(AbstractPollingMessageReceiver.java:219) 
    at org.mule.transport.PollingReceiverWorker.poll(PollingReceiverWorker.java:84) 
    at org.mule.transport.PollingReceiverWorker.run(PollingReceiverWorker.java:53) 
    at org.mule.work.WorkerContext.run(WorkerContext.java:311) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 
    at java.lang.Thread.run(Unknown Source)

请帮我解决这个问题。

感谢， vkumar

来源

2013-04-26 user2324686

你与XaTransactedJmsMessageReceiver或与JBoss使用它试图？ – AlessandroEmm 2013-04-26 18:25:49

[mule - 如何从周期性基础（石英）作业上的jms队列中消耗所有消息的可能重复（http://stackoverflow.com/questions/16241300/mule-how-to-consume-all-messages-from- jms-queue-on-periodic-basesquartz-job） – 2013-04-27 07:05:26

我正在使用TransactedPollingJmsMessageReceiver，如下所示： – user2324686 2013-04-29 14:12:43

你通过提高响应超时

您还可以配置重新连接策略，如果你的连接丢失

来源

2015-10-26 12:33:50 Utsav

设置骡队jms队列的轮询频率

回答

相关问题