class Tackle::Consumer::DeadQueue
Public Class Methods
new(exchange, connection, logger)
click to toggle source
Calls superclass method
Tackle::Consumer::Queue::new
# File lib/tackle/consumer/dead_queue.rb, line 5 def initialize(exchange, connection, logger) name = "#{exchange.name}.dead" options = { :durable => true } super(name, options, connection, logger) end
Public Instance Methods
publish(message)
click to toggle source
# File lib/tackle/consumer/dead_queue.rb, line 13 def publish(message) message.log_error "Pushing message to '#{name}'" @amqp_queue.publish(message.payload) message.log_error "Message pushed to '#{name}'" rescue StandardError => ex message.log_error "Error while pushing message exception='#{ex}'" raise ex end