From f009c8522e64b47df904b13f4093249e2abe6b4f Mon Sep 17 00:00:00 2001 From: ShvaykaD Date: Mon, 1 Apr 2019 14:25:59 +0300 Subject: [PATCH] fix typo --- .../engine/action/TbSaveToCustomCassandraTableNode.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbSaveToCustomCassandraTableNode.java b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbSaveToCustomCassandraTableNode.java index ddacfc5f15..7bcf710492 100644 --- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbSaveToCustomCassandraTableNode.java +++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbSaveToCustomCassandraTableNode.java @@ -205,7 +205,9 @@ public class TbSaveToCustomCassandraTableNode implements TbNode { BoundStatement stmt = saveStmt.bind(); AtomicInteger i = new AtomicInteger(0); fieldsMap.forEach((key, value) -> { - if (dataAsObject.has(key)) { + if (key.equals(ENTITY_ID)) { + stmt.setUUID(i.get(), msg.getOriginator().getId()); + } else if (dataAsObject.has(key)) { if (dataAsObject.get(key).isJsonPrimitive()) { JsonPrimitive primitive = dataAsObject.get(key).getAsJsonPrimitive(); if (primitive.isNumber()) { @@ -220,8 +222,6 @@ public class TbSaveToCustomCassandraTableNode implements TbNode { } else { throw new IllegalStateException("Message data key: '" + key + "' with value: '" + value + "' is not a JSON Primitive!"); } - } else if (key.equals(ENTITY_ID)) { - stmt.setUUID(i.get(), msg.getOriginator().getId()); } else { throw new RuntimeException("Message data doesn't contain key: " + "'" + key + "'!"); }