From d66fb8f528253abe1d94d3c9475d2edaf5e25c7a Mon Sep 17 00:00:00 2001
From: Nikitozin <nikitozin91@gmail.com>
Date: Fri, 14 Jan 2022 12:00:45 +0200
Subject: [PATCH] [3.3.3] Add feature to save json to custom Cassandra table

---
 .../rule/engine/action/TbSaveToCustomCassandraTableNode.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 66291f5245..9720897bec 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
@@ -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");
                     }
                 } else {
                     throw new RuntimeException("Message data doesn't contain key: " + "'" + key + "'!");