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