[direct-io-pubsub] set executor to null after close() in PubSubWriter

je-ik · je-ik · commit d4f16db969db · 2025-11-05T12:56:29.000+01:00
diff --git a/direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/AbstractPubSubWriter.java b/direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/AbstractPubSubWriter.java
@@ -142,6 +142,7 @@ public synchronized void close() {
         }
         executor.shutdown();
         executor.awaitTermination(10, TimeUnit.SECONDS);
+        executor = null;
         publisher.shutdown();
       } catch (Exception ex) {
         log.warn("Failed to shutdown publisher {}", publisher, ex);

Original file line number	Diff line number	Diff line change
`@@ -142,6 +142,7 @@ public synchronized void close() {`
`142`	`142`	`}`
`143`	`143`	`executor.shutdown();`
`144`	`144`	`executor.awaitTermination(10, TimeUnit.SECONDS);`
	`145`	`+ executor = null;`
`145`	`146`	`publisher.shutdown();`
`146`	`147`	`} catch (Exception ex) {`
`147`	`148`	`log.warn("Failed to shutdown publisher {}", publisher, ex);`