Minor changes like i18n and functionality for stopping one replica

This commit is contained in:
Simon Pamies committed 2013-06-20 23:14:37 +02:00
1 parent 290602288d
commit b994b71236
8 files changed
+26 -4

No files matched your search

@@ -165,7 +165,6 @@ public class ReplicationServiceImpl implements ReplicationService, OperationExec
masterChannel = null;
}
}
logger.info("Unregistered replica " + replica.getIpAddress().toString());
}
}
@@ -125,10 +125,11 @@ public class Replicator implements Runnable {
try {
logger.info("Channel seems to be closed. Trying to reconnect consumer queue...");
this.consumer = master.getConsumer();
logger.info("OK - channel reconnected!");
Thread.sleep(CHECK_INTERVAL_MILLIS);
checksPerformed += 1;
} catch (IOException eio) {
eio.printStackTrace();
// do not print exceptions known to occur
}
}
} catch (InterruptedException eir) {