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