if (log.isDebugEnabled()) log.debug("RemotePlugin:("+me+") Nmessages= "+messageSub.getCollection().size());
if (log != null && log.isDebugEnabled()) log.debug("RemotePlugin:("+me+") Nmessages= "+messageSub.getCollection().size());
  public void execute () {    if (log.isDebugEnabled()) log.debug("RemotePlugin:("+me+") Nmessages= "+messageSub.getCollection().size());    // process new messages    for(Enumeration e = messageSub.getAddedList(); e.hasMoreElements();)    {      receiveMessage((AggRelay)e.nextElement());    }    // process removed sessions    for(Enumeration e = messageSub.getRemovedList(); e.hasMoreElements();)    {      cancelSession((AggRelay)e.nextElement());    }    // process changed subscriptions    synchronized (lock)    {      Iterator iter = queryMap.keySet().iterator();      while (iter.hasNext()) {        IncrementalSubscription sub = (IncrementalSubscription) iter.next();        if (sub.hasChanged())          ((BBSession) queryMap.get(sub)).subscriptionChanged();      }    }  }