我正在尝试使用持久队列的 vm 传输;这是连接器配置:
<vm:connector
name="vmConnector"
createMultipleTransactedReceivers="true"
numberOfConcurrentTransactedReceivers="20">
<vm:queue-profile maxOutstandingMessages="50000">
<file-queue-store/>
</vm:queue-profile>
</vm:connector>
传输工作正常并且传输,.msg 文件正在累积在 .mule 的相应子目录中。现在,如果我杀死虚拟机(或定期关闭 mule 实例)然后重新启动 mule 和我的应用程序,我希望队列中当前消息的消耗能够恢复,但事实并非如此。
我是不是理解错了什么?我认为这种行为将是使用持久队列的一个原因。还是我的配置有问题?这是我可以从文档中收集到的全部内容,但我可能遗漏了一些东西。
编辑:经过进一步检查,我在我的应用程序日志中发现了以下投诉:
WARN TransactionalQueueManager [THREAD vmConnector.scheduler.03 THREAD]: Could not commit tx 768d9b5c-ab3a-11e1-a48f-ff62aff02664[committing], rolling back instead
org.mule.util.xa.ResourceManagerException: Deleting ...\mule-enterprise-standalone-3.2.2\.mule\myapp\queuestore\work\0-768b784b-ab3a-11e1-a48f-ff62aff02664.msg failed (org.mule.api.store.ObjectStoreException)
at org.mule.util.queue.QueueTransactionContext.doCommit(QueueTransactionContext.java:201)
at org.mule.util.queue.TransactionalQueueManager.doCommit(TransactionalQueueManager.java:173)
at org.mule.util.xa.AbstractResourceManager.commitTransaction(AbstractResourceManager.java:288)
at org.mule.util.xa.DefaultXASession.commit(DefaultXASession.java:83)
at org.mule.transport.vm.VMTransaction.doCommit(VMTransaction.java:59)
at org.mule.transaction.AbstractTransaction.commit(AbstractTransaction.java:82)
at org.mule.transaction.AbstractSingleResourceTransaction.commit(AbstractSingleResourceTransaction.java:78)
at org.mule.transaction.TransactionTemplate.resolveTransaction(TransactionTemplate.java:147)
at org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:117)
at org.mule.transport.TransactedPollingMessageReceiver.poll(TransactedPollingMessageReceiver.java:138)
at org.mule.transport.AbstractPollingMessageReceiver.performPoll(AbstractPollingMessageReceiver.java:219)
at org.mule.transport.PollingReceiverWorker.poll(PollingReceiverWorker.java:85)
at org.mule.transport.ContinuousPollingReceiverWorker.poll(ContinuousPollingReceiverWorker.java:36)
at org.mule.transport.PollingReceiverWorker.run(PollingReceiverWorker.java:53)
at org.mule.work.WorkerContext.run(WorkerContext.java:310)
at java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.rejectedExecution(ThreadPoolExecutor.java:1746)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
at org.mule.work.ScheduleWorkExecutor.doExecute(ScheduleWorkExecutor.java:41)
at org.mule.work.MuleWorkManager.executeWork(MuleWorkManager.java:250)
at org.mule.work.MuleWorkManager.scheduleWork(MuleWorkManager.java:208)
at org.mule.transport.PollingReceiverWorkerSchedule.run(PollingReceiverWorkerSchedule.java:35)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Caused by: org.mule.api.store.ObjectStoreException: Deleting ...\mule-enterprise-standalone-3.2.2\.mule\myapp\queuestore\work\0-768b784b-ab3a-11e1-a48f-ff62aff02664.msg failed
at org.mule.util.store.QueuePersistenceObjectStore.deleteStoreFile(QueuePersistenceObjectStore.java:310)
at org.mule.util.store.QueuePersistenceObjectStore.doRemove(QueuePersistenceObjectStore.java:295)
at org.mule.util.store.AbstractObjectStore.remove(AbstractObjectStore.java:91)
at org.mule.util.queue.TransactionalQueueManager.doRemove(TransactionalQueueManager.java:191)
at org.mule.util.queue.QueueTransactionContext.doCommit(QueueTransactionContext.java:193)
... 30 more
提到的文件确实仍然存在。