私はenqueue
仕事にResqueを使用しています。
ワーカーを開始すると、ジョブが処理されます。
before_enqueue
私のジョブは、after_enqueue
、before_perform
、などのジョブ フックを実装する gem を拡張し、after_perform
データを statsd に送信します。それらは機能します。しかし、before_dequeue
とafter_dequeue
呼ばれていないようです。理由はありますか?
また、Resque についての私の理解はすべてではありません。を呼び出しResque.enqueue
てジョブ クラスをキューに入れ、Resque ワーカーを開始すると、自動的にキューからタスクがポップされ、次にタスクがポップされperform
ます。どこでdequeue
出番ですか?Resqueワーカー ワークフローでステップdequeue
が発生するのはいつですか?dequeue
after_dequeue
タスクがキューに留まっている時間を記録したいのでフックしたいので、 before_enqueue
and にフックする必要がありafter_dequeue
ます。