Module: AMQP::Client

Defined in:
lib/mqrpc/agent.rb

Instance Method Summary collapse

Instance Method Details

#original_reconnect ⇒ Object 



15
 
# File 'lib/mqrpc/agent.rb', line 15

alias :original_reconnect :reconnect

#reconnect(*args) ⇒ Object 



16
17
18
19
20
21
22
23
 
# File 'lib/mqrpc/agent.rb', line 16

def reconnect(*args)
  $logger.warn "reconnecting to broker (bad MQ settings?)"

  # some rate limiting
  sleep(5)

  original_reconnect(*args)
end