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