2013-01-17 1 views
6

トルクボックスにあるレールアプリがあります。私はいくつかのバックグラウンドジョブに対してプロセッサーを使用しています。私はそのプロセッサに4人の労働者を割り当てました。トルクボックスに時間が経つにつれて消費者が減少していない

queues: 
    /queue/company: 

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

CompanyWorkerは他のサイトを呼び出しています。それは例外を発生させるかもしれないが、私は労働者自身の中に入った。しかし、私が私のログに気づいたので、私はそれを見ませんでした。時間が経過するとスレッド/ワーカーの数が減少します。 10-15時間後には、1つのスレッド/プロセッサのみが動作しています。どのようにしてこれをやめて、4人のワーカー/プロセッサーを生き残らせるか。

いくつかの時間後、私は唯一の、唯一の仕事をして124スレッド

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

を見ると、数時間後に私は

答えて

0

ていることを確認します働くすべての4つのプロセッサを取得するには、サーバーを再起動する必要がありますすべてのプロセッサが完了しています。つまり、無期限にハングしません。 Throwableを捕まえていることを確認して、何も投げ込まれないようにしてください。

+0

throwableをキャッチする例を追加できますか –

関連する問題