diff --git a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgAttributesNode.java b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgAttributesNode.java
index f0f5d2418f..5da3df68ae 100644
--- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgAttributesNode.java
+++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgAttributesNode.java
@@ -66,7 +66,7 @@ public class TbMsgAttributesNode implements TbNode {
         if (StringUtils.isEmpty(msg.getMetaData().getValue(SCOPE))) {
             msg.getMetaData().putValue(SCOPE, config.getScope());
         }
-        ctx.getTelemetryService().saveAndNotify(ctx.getTenantId(), msg.getOriginator(), config.getScope(),
+        ctx.getTelemetryService().saveAndNotify(ctx.getTenantId(), msg.getOriginator(), msg.getMetaData().getValue(SCOPE),
                 new ArrayList<>(attributes), new TelemetryNodeCallback(ctx, msg));
     }