public void subscriptionChanged(Subscription s)
public synchronized void subscriptionChanged(Subscription s)
      public void subscriptionChanged(Subscription s)      {        synchronized(localLock)        {          Enumeration changedList =            ((IncrementalSubscription)s).getChangedList();          if (changedList.hasMoreElements())          {            changedQra = (QueryResultAdapter)changedList.nextElement();            if (allClustersResponded(changedQra)) {              //System.out.println("All clusters checked in");              localLock.notify();            } else {              //System.out.println("Still waiting for some clusters");            }          }        }      }