diff --git a/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/profile/TbDeviceProfileNodeTest.java b/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/profile/TbDeviceProfileNodeTest.java
index c3bbc8bcf6..b2c79102c4 100644
--- a/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/profile/TbDeviceProfileNodeTest.java
+++ b/rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/profile/TbDeviceProfileNodeTest.java
@@ -196,7 +196,7 @@ public class TbDeviceProfileNodeTest {
                 TbMsgDataType.JSON, mapper.writeValueAsString(data), null, null);
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
 
         TbMsg theMsg2 = TbMsg.newMsg("ALARM", deviceId, new TbMsgMetaData(), "2");
@@ -207,7 +207,7 @@ public class TbDeviceProfileNodeTest {
                 TbMsgDataType.JSON, mapper.writeValueAsString(data), null, null);
         node.onMsg(ctx, msg2);
         verify(ctx).tellSuccess(msg2);
-        verify(ctx).tellNext(theMsg2, "Alarm Updated");
+        verify(ctx).enqueueForTellNext(theMsg2, "Alarm Updated");
 
     }
 
@@ -289,7 +289,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -376,7 +376,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -445,7 +445,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -554,7 +554,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg2);
         verify(ctx).tellSuccess(msg2);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -678,7 +678,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg2);
         verify(ctx).tellSuccess(msg2);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -781,7 +781,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg2);
         verify(ctx).tellSuccess(msg2);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -897,7 +897,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg2);
         verify(ctx).tellSuccess(msg2);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -999,7 +999,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg2);
         verify(ctx).tellSuccess(msg2);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -1082,7 +1082,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -1163,7 +1163,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -1237,7 +1237,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }
 
@@ -1321,7 +1321,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
 
     }
@@ -1407,7 +1407,7 @@ public class TbDeviceProfileNodeTest {
 
         node.onMsg(ctx, msg);
         verify(ctx).tellSuccess(msg);
-        verify(ctx).tellNext(theMsg, "Alarm Created");
+        verify(ctx).enqueueForTellNext(theMsg, "Alarm Created");
         verify(ctx, Mockito.never()).tellFailure(Mockito.any(), Mockito.any());
     }