lib/backburner/connection.rb in backburner-allq-1.0.38 vs lib/backburner/connection.rb in backburner-allq-1.0.39

@@ -21,10 +21,14 @@
       @allq_wrapper = nil
       @on_reconnect = on_reconnect
       connect!
     end
 
+    def clear(tube)
+      @allq_wrapper.clear(tube)
+    end
+
     # Close the connection, if it exists
     def close
       @allq_wrapper.close if @allq_wrapper
       @allq_wrapper = nil
     end
@@ -108,9 +112,14 @@
         delay: opt[:delay].to_i,
         ttr: ttr
       }
 
       options[:shard_key] = opt[:shard_key] if opt[:shard_key]
+      options[:parent_id] = opt[:parent_id] if opt[:parent_id]
+      options[:timeout] = opt[:timeout] if opt[:timeout]
+      options[:run_on_timeout] = opt[:run_on_timeout] if opt[:run_on_timeout]
+      options[:limit] = opt[:limit] if opt[:limit]
+      options[:is_parent] = opt[:is_parent] if opt[:is_parent]
 
       # Overwrite originals
       opt.merge!(options)
       @allq_wrapper.put(data, options)
     end