class Tackle::Consumer::Params
Attributes
amqp_url[R]
connection[R]
exception_handler[R]
exchange[R]
logger[R]
manual_ack[R]
retry_delay[R]
retry_limit[R]
routing_key[R]
service[R]
Public Class Methods
new(params = {})
click to toggle source
# File lib/tackle/consumer/params.rb, line 16 def initialize(params = {}) # required @amqp_url = params.fetch(:url) @exchange = params.fetch(:exchange) @routing_key = params.fetch(:routing_key) @service = params.fetch(:service) # optional @retry_limit = params[:retry_limit] || 8 @retry_delay = params[:retry_delay] || 30 @logger = params[:logger] || Logger.new(STDOUT) @manual_ack = params.fetch(:manual_ack, false) @exception_handler = params[:exception_handler] @connection = params.fetch(:connection, nil) end
Public Instance Methods
manual_ack?()
click to toggle source
# File lib/tackle/consumer/params.rb, line 34 def manual_ack? @manual_ack == true end