class Protobuf::Rpc::Connectors::Zmq

def close_connection
  return if @error
  zmq_error_check(@socket.close)
  zmq_error_check(@zmq_context.terminate)
  log_debug { sign_message("Connector closed")  }
end