class Tochtli::ReplyQueue::Consumer

Public Class Methods

new(reply_queue, *args) click to toggle source
Calls superclass method
# File lib/tochtli/reply_queue.rb, line 113
def initialize(reply_queue, *args)
  super(*args)
  @reply_queue = reply_queue
end

Public Instance Methods

recover_from_network_failure() click to toggle source
Calls superclass method
# File lib/tochtli/reply_queue.rb, line 118
def recover_from_network_failure
  super
  @reply_queue.reconnect(@channel)
rescue Exception
  logger = channel.connection.logger
  logger.error $!
  logger.error $!.backtrace.join("\n")
  raise
end