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