Properly handle interruption while destroying MessageBusVisitorSession
@@ -1166,7 +1166,8 @@ public class MessageBusVisitorSession implements VisitorSession {
}
}
} catch (InterruptedException e) {
- e.printStackTrace();
+ log.log(Level.WARNING, "Interrupted waiting for visitor session to be destroyed");
+ Thread.currentThread().interrupt();
} finally {
try {
sender.destroy();
