Contents

module Tennis::Worker::Generic::Options
  SNEAKER_QUEUE_OPTIONS = %i(exchange).freeze

  def set_option(symbol, value)
    if symbol == :queue_name
      worker.from_queue(value, worker.queue_opts)
    else
      options[symbol] = value
      if SNEAKER_QUEUE_OPTIONS.include?(symbol)
        worker.queue_opts[symbol] = value
      end
    end
  end

  def options
    @_options ||= {}
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
tennis-jobs-0.3.1	lib/tennis/worker/generic/options.rb