diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java
index 7ad22a7a8b..0a82994a42 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java
@@ -198,6 +198,9 @@ public class DefaultTbClusterService implements TbClusterService {
     public void pushNotificationToTransport(String serviceId, ToTransportMsg response, TbQueueCallback callback) {
         if (serviceId == null || serviceId.isEmpty()){
             log.trace("pushNotificationToTransport: skipping message without serviceId [{}], (ToTransportMsg) response [{}]", serviceId, response);
+            if (callback != null) {
+                callback.onSuccess(null); //callback that message already sent, no useful payload expected
+            }
             return;
         }
         TopicPartitionInfo tpi = partitionService.getNotificationsTopic(ServiceType.TB_TRANSPORT, serviceId);