Browse Source
Merge pull request #4219 from volodymyr-babak/fix-error-msg
Fixed msg in case unexpected originator type
pull/4224/head
Igor Kulikov
6 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with
4 additions and
4 deletions
-
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesAlarmOriginatorIdAsyncLoader.java
-
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesCustomerIdAsyncLoader.java
-
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesFieldsAsyncLoader.java
-
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/util/EntitiesTenantIdAsyncLoader.java
|
|
|
@ -32,7 +32,7 @@ public class EntitiesAlarmOriginatorIdAsyncLoader { |
|
|
|
case ALARM: |
|
|
|
return getAlarmOriginatorAsync(ctx.getAlarmService().findAlarmByIdAsync(ctx.getTenantId(), (AlarmId) original)); |
|
|
|
default: |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType())); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -42,7 +42,7 @@ public class EntitiesCustomerIdAsyncLoader { |
|
|
|
case DEVICE: |
|
|
|
return getCustomerAsync(ctx.getDeviceService().findDeviceByIdAsync(ctx.getTenantId(), (DeviceId) original)); |
|
|
|
default: |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType())); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -63,7 +63,7 @@ public class EntitiesFieldsAsyncLoader { |
|
|
|
return getAsync(ctx.getEntityViewService().findEntityViewByIdAsync(ctx.getTenantId(), (EntityViewId) original), |
|
|
|
EntityFieldsData::new); |
|
|
|
default: |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType())); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -50,7 +50,7 @@ public class EntitiesTenantIdAsyncLoader { |
|
|
|
case RULE_CHAIN: |
|
|
|
return getTenantAsync(ctx.getRuleChainService().findRuleChainByIdAsync(ctx.getTenantId(), (RuleChainId) original)); |
|
|
|
default: |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original)); |
|
|
|
return Futures.immediateFailedFuture(new TbNodeException("Unexpected original EntityType " + original.getEntityType())); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|