DaemonKit::AMQP

# File lib/daemon_kit/amqp.rb, line 13
def instance
  @instance ||= new
end

# File lib/daemon_kit/amqp.rb, line 24
def initialize( config = {} )
  @config = DaemonKit::Config.load('amqp').to_h( true )
end

# File lib/daemon_kit/amqp.rb, line 19
def run(&block)
  instance.run(&block)
end

# File lib/daemon_kit/amqp.rb, line 28
def run(&block)
  # Ensure graceful shutdown of the connection to the broker
  DaemonKit.trap('INT') { ::AMQP.stop { ::EM.stop } }
  DaemonKit.trap('TERM') { ::AMQP.stop { ::EM.stop } }

  # Start our event loop and AMQP client
  DaemonKit.logger.debug("AMQP.start(#{@config.inspect})")
  ::AMQP.start(@config, &block)
end