}
} 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);
}