protected long copyCollection(CollectionId collectionId,long timestamp) throws InterruptedException {
  AtomicLong docCount=new AtomicLong();
  primaryClient.executeBlocking("sync '" + collectionId + "'",null);
  return docCount.get();
}

protected long copyCollection ( CollectionId collectionId , long timestamp ) throws InterruptedException { AtomicLong docCount = new AtomicLong ( ) ; primaryClient . executeBlocking ( "sync '" + collectionId + "'" , null ) ; return docCount . get ( ) ; }
copy the collection , sending to the recorder a record for each document .
