added shutdown for producerExecutor

2 years ago · f2ea1b87d7
1 changed files with 3 additions and 0 deletions
--- 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();
+        }
    }
 }