fix(sqs inbound): fix NPE when deactivate (#712)

camunda · Jun 8, 2023 · 6bf618e · 6bf618e
1 parent 71cd24d
commit 6bf618e
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/connectors/sqs/src/main/java/io/camunda/connector/inbound/SqsExecutable.java b/connectors/sqs/src/main/java/io/camunda/connector/inbound/SqsExecutable.java
@@ -55,12 +55,10 @@ public void activate(final InboundConnectorContext context) {
             properties.getAuthentication().getSecretKey(),
             properties.getQueue().getRegion());
     LOGGER.debug("SQS client created successfully");
-
-    executorService.execute(
-        sqsQueueConsumer == null
-            ? new SqsQueueConsumer(amazonSQS, properties, context)
-            : sqsQueueConsumer);
-
+    if (sqsQueueConsumer == null) {
+      sqsQueueConsumer = new SqsQueueConsumer(amazonSQS, properties, context);
+    }
+    executorService.execute(sqsQueueConsumer);
     LOGGER.debug("SQS queue consumer started successfully");
   }