# File lib/daemon_kit/nanite/agent.rb, line 49
      def run(&block)
        # Ensure graceful shutdown of the connection to the broker
        DaemonKit.trap('INT') { ::EM.stop }
        DaemonKit.trap('TERM') { ::EM.stop }
        ::Nanite::Log.logger = DaemonKit.logger

        # Start our mapper
        mapper_thread = Thread.new do
          EM.run do
            agent = ::Nanite::Agent.new( @config )
            agent.init_block = block
            agent.run
          end
        end

        mapper_thread.join
      end