Commit 0fc43c3bd4b1b5623397acc93bbe987e2a06381f
1 parent
7bf0cb90
Add 'Timeseries Updated' into message type switch node
Showing
2 changed files
with
7 additions
and
3 deletions
@@ -35,7 +35,7 @@ import org.thingsboard.server.common.msg.session.SessionMsgType; | @@ -35,7 +35,7 @@ import org.thingsboard.server.common.msg.session.SessionMsgType; | ||
35 | configClazz = EmptyNodeConfiguration.class, | 35 | configClazz = EmptyNodeConfiguration.class, |
36 | relationTypes = {"Post attributes", "Post telemetry", "RPC Request from Device", "RPC Request to Device", "Activity Event", "Inactivity Event", | 36 | relationTypes = {"Post attributes", "Post telemetry", "RPC Request from Device", "RPC Request to Device", "Activity Event", "Inactivity Event", |
37 | "Connect Event", "Disconnect Event", "Entity Created", "Entity Updated", "Entity Deleted", "Entity Assigned", | 37 | "Connect Event", "Disconnect Event", "Entity Created", "Entity Updated", "Entity Deleted", "Entity Assigned", |
38 | - "Entity Unassigned", "Attributes Updated", "Attributes Deleted", "Alarm Acknowledged", "Alarm Cleared", "Other", "Entity Assigned From Tenant", "Entity Assigned To Tenant"}, | 38 | + "Entity Unassigned", "Attributes Updated", "Attributes Deleted", "Alarm Acknowledged", "Alarm Cleared", "Other", "Entity Assigned From Tenant", "Entity Assigned To Tenant", "Timeseries Updated"}, |
39 | nodeDescription = "Route incoming messages by Message Type", | 39 | nodeDescription = "Route incoming messages by Message Type", |
40 | nodeDetails = "Sends messages with message types <b>\"Post attributes\", \"Post telemetry\", \"RPC Request\"</b> etc. via corresponding chain, otherwise <b>Other</b> chain is used.", | 40 | nodeDetails = "Sends messages with message types <b>\"Post attributes\", \"Post telemetry\", \"RPC Request\"</b> etc. via corresponding chain, otherwise <b>Other</b> chain is used.", |
41 | uiResources = {"static/rulenode/rulenode-core-config.js"}, | 41 | uiResources = {"static/rulenode/rulenode-core-config.js"}, |
@@ -90,6 +90,8 @@ public class TbMsgTypeSwitchNode implements TbNode { | @@ -90,6 +90,8 @@ public class TbMsgTypeSwitchNode implements TbNode { | ||
90 | relationType = "Entity Assigned From Tenant"; | 90 | relationType = "Entity Assigned From Tenant"; |
91 | } else if (msg.getType().equals(DataConstants.ENTITY_ASSIGNED_TO_TENANT)) { | 91 | } else if (msg.getType().equals(DataConstants.ENTITY_ASSIGNED_TO_TENANT)) { |
92 | relationType = "Entity Assigned To Tenant"; | 92 | relationType = "Entity Assigned To Tenant"; |
93 | + } else if (msg.getType().equals(DataConstants.TIMESERIES_UPDATED)) { | ||
94 | + relationType = "Timeseries updated"; | ||
93 | } else { | 95 | } else { |
94 | relationType = "Other"; | 96 | relationType = "Other"; |
95 | } | 97 | } |
@@ -348,7 +348,8 @@ export enum MessageType { | @@ -348,7 +348,8 @@ export enum MessageType { | ||
348 | ENTITY_ASSIGNED = 'ENTITY_ASSIGNED', | 348 | ENTITY_ASSIGNED = 'ENTITY_ASSIGNED', |
349 | ENTITY_UNASSIGNED = 'ENTITY_UNASSIGNED', | 349 | ENTITY_UNASSIGNED = 'ENTITY_UNASSIGNED', |
350 | ATTRIBUTES_UPDATED = 'ATTRIBUTES_UPDATED', | 350 | ATTRIBUTES_UPDATED = 'ATTRIBUTES_UPDATED', |
351 | - ATTRIBUTES_DELETED = 'ATTRIBUTES_DELETED' | 351 | + ATTRIBUTES_DELETED = 'ATTRIBUTES_DELETED', |
352 | + TIMESERIES_UPDATED = 'TIMESERIES_UPDATED' | ||
352 | } | 353 | } |
353 | 354 | ||
354 | export const messageTypeNames = new Map<MessageType, string>( | 355 | export const messageTypeNames = new Map<MessageType, string>( |
@@ -367,7 +368,8 @@ export const messageTypeNames = new Map<MessageType, string>( | @@ -367,7 +368,8 @@ export const messageTypeNames = new Map<MessageType, string>( | ||
367 | [MessageType.ENTITY_ASSIGNED, 'Entity Assigned'], | 368 | [MessageType.ENTITY_ASSIGNED, 'Entity Assigned'], |
368 | [MessageType.ENTITY_UNASSIGNED, 'Entity Unassigned'], | 369 | [MessageType.ENTITY_UNASSIGNED, 'Entity Unassigned'], |
369 | [MessageType.ATTRIBUTES_UPDATED, 'Attributes Updated'], | 370 | [MessageType.ATTRIBUTES_UPDATED, 'Attributes Updated'], |
370 | - [MessageType.ATTRIBUTES_DELETED, 'Attributes Deleted'] | 371 | + [MessageType.ATTRIBUTES_DELETED, 'Attributes Deleted'], |
372 | + [MessageType.TIMESERIES_UPDATED, 'Timeseries Updated'] | ||
371 | ] | 373 | ] |
372 | ); | 374 | ); |
373 | 375 |