From 68225b438c047e4b7a1bb15740c42258ebef3f01 Mon Sep 17 00:00:00 2001
From: Sergey Matvienko <smatvienko@thingsboard.io>
Date: Thu, 16 May 2024 18:27:28 +0200
Subject: [PATCH] TbQueueConsumerTask access the lazy consumer only by getter

---
 .../server/service/queue/ruleengine/TbQueueConsumerTask.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java b/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
index a25f74a5b1..e696192a43 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
@@ -63,12 +63,12 @@ public class TbQueueConsumerTask {
 
     public void subscribe(Set<TopicPartitionInfo> partitions) {
         log.trace("[{}] Subscribing to partitions: {}", key, partitions);
-        consumer.subscribe(partitions);
+        getConsumer().subscribe(partitions);
     }
 
     public void initiateStop() {
         log.debug("[{}] Initiating stop", key);
-        consumer.stop();
+        getConsumer().stop();
     }
 
     public void awaitCompletion() {