Clean shutdown hook in performance test

The hook for the shutdown service. It is now removed once
the shutdown service has run.

Author: acogoluegnes

src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java

@@ -560,6 +560,8 @@ public Integer call() throws Exception {
     this.messageSize = this.messageSize < 8 ? 8 : this.messageSize; // we need to store a long in it
 
     ShutdownService shutdownService = new ShutdownService();
+    Thread shutdownServiceShutdownHook = new Thread(() -> shutdownService.close());
+    Runtime.getRuntime().addShutdownHook(shutdownServiceShutdownHook);
 
     try {
 
@@ -570,8 +572,6 @@ public Integer call() throws Exception {
 
       shutdownService.wrap(closeStep("Closing monitoring context", monitoringContext::close));
 
-      Runtime.getRuntime().addShutdownHook(new Thread(() -> shutdownService.close()));
-
       // FIXME add confirm latency
 
       ScheduledExecutorService envExecutor =
@@ -958,6 +958,7 @@ public Integer call() throws Exception {
       }
     } finally {
       shutdownService.close();
+      Runtime.getRuntime().removeShutdownHook(shutdownServiceShutdownHook);
     }
 
     return 0;