From dc77ccdb9cc4af1162f6a46b24e267c2bd5e79a7 Mon Sep 17 00:00:00 2001 From: Andrei Cheboksarov <37665782+0xaa4eb@users.noreply.github.com> Date: Wed, 3 Jan 2024 16:34:35 +0400 Subject: [PATCH] shutdown now in closing data writer --- ulyp-agent/lombok.config | 4 ++-- .../com/ulyp/storage/writer/AsyncFileRecordingDataWriter.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ulyp-agent/lombok.config b/ulyp-agent/lombok.config index cf350fc5..6aa51d71 100644 --- a/ulyp-agent/lombok.config +++ b/ulyp-agent/lombok.config @@ -1,2 +1,2 @@ -# This file is generated by the 'io.freefair.lombok' Gradle plugin -config.stopBubbling = true +# This file is generated by the 'io.freefair.lombok' Gradle plugin +config.stopBubbling = true diff --git a/ulyp-storage/src/main/java/com/ulyp/storage/writer/AsyncFileRecordingDataWriter.java b/ulyp-storage/src/main/java/com/ulyp/storage/writer/AsyncFileRecordingDataWriter.java index 05c603e5..89030615 100644 --- a/ulyp-storage/src/main/java/com/ulyp/storage/writer/AsyncFileRecordingDataWriter.java +++ b/ulyp-storage/src/main/java/com/ulyp/storage/writer/AsyncFileRecordingDataWriter.java @@ -74,7 +74,7 @@ private void writeAsync(Runnable runnable) { @SneakyThrows public synchronized void close() { try { - executorService.shutdown(); + executorService.shutdownNow(); executorService.awaitTermination(30, TimeUnit.SECONDS); } finally { delegate.close();