lib/tennis/worker/generic.rb in tennis-jobs-0.2.0 vs lib/tennis/worker/generic.rb in tennis-jobs-0.3.0
- old
+ new
@@ -35,10 +35,10 @@
def _work
@_work ||= ->(_){ ack! }
end
- def execute(message)
+ def send_work(message)
message = _apply_serializer(:dump, message)
if Tennis.config.async
publisher_opts = worker.queue_opts.select do |opt_name, _|
opt_name == :exchange ||
opt_name == :exchange_type