Log interrupted exception at info level

acogoluegnes · acogoluegnes · commit e5b9874e2532 · 2021-09-07T10:58:22.000+02:00
References #27
diff --git a/src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java b/src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java
@@ -671,7 +671,11 @@ public Integer call() throws Exception {
                                 confirmationHandler);
                           }
                         } catch (Exception e) {
-                          LOGGER.warn("Publisher #{} crashed", i, e);
+                          if (e instanceof InterruptedException) {
+                            LOGGER.info("Publisher #{} thread interrupted", i, e);
+                          } else {
+                            LOGGER.warn("Publisher #{} crashed", i, e);
+                          }
                         }
                       };
                 })

Original file line number	Diff line number	Diff line change
`@@ -671,7 +671,11 @@ public Integer call() throws Exception {`
`671`	`671`	`confirmationHandler);`
`672`	`672`	`}`
`673`	`673`	`} catch (Exception e) {`
`674`		`- LOGGER.warn("Publisher #{} crashed", i, e);`
	`674`	`+ if (e instanceof InterruptedException) {`
	`675`	`+ LOGGER.info("Publisher #{} thread interrupted", i, e);`
	`676`	`+ } else {`
	`677`	`+ LOGGER.warn("Publisher #{} crashed", i, e);`
	`678`	`+ }`
`675`	`679`	`}`
`676`	`680`	`};`
`677`	`681`	`})`