module Asynk::Consumer::ClassMethods

Attributes

queue_options[R]
routing_keys[R]
subscribe_arguments[R]

Public Instance Methods

action_name_from_routing_key(routing_key) click to toggle source
# File lib/asynk/consumer.rb, line 90
def action_name_from_routing_key(routing_key)
  splitted = routing_key.split('.')
  raise 'There now action in routing_key' if splitted.empty? || splitted.count < 2
  splitted.last.to_sym
end
concurrency() click to toggle source
# File lib/asynk/consumer.rb, line 86
def concurrency
  @concurrency || Asynk.config[:default_consumer_concurrency]
end
queue_name() click to toggle source
# File lib/asynk/consumer.rb, line 70
def queue_name
  return @queue_name unless @queue_name.nil?
  app_name = Rails.application.class.parent_name.dup.underscore if defined?(Rails)
  queue_name = ActiveSupport::Inflector.underscore(self.name.gsub(/::/, '.'))
  queue_name = [app_name, queue_name].join('.') if app_name
  queue_name
end
route_ending_as_action?() click to toggle source
# File lib/asynk/consumer.rb, line 58
def route_ending_as_action?
  @route_ending_as_action || false
end
set_concurrency(size) click to toggle source
# File lib/asynk/consumer.rb, line 82
def set_concurrency(size)
  @concurrency = size
end
set_consume(*routing_keys) click to toggle source
# File lib/asynk/consumer.rb, line 50
def set_consume(*routing_keys)
  @routing_keys = routing_keys
end
set_queue_name(options = {}) click to toggle source
# File lib/asynk/consumer.rb, line 62
def set_queue_name(options = {})
  @queue_name = name
end
set_queue_options(options = {}) click to toggle source
# File lib/asynk/consumer.rb, line 66
def set_queue_options(options = {})
  @queue_options = options
end
set_route_ending_as_action(value) click to toggle source
# File lib/asynk/consumer.rb, line 54
def set_route_ending_as_action(value)
  @route_ending_as_action = value
end
set_subscribe_arguments(arguments = {}) click to toggle source
# File lib/asynk/consumer.rb, line 78
def set_subscribe_arguments(arguments = {})
  @subscribe_arguments = arguments
end