Removing unneeded check - classloader reset needs to take place at every step

This commit is contained in:
Simon Pamies committed 2013-06-19 16:15:17 +02:00
1 parent d9bb941af0
commit e1d7556e84
1 file changed
+1 -5
@@ -83,7 +83,6 @@ public class Replicator implements Runnable {
ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
while (true) {
boolean noClassLoaderReset = false;
try {
Delivery delivery = consumer.nextDelivery();
byte[] bytesFromMessage = delivery.getBody();
@@ -121,7 +120,6 @@ public class Replicator implements Runnable {
eir.printStackTrace();
}
checksPerformed += 1;
noClassLoaderReset = true;
continue;
} else {
logger.severe("Grace time (" + CHECK_COUNT*(CHECK_INTERVAL/1000) + "secs) is over. Terminating replication listener " + this.toString());
@@ -132,9 +130,7 @@ public class Replicator implements Runnable {
logger.info("Exception while processing replica: "+e.getMessage());
logger.log(Level.SEVERE, "run", e);
} finally {
if (noClassLoaderReset == false) {
Thread.currentThread().setContextClassLoader(oldClassLoader);
}
Thread.currentThread().setContextClassLoader(oldClassLoader);
}
}
}