Module: AMQP::Client

Defined in:
lib/mqrpc/agent.rb

Instance Method Summary collapse

Instance Method Details

#original_reconnect ⇒ Object 



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

alias :original_reconnect :reconnect

#reconnect(*args) ⇒ Object 



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

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

  # some rate limiting
  sleep(5)

  original_reconnect(*args)
end