From a570101aeee5d5a999cc45fbe8b68172872af634 Mon Sep 17 00:00:00 2001
From: ViacheslavKlimov <viacheslavklimov11@gmail.com>
Date: Thu, 7 Sep 2023 18:13:14 +0300
Subject: [PATCH] Use DbCallbackExecutor in forwardToEventService

---
 .../server/service/queue/DefaultTbCoreConsumerService.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
index f6623b62a3..fd5a252cc5 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
@@ -667,7 +667,8 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
     private void forwardToEventService(Event event, TbCallback callback) {
         DonAsynchron.withCallback(actorContext.getEventService().saveAsync(event),
                 result -> callback.onSuccess(),
-                callback::onFailure);
+                callback::onFailure,
+                actorContext.getDbCallbackExecutor());
     }
 
     private void throwNotHandled(Object msg, TbCallback callback) {