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