def out_receiver_thread
        Thread.start {
          log_info { "start out receiver thread" }
          loop do
            begin