Commit 910d90b9e5da52a9881c284f0e31b7309fbe4855
Committed by
Andrew Shvayka
Andrew Shvayka
1 parent
daac250c
Fixed incorrect fetch of scope config in push to edge node
Showing
1 changed file
with
2 additions
and
2 deletions
| @@ -171,13 +171,13 @@ public class TbMsgPushToEdgeNode implements TbNode { | @@ -171,13 +171,13 @@ public class TbMsgPushToEdgeNode implements TbNode { | ||
| 171 | case ATTRIBUTES_UPDATED: | 171 | case ATTRIBUTES_UPDATED: |
| 172 | case POST_ATTRIBUTES: | 172 | case POST_ATTRIBUTES: |
| 173 | entityBody.put("kv", dataJson); | 173 | entityBody.put("kv", dataJson); |
| 174 | - entityBody.put(SCOPE, config.getScope()); | 174 | + entityBody.put(SCOPE, getScope(metadata)); |
| 175 | break; | 175 | break; |
| 176 | case ATTRIBUTES_DELETED: | 176 | case ATTRIBUTES_DELETED: |
| 177 | List<String> keys = JacksonUtil.convertValue(dataJson.get("attributes"), new TypeReference<>() { | 177 | List<String> keys = JacksonUtil.convertValue(dataJson.get("attributes"), new TypeReference<>() { |
| 178 | }); | 178 | }); |
| 179 | entityBody.put("keys", keys); | 179 | entityBody.put("keys", keys); |
| 180 | - entityBody.put(SCOPE, config.getScope()); | 180 | + entityBody.put(SCOPE, getScope(metadata)); |
| 181 | break; | 181 | break; |
| 182 | case TIMESERIES_UPDATED: | 182 | case TIMESERIES_UPDATED: |
| 183 | entityBody.put("data", dataJson); | 183 | entityBody.put("data", dataJson); |