}
} catch (InterruptedException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
- Thread.currentThread().interrupt();
+ //Thread.currentThread().interrupt();
} catch (IOException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
}