} catch (InterruptedException x) {
log.warn("After size>0, pending msg take() threw InterruptedException. Ignoring. (" + x.getMessage() + ")",
x);
- Thread.currentThread().interrupt();
+ //Thread.currentThread().interrupt();
}
Callable<Boolean> run = new Callable<Boolean>() {