2017-10-26 6 views
0

ich eine benutzerdefinierten Job-Klasse habe:verzögert Job nicht nach durchgeführter Warteschlange eingereiht

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 

Wenn ich auf Schienen Konsole ausführen:

RemoteServiceNotifierJob.enqueue id, 'ServiceRequest', 'update' 

Der verzögerte Job eingeführt wird, und dann sofort rechts nach gelöscht.

Ich habe verzögert Job Config auf:

Delayed::Worker.destroy_failed_jobs = false 

Aber die verzögerte Job wird nie ausgeführt.

+0

aus irgendeinem Grund, nachdem ich redeploy, alles funktioniert perfekt. – user3286371

Antwort

0

aus irgendeinem Grund, nachdem ich redeploy, alles funktioniert perfekt.

Verwandte Themen