Method: Beetle::Client#reset

Defined in:
lib/beetle/client.rb

#reset ⇒ Object 



320
321
322
323
324
325
326
327
328
329
330
331
 
# File 'lib/beetle/client.rb', line 320

def reset
  stop_publishing
  stop_listening
  config.reload
  load_brokers_from_config
rescue Exception => e
  logger.warn("Error resetting client")
  logger.warn(e)
ensure
  @publisher = nil
  @subscriber = nil
end