Print InterruptedException message

2d18e506 · 许晓东 · 32881d46 · 2d18e506
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java .../java/org/apache/rocketmq/example/benchmark/Producer.java +2 -1

未找到文件。
--- a/example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java
@@ -228,7 +228,8 @@ public class Producer {
                    statsBenchmark.getSendRequestFailedCount().get(), statsBenchmark.getReceiveResponseFailedCount().get());
            }
            producer.shutdown();
-        } catch (InterruptedException ignored) {
+        } catch (InterruptedException e) {
+            log.error("[Exit] Thread Interrupted Exception", e);
        }
    }