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