add.size() + " added, " + delete.size() +
currentAdd.size() + " added, " + currentDelete.size() +
    public void run() {        while (Thread.currentThread() == runner) {            if (prepareReplication()) {                for (int i = 0; i < urls.size(); i++) {                    try {                        String url = (String) urls.elementAt(i);                        IReplicationListener listener = (IReplicationListener) Naming.lookup(url);                        listener.replicateCache(currentAdd, currentDelete);                        if (nmgr.logReplication) {                            nmgr.app.logEvent("Sent cache replication event: " +                                              add.size() + " added, " + delete.size() +                                              " deleted");                        }                    } catch (Exception x) {                        nmgr.app.logEvent("Error sending cache replication event: " + x);                    }                }            }            try {                if (runner != null) {                    runner.sleep(1000L);                }            } catch (InterruptedException ir) {                runner = null;            }        }    }