class Tackle::Consumer::Queue

Attributes

name[R]

Public Class Methods

new(name, options, connection, logger) click to toggle source
# File lib/tackle/consumer/queue.rb, line 7
def initialize(name, options, connection, logger)
  @name = name
  @connection = connection
  @logger = logger
  @options = options

  @amqp_queue = create_amqp_queue
end

Public Instance Methods

create_amqp_queue() click to toggle source
# File lib/tackle/consumer/queue.rb, line 16
def create_amqp_queue
  @logger.info("Creating queue '#{@name}'")
  @connection.channel.queue(@name, @options)
rescue Exception => ex
  @logger.error "Failed to create queue '#{ex}'"
  raise ex
end