0
私はカスタム・ジョブ・クラスを持ってエンキュー行われていない:遅れたジョブは後
class RemoteServiceNotifierJob < Struct.new(:object_id, :object_class, :action)
def self.enqueue(object_id, object_class, action)
job = new(object_id, object_class, action)
Delayed::Job.enqueue job, queue: 'remote_service_notifier'
end
def perform
RestClient.post(url, params, content_type: 'application/json') { |response, request, result, &block|
unless response.code == 201
raise RemoteServiceNotifierError
end
}
end
end
私はレールコンソールで実行します。
RemoteServiceNotifierJob.enqueue id, 'ServiceRequest', 'update'
遅れジョブが挿入され、その後、右の後すぐに削除されます。
私はに遅れてジョブ設定を設定している:
Delayed::Worker.destroy_failed_jobs = false
しかし、遅れて仕事に行われることは決してありません。
何かの理由で、私が再配布した後、すべてが完全に動作しています。 – user3286371