Browse Source
Merge pull request #5892 from Nikitozin/feature/add_feature_to_save_json_to_cassandra
[3.3.3] Add feature to save json to custom Cassandra table
pull/5579/head
Andrew Shvayka
5 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
3 additions and
1 deletions
-
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbSaveToCustomCassandraTableNode.java
|
|
|
@ -195,8 +195,10 @@ public class TbSaveToCustomCassandraTableNode implements TbNode { |
|
|
|
} else { |
|
|
|
stmtBuilder.setToNull(i.get()); |
|
|
|
} |
|
|
|
} else if (dataKeyElement.isJsonObject()) { |
|
|
|
stmtBuilder.setString(i.get(), dataKeyElement.getAsJsonObject().toString()); |
|
|
|
} else { |
|
|
|
throw new IllegalStateException("Message data key: '" + key + "' with value: '" + value + "' is not a JSON Primitive!"); |
|
|
|
throw new IllegalStateException("Message data key: '" + key + "' with value: '" + value + "' is not a JSON Object or JSON Primitive!"); |
|
|
|
} |
|
|
|
} else { |
|
|
|
throw new RuntimeException("Message data doesn't contain key: " + "'" + key + "'!"); |
|
|
|
|