Fix invalid json error given for a nested Json message

See wso2/streaming-integrator#228 for more details.
siddhi-io · Apr 23, 2021 · 8bc53c2 · 8bc53c2
1 parent de77cce
commit 8bc53c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/TemplateBuilder.java b/modules/siddhi-core/src/main/java/io/siddhi/core/util/transport/TemplateBuilder.java
@@ -39,7 +39,7 @@
 public class TemplateBuilder {
 
     private static final Pattern DYNAMIC_PATTERN = Pattern.compile("(\\{\\{[^{}]*\\}\\})|[{}]");
-    private static final String SPLIT_PATTERN = "(\\{\\{|\\}\\})";
+    private static final String SPLIT_PATTERN = "(\\{.\\{|\\}.\\})";
     private int[] positionArray;
     private String[] splitTemplateArray;
     private boolean isObjectMessage = false;
@@ -113,7 +113,7 @@ private String parseTextMessage(StreamDefinition streamDefinition, String templa
             if (m.group(1) != null) {
                 int attrIndex = attributes.indexOf(m.group(1).replaceAll("\\p{Ps}", "").replaceAll("\\p{Pe}", ""));
                 if (attrIndex >= 0) {
-                    m.appendReplacement(result, String.format("{{%s}}", attrIndex));
+                    m.appendReplacement(result, String.format("{.{%s}.}", attrIndex));
                 } else {
                     throw new NoSuchAttributeException(String.format("Attribute : %s does not exist in %s.",
                             m.group(1), streamDefinition));