From f2ea1b87d76328b9bd2b46656f504fe8db75de27 Mon Sep 17 00:00:00 2001
From: dashevchenko <dshevchenko@thingsboard.io>
Date: Wed, 27 Dec 2023 14:51:20 +0200
Subject: [PATCH] added shutdown for producerExecutor

---
 .../java/org/thingsboard/server/queue/sqs/TbAwsSqsAdmin.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/sqs/TbAwsSqsAdmin.java b/common/queue/src/main/java/org/thingsboard/server/queue/sqs/TbAwsSqsAdmin.java
index 337bb271e5..7ef3b26b27 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/sqs/TbAwsSqsAdmin.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/sqs/TbAwsSqsAdmin.java
@@ -115,5 +115,8 @@ public class TbAwsSqsAdmin implements TbQueueAdmin {
         if (sqsClient != null) {
             sqsClient.shutdown();
         }
+        if (producerExecutor != null) {
+            producerExecutor.shutdownNow();
+        }
     }
 }