diff --git a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/edge/TbMsgPushToEdgeNode.java b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/edge/TbMsgPushToEdgeNode.java
index 97b0c1c8a0..7b96bb45f6 100644
--- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/edge/TbMsgPushToEdgeNode.java
+++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/edge/TbMsgPushToEdgeNode.java
@@ -80,7 +80,7 @@ public class TbMsgPushToEdgeNode implements TbNode {
                 ListenableFuture<EdgeId> getEdgeIdFuture = getEdgeIdByOriginatorId(ctx, ctx.getTenantId(), msg.getOriginator());
                 Futures.addCallback(getEdgeIdFuture, new FutureCallback<EdgeId>() {
                     @Override
-                    public void onSuccess(@org.checkerframework.checker.nullness.qual.Nullable EdgeId edgeId) {
+                    public void onSuccess(@Nullable EdgeId edgeId) {
                         EdgeEventType edgeEventTypeByEntityType = ctx.getEdgeEventService().getEdgeEventTypeByEntityType(msg.getOriginator().getEntityType());
                         if (edgeEventTypeByEntityType == null) {
                             log.debug("Edge event type is null. Entity Type {}", msg.getOriginator().getEntityType());
@@ -97,16 +97,19 @@ public class TbMsgPushToEdgeNode implements TbNode {
                             @Override
                             public void onSuccess(@Nullable EdgeEvent event) {
                                 ctx.tellNext(msg, SUCCESS);
-                            }                            @Override
+                            }
+                            @Override
                             public void onFailure(Throwable th) {
                                 log.error("Could not save edge event", th);
                                 ctx.tellFailure(msg, th);
                             }
                         }, ctx.getDbCallbackExecutor());
-                    }                    @Override
+                    }
+                    @Override
                     public void onFailure(Throwable t) {
                         ctx.tellFailure(msg, t);
                     }
+
                 }, ctx.getDbCallbackExecutor());
             } else {
                 log.debug("Unsupported msg type {}", msg.getType());