We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 99cbfb6 commit a003d5dCopy full SHA for a003d5d
src/main/java/com/rabbitmq/perf/MulticastSet.java
@@ -242,7 +242,9 @@ public void run(boolean announceStartup)
242
this.threadingHandler.scheduledExecutorService(
243
"perf-test-heartbeat-sender-", this.params.getHeartbeatSenderThreads());
244
factory.setHeartbeatExecutor(heartbeatSenderExecutorService);
245
- shutdownService.wrap(heartbeatSenderExecutorService::shutdownNow);
+ if (heartbeatSenderExecutorService != null) {
246
+ shutdownService.wrap(heartbeatSenderExecutorService::shutdownNow);
247
+ }
248
}
249
250
// use a single-threaded executor for the configuration connection
0 commit comments