if (log.isDebugEnabled()) log.debug("("+me+")Cancelling remote session "+queryId);
if (log != null && log.isDebugEnabled()) log.debug("("+me+")Cancelling remote session "+queryId);
  private void checkRemovedQueries() {    for (Enumeration e = querySub.getRemovedList(); e.hasMoreElements();)    {      QueryResultAdapter qra = (QueryResultAdapter)e.nextElement();      AggregationQuery aq = qra.getQuery();      String queryId = qra.getID();      // ignore removal of transient queries      if (aq.getType() == QueryType.PERSISTENT)      {        if (aq.getUpdateMethod() == UpdateMethod.PULL)        {          // cancel local pull session          qra.getQuery().getPullTimer().cancel();        }        // cancel session on each of the source clusters listed in query        if (log.isDebugEnabled()) log.debug("("+me+")Cancelling remote session "+queryId);        cancelRemoteSession(queryId);      }    }  }