lib/ruote/worker.rb in ruote-2.1.7 vs lib/ruote/worker.rb in ruote-2.1.8

@@ -199,21 +199,21 @@
 
     def trigger (schedule)
 
       msg = Ruote.fulldup(schedule['msg'])
 
-      return false unless @storage.reserve(schedule)
+      return false unless @storage.delete(schedule).nil?
 
       @storage.put_msg(msg.delete('action'), msg)
 
       true
     end
 
     def process (msg)
 
       return false if cannot_handle(msg)
 
-      return false unless @storage.reserve(msg)
+      return false unless @storage.delete(msg).nil?
 
       begin
 
         action = msg['action']