module LaGear::Worker::SneakersClassMethods

Public Instance Methods

app_name() click to toggle source
# File lib/la_gear/worker.rb, line 29
def app_name
  ::Sneakers::CONFIG.fetch(:app_name, 'sneakers').underscore
end
default_queue_args() click to toggle source
# File lib/la_gear/worker.rb, line 57
def default_queue_args
  { 'x-dead-letter-exchange' => "#{::Sneakers::CONFIG.fetch(:exchange, 'sneakers').underscore}.retry" }
end
default_queue_name() click to toggle source
# File lib/la_gear/worker.rb, line 33
def default_queue_name
  @default_queue_name ||= "#{app_name}.#{routing_key}"
end
default_queue_opts() click to toggle source
# File lib/la_gear/worker.rb, line 37
def default_queue_opts
  {
    routing_key: [*routing_key, retry_routing_key],
    queue_options: {
      arguments: default_queue_args
    }.merge(::Sneakers::CONFIG.fetch(:global_queue_options, {})),
    handler_opts: {
      routing_key: retry_routing_key
    }
  }
end
retry_routing_key() click to toggle source
# File lib/la_gear/worker.rb, line 53
def retry_routing_key
  "#{default_queue_name}.retry"
end
routing_key() click to toggle source
# File lib/la_gear/worker.rb, line 49
def routing_key
  @routing_key ||= name.underscore.tr('/', '.')
end
subscribes_to(routing_key) click to toggle source
# File lib/la_gear/worker.rb, line 61
def subscribes_to(routing_key)
  @routing_key = routing_key
  @default_queue_name = "#{app_name}.#{name.underscore.tr('/', '.')}"
  from_queue(default_queue_name, default_queue_opts) unless Worker.sidekiq_proc?
end