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