class Protobuf::Rpc::Zmq::Server

def start_worker
  @workers << Thread.new(self, @broker) do |server, broker|
    begin
      ::Protobuf::Rpc::Zmq::Worker.new(server, broker).run
    rescue => e
      message = "Worker failed: #{e.inspect}\n #{e.backtrace.join($INPUT_RECORD_SEPARATOR)}"
      $stderr.puts(message)
      logger.error { message }
    end
  end
end