随着Torquebox的时间流逝,消费者的数量不会减少

Question

我有一个在扭矩盒上的rails应用程序.我正在使用处理器来完成一些后台工作.我已经为这个处理器分配了4名工人.

queues:
  /queue/company:

messaging:
  /queue/company:
    CompanyWorker:
      concurrency: 4

该CompanyWorker是做给其他一些网站的电话.它可能引发异常,但我已经被工人本身抓住了.但是当我注意到我的日志时,我看到了没有.线程/工作人员随着时间的推移而减少.10-15小时后,只有一个线程/处理器工作.如何阻止这种情况发生并使所有4个工作人员/处理器保持活着状态.

几个小时后我才看到

22:29:40,945 INFO  [stdout] (Thread-124 (HornetQ-client-global-threads-1460048766))

只有线程124完成其工作,

几个小时后,我需要重新启动服务器以使所有4个处理器正常工作

Answer 1

确保所有处理器都已完成，即不会无限期挂起。还要确保你抓住了 Throwable，这样抛出的东西就不会逃脱。