We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 83d9e6e commit a268ed1Copy full SHA for a268ed1
src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java
@@ -672,7 +672,9 @@ public Integer call() throws Exception {
672
confirmationHandler);
673
}
674
} catch (Exception e) {
675
- if (e instanceof InterruptedException) {
+ if (e instanceof InterruptedException
676
+ || (e.getCause() != null
677
+ && e.getCause() instanceof InterruptedException)) {
678
LOGGER.info("Publisher #{} thread interrupted", i, e);
679
} else {
680
LOGGER.warn("Publisher #{} crashed", i, e);
0 commit comments