if (log.isDebugEnabled()) log.debug("Pull session created("+me+")");
if (log != null && log.isDebugEnabled()) log.debug("Pull session created("+me+")");
  private void createPullSession (Element root, AggRelay relay)    throws Exception {    String queryId = root.getAttribute("query_id");    String requester = root.getAttribute("requester");    UnaryPredicate seeker = ScriptSpec.makeUnaryPredicate(      XmlUtils.getChildElement(root, "unary_predicate"));    if (seeker == null)      throw new Exception("Could not create unary predicate");    IncrementFormat formatter = ScriptSpec.makeIncrementFormat(      XmlUtils.getChildElement(root, "xml_encoder"));    if (formatter == null)      throw new Exception("Could not create formatter");    new RemotePullSession(      String.valueOf(idCounter++), queryId, formatter, relay, seeker);    if (log.isDebugEnabled()) log.debug("Pull session created("+me+")");  }