lib/active_beaneater/worker.rb in active_beaneater-0.1.0 vs lib/active_beaneater/worker.rb in active_beaneater-0.1.1

- old
+ new

@@ -3,10 +3,10 @@ def self.work(only: nil, exclude: []) client = Rails.application.config.beaneater.client - tube_names = [] + tube_names = [ActiveBeaneater.resolve_queue_name('mailers')] ObjectSpace.each_object(Class) do |k| if k.ancestors.include?(ActiveJob::Base) tube_names << ActiveBeaneater.resolve_queue_name(k.queue_name) end