dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed msg in case unexpected originator type

Browse Source
This commit is contained in:
Volodymyr Babak 2021-03-10 12:01:58 +02:00
parent eec8bb0202
commit ec6e2611cb
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesAlarmOriginatorIdAsyncLoader.java
View File

@ -32,7 +32,7 @@ public class EntitiesAlarmOriginatorIdAsyncLoader {
case ALARM: case ALARM:
return getAlarmOriginatorAsync(ctx.getAlarmService().findAlarmByIdAsync(ctx.getTenantId(), (AlarmId) original)); return getAlarmOriginatorAsync(ctx.getAlarmService().findAlarmByIdAsync(ctx.getTenantId(), (AlarmId) original));
default: default:
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType()));
} }
} }

2
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesCustomerIdAsyncLoader.java
View File

@ -42,7 +42,7 @@ public class EntitiesCustomerIdAsyncLoader {
case DEVICE: case DEVICE:
return getCustomerAsync(ctx.getDeviceService().findDeviceByIdAsync(ctx.getTenantId(), (DeviceId) original)); return getCustomerAsync(ctx.getDeviceService().findDeviceByIdAsync(ctx.getTenantId(), (DeviceId) original));
default: default:
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType()));
} }
} }

2
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesFieldsAsyncLoader.java
View File

@ -63,7 +63,7 @@ public class EntitiesFieldsAsyncLoader {
return getAsync(ctx.getEntityViewService().findEntityViewByIdAsync(ctx.getTenantId(), (EntityViewId) original), return getAsync(ctx.getEntityViewService().findEntityViewByIdAsync(ctx.getTenantId(), (EntityViewId) original),
EntityFieldsData::new); EntityFieldsData::new);
default: default:
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType()));
} }
} }

2
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesTenantIdAsyncLoader.java
View File

@ -50,7 +50,7 @@ public class EntitiesTenantIdAsyncLoader {
case RULE_CHAIN: case RULE_CHAIN:
return getTenantAsync(ctx.getRuleChainService().findRuleChainByIdAsync(ctx.getTenantId(), (RuleChainId) original)); return getTenantAsync(ctx.getRuleChainService().findRuleChainByIdAsync(ctx.getTenantId(), (RuleChainId) original));
default: default:
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType()));
} }
} }