diff --git a/.gitignore b/.gitignore
index 96689a4935..ec32ace4b0 100644
--- a/.gitignore
+++ b/.gitignore
@@ -15,4 +15,5 @@
 target/
 
 ## various other file types we don't want to have in the repository:
-.DS_Store
\ No newline at end of file
+.DS_Store
+/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/gen/
diff --git a/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionLexer.g4 b/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionLexer.g4
index 072f463914..1fd3f8b3e7 100644
--- a/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionLexer.g4
+++ b/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionLexer.g4
@@ -7,7 +7,7 @@ VAR: 'var';
 PAYLOAD: 'payload' | '$';
 HEADERS: 'headers';
 CONFIG: 'config';
-ATTRIBUTES: 'attributes';
+ATTRIBUTES: 'attributes' | 'attr';
 AXIS2: 'axis2';
 SYNAPSE: 'synapse';
 REGISTRY: 'registry';
@@ -28,6 +28,8 @@ INTEGER: 'integer';
 FLOAT: 'float';
 STRING: 'string';
 BOOLEAN: 'boolean';
+OBJECT: 'object';
+ARRAY: 'array';
 ABS: 'abs';
 FLOOR: 'floor';
 CEIL: 'ceil';
@@ -41,6 +43,7 @@ SUBSTRING: 'subString';
 STARTSWITH: 'startsWith';
 ENDSWITH: 'endsWith';
 CONTAINS: 'contains';
+EXISTS: 'exists';
 TRIM: 'trim';
 REPLACE: 'replace';
 SPLIT: 'split';
@@ -104,8 +107,8 @@ NULL_LITERAL
     ;
 
 // Identifiers
-ID: [a-zA-Z_][a-zA-Z_0-9]*;
 GETPROPERTY: 'getProperty';
+ID: [a-zA-Z_][a-zA-Z_0-9]*;
 // Special symbols for JSONPath filter expressions
 QUESTION: '?';
 AT: '@';
diff --git a/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionParser.g4 b/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionParser.g4
index 5f72f75261..72ce8693f5 100644
--- a/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionParser.g4
+++ b/modules/core/src/main/antlr4/org/apache/synapse/util/synapse_path/ExpressionParser.g4
@@ -100,6 +100,15 @@ payloadAccess
     | DOUBLE_DOT ID (LBRACKET arrayIndex RBRACKET)? )
     ;
 
+registryAccess
+    : (DOUBLE_DOT ASTERISK
+          | DOUBLE_DOT ID
+          | DOT ID
+          | LBRACKET arrayIndex RBRACKET
+          | DOT LBRACKET arrayIndex RBRACKET
+          | DOT ASTERISK)*
+    ;
+
 arrayIndex
     : NUMBER
     | STRING_LITERAL
@@ -161,7 +170,7 @@ functionCall
     | SQRT LPAREN expression RPAREN
     | LOG LPAREN expression RPAREN
     | POW LPAREN expression COMMA expression RPAREN
-    | REGISTRY LPAREN expression RPAREN (DOT GETPROPERTY LPAREN expression RPAREN)?
+    | REGISTRY LPAREN expression RPAREN ( (DOT GETPROPERTY LPAREN expression RPAREN) | registryAccess )?
     | SECRET LPAREN expression RPAREN
     | BASE64ENCODE LPAREN expression (COMMA expression)? RPAREN
     | BASE64DECODE LPAREN expression RPAREN
@@ -179,4 +188,7 @@ functionCall
     | FLOAT LPAREN expression RPAREN
     | STRING LPAREN expression RPAREN
     | BOOLEAN LPAREN expression RPAREN
+    | EXISTS LPAREN expression RPAREN
+    | OBJECT LPAREN expression RPAREN
+    | ARRAY LPAREN expression RPAREN
     ;
diff --git a/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java b/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
index e4e987f8ef..38ddb7d615 100644
--- a/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
+++ b/modules/core/src/main/java/org/apache/synapse/SynapseConstants.java
@@ -655,6 +655,10 @@ public enum ENDPOINT_TIMEOUT_TYPE { ENDPOINT_TIMEOUT, GLOBAL_TIMEOUT, HTTP_CONNE
     public static final String  IS_STRING = "isString";
     public static final String  IS_ARRAY = "isArray";
     public static final String  IS_OBJECT = "isObject";
+    public static final String  OBJECT = "object";
+    public static final String  ARRAY = "array";
+    public static final String  REGISTRY = "registry";
+    public static final String  EXISTS = "exists";
 
     public static final String  ROUND = "round";
     public static final String  INTEGER = "integer";
@@ -669,16 +673,4 @@ public enum ENDPOINT_TIMEOUT_TYPE { ENDPOINT_TIMEOUT, GLOBAL_TIMEOUT, HTTP_CONNE
     public static final String  AXIS2 = "axis2";
 
     public static final String  UNKNOWN = "unknown";
-
-    public static final class SIELErrors {
-        public static final String IF_CONDITION_ERROR = "Condition is not a boolean value";
-        private static final String INVALID_ARGUMENT = "Invalid argument type provided for %s function";
-        private static final String INVALID_OPERATION = "Invalid argument type provided for %s operation";
-        public static String getInvalidArgumentMessage(String functionName) {
-            return String.format(INVALID_ARGUMENT, functionName);
-        }
-        public static String getInvalidOperationMessage(String functionName) {
-            return String.format(INVALID_OPERATION, functionName);
-        }
-    }
 }
diff --git a/modules/core/src/main/java/org/apache/synapse/config/xml/PropertyMediatorFactory.java b/modules/core/src/main/java/org/apache/synapse/config/xml/PropertyMediatorFactory.java
index abea2741ae..952c8abfde 100644
--- a/modules/core/src/main/java/org/apache/synapse/config/xml/PropertyMediatorFactory.java
+++ b/modules/core/src/main/java/org/apache/synapse/config/xml/PropertyMediatorFactory.java
@@ -28,7 +28,7 @@
 import org.apache.synapse.mediators.builtin.PropertyMediator;
 import org.apache.synapse.util.MediatorPropertyUtils;
 import org.apache.synapse.util.xpath.SynapseJsonPath;
-import org.apache.synapse.util.xpath.SynapsePath;
+import org.apache.synapse.util.xpath.Synapse_Path;
 import org.apache.synapse.util.xpath.SynapseXPath;
 import org.jaxen.JaxenException;
 
@@ -87,7 +87,7 @@ public Mediator createSpecificMediator(OMElement elem, Properties properties) {
                     new SynapseJsonPath(nameExpression.substring(10, nameExpression.length() - 1));
                 } else if (nameExpression.startsWith(SynapseConstants.SIEL_IDENTIFIER_START) &&
                         nameExpression.endsWith(SynapseConstants.SIEL_IDENTIFIER_END)) {
-                    new SynapsePath(nameExpression.substring(2, nameExpression.length() - 1));
+                    new Synapse_Path(nameExpression.substring(2, nameExpression.length() - 1));
                 } else {
                     new SynapseXPath(nameExpression);
                 }
diff --git a/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePath.java b/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePath.java
index 77b2c1a650..c66d4eb27f 100644
--- a/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePath.java
+++ b/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePath.java
@@ -106,6 +106,13 @@ public String toString() {
 
 	public abstract String stringValueOf(MessageContext synCtx);
 
+	/**
+	 * New method to get the object value of the expression in places where we can handle the Object result.
+	 * @param synCtx MessageContext
+	 * @return Object - can be String, Integer, Double, Boolean, OMNode, JSONElement or null.
+	 */
+	public abstract Object objectValueOf(MessageContext synCtx);
+
 	public void handleException(String msg, Throwable e) {
 		log.error(msg, e);
 		throw new SynapseException(msg, e);
diff --git a/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePathFactory.java b/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePathFactory.java
index 8303492bf9..eccdf91bf1 100644
--- a/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePathFactory.java
+++ b/modules/core/src/main/java/org/apache/synapse/config/xml/SynapsePathFactory.java
@@ -27,7 +27,7 @@
 import org.apache.synapse.SynapseException;
 import org.apache.synapse.config.SynapsePropertiesLoader;
 import org.apache.synapse.util.xpath.SynapseJsonPath;
-import org.apache.synapse.util.xpath.SynapsePath;
+import org.apache.synapse.util.xpath.Synapse_Path;
 import org.apache.synapse.util.xpath.SynapseXPath;
 import org.jaxen.JaxenException;
 
@@ -52,7 +52,7 @@ public static org.apache.synapse.config.xml.SynapsePath getSynapsePath(OMElement
                 path = new SynapseJsonPath(pathAttrib.getAttributeValue().substring(10, pathAttrib.getAttributeValue().length() - 1));
             } else if (pathAttrib.getAttributeValue().startsWith(SynapseConstants.SIEL_IDENTIFIER_START) &&
                     pathAttrib.getAttributeValue().endsWith(SynapseConstants.SIEL_IDENTIFIER_END)) {
-                path = new SynapsePath(pathAttrib.getAttributeValue().substring(2, pathAttrib.getAttributeValue().length() - 1));
+                path = new Synapse_Path(pathAttrib.getAttributeValue().substring(2, pathAttrib.getAttributeValue().length() - 1));
             } else {
                 try {
                     path = new SynapseXPath(pathAttrib.getAttributeValue());
diff --git a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/ExpressionResult.java b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/ExpressionResult.java
index 2957dadd16..7b55156f56 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/ExpressionResult.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/ExpressionResult.java
@@ -18,10 +18,15 @@
 
 package org.apache.synapse.util.synapse_path.ast;
 
+import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonNull;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
 import com.google.gson.JsonPrimitive;
+import com.google.gson.JsonSyntaxException;
 import com.google.gson.internal.LazilyParsedNumber;
+import org.apache.axiom.om.OMElement;
 import org.apache.synapse.util.synapse_path.exception.EvaluationException;
 
 /**
@@ -39,6 +44,14 @@ public ExpressionResult(String value) {
         this.value = value;
     }
 
+    public ExpressionResult(OMElement value) {
+        this.value = value;
+    }
+
+    public Object getValue() {
+        return value;
+    }
+
     public ExpressionResult(Number value) {
         this.value = value;
     }
@@ -119,6 +132,24 @@ public JsonElement asJsonElement() {
         throw new EvaluationException("Value is not a JsonElement");
     }
 
+    public JsonObject asJsonObject() {
+        if (value instanceof JsonObject) {
+            return (JsonObject) value;
+        } else if (value instanceof String) {
+            return parseStringToJsonObject((String) value);
+        }
+        throw new EvaluationException("Value is not a JsonObject");
+    }
+
+    public JsonArray asJsonArray() {
+        if (value instanceof JsonArray) {
+            return (JsonArray) value;
+        } else if (value instanceof String) {
+            return parseStringToJsonArray((String) value);
+        }
+        throw new EvaluationException("Value is not a JsonArray");
+    }
+
     // Method to check the actual type of the result
     public Class<?> getType() {
         if (value == null) {
@@ -148,11 +179,31 @@ public boolean isString() {
     }
 
     public boolean isObject() {
-        return value instanceof JsonElement && ((JsonElement) value).isJsonObject();
+        if (value instanceof JsonElement && ((JsonElement) value).isJsonObject()) {
+            return true;
+        } else if (value instanceof String) {
+            try {
+                parseStringToJsonObject((String) value);
+                return true;
+            } catch (EvaluationException e) {
+                return false;
+            }
+        }
+        return false;
     }
 
     public boolean isArray() {
-        return value instanceof JsonElement && ((JsonElement) value).isJsonArray();
+        if (value instanceof JsonElement && ((JsonElement) value).isJsonArray()) {
+            return true;
+        } else if (value instanceof String) {
+            try {
+                parseStringToJsonArray((String) value);
+                return true;
+            } catch (Exception e) {
+                return false;
+            }
+        }
+        return false;
     }
 
     public boolean isJsonPrimitive() {
@@ -197,4 +248,40 @@ private boolean isDouble(JsonPrimitive jsonPrimitive) {
         }
         return false; // Not a number, so it's not a double
     }
+
+    public boolean isOMElement() {
+        return value instanceof OMElement;
+    }
+
+    private JsonObject parseStringToJsonObject(String value) throws EvaluationException {
+        String stringValue = value;
+        if (stringValue.startsWith("\"") && stringValue.endsWith("\"")) {
+            stringValue = stringValue.substring(1, stringValue.length() - 1);
+        }
+        try {
+            JsonElement jsonElement = JsonParser.parseString(stringValue.replace("\\", ""));
+            if (jsonElement.isJsonObject()) {
+                return jsonElement.getAsJsonObject();
+            }
+        } catch (JsonSyntaxException e) {
+            throw new EvaluationException("Value is not a JsonObject");
+        }
+        throw new EvaluationException("Value is not a JsonObject");
+    }
+
+    private JsonArray parseStringToJsonArray(String value) throws EvaluationException {
+        String stringValue = value;
+        if (stringValue.startsWith("\"") && stringValue.endsWith("\"")) {
+            stringValue = stringValue.substring(1, stringValue.length() - 1);
+        }
+        try {
+            JsonElement jsonElement = JsonParser.parseString(stringValue.replace("\\", ""));
+            if (jsonElement.isJsonArray()) {
+                return jsonElement.getAsJsonArray();
+            }
+        } catch (JsonSyntaxException e) {
+            throw new EvaluationException("Value is not a JsonArray");
+        }
+        throw new EvaluationException("Value is not a JsonArray");
+    }
 }
diff --git a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PayloadAccessNode.java b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PayloadAccessNode.java
index 196f546cb2..8311d2c64d 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PayloadAccessNode.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PayloadAccessNode.java
@@ -53,13 +53,20 @@ public class PayloadAccessNode implements ExpressionNode {
     private static final Log log = LogFactory.getLog(PayloadAccessNode.class);
     private String expression;
     private final Map<String, ExpressionNode> arguments;
+    public enum Type {
+        PAYLOAD,
+        VARIABLE,
+        REGISTRY,
+    }
+    private final Type type;
+    private ExpressionNode registryAccessNode = null;
 
-    private final boolean isVariable;
-
-    public PayloadAccessNode(String expression, Map<String, ExpressionNode> arguments, boolean isVariable) {
+    public PayloadAccessNode(String expression, Map<String, ExpressionNode> arguments, Type type,
+                             ExpressionNode registryAccessNode) {
         this.expression = expression;
         this.arguments = arguments;
-        this.isVariable = isVariable;
+        this.type = type;
+        this.registryAccessNode = registryAccessNode;
         Configuration.setDefaults(new Configuration.Defaults() {
             private final JsonProvider jsonProvider = new GsonJsonProvider(new GsonBuilder().serializeNulls().create());
             private final MappingProvider mappingProvider = new GsonMappingProvider();
@@ -80,7 +87,7 @@ public Set<Option> options() {
 
     @Override
     public ExpressionResult evaluate(EvaluationContext context) {
-        if (expression.startsWith(SynapseConstants.PAYLOAD) && !isVariable) {
+        if (expression.startsWith(SynapseConstants.PAYLOAD)) {
             expression = SynapseConstants.PAYLOAD_$ + expression.substring(SynapseConstants.PAYLOAD.length());
         }
 
@@ -90,8 +97,8 @@ public ExpressionResult evaluate(EvaluationContext context) {
                     .ifPresent(result -> processResult(entry, result));
         }
 
-        Object result;
-        if (!isVariable) {
+        Object result = null;
+        if (type.equals(Type.PAYLOAD)) {
             try {
                 result = context.getPayload();
                 if (result == null) {
@@ -104,7 +111,7 @@ public ExpressionResult evaluate(EvaluationContext context) {
             } catch (IOException e) {
                 throw new EvaluationException("Error while parsing payload");
             }
-        } else {
+        } else if (type.equals(Type.VARIABLE)) {
             String[] variableAndExpression = ExpressionUtils.extractVariableAndJsonPath(expression);
             Object variable = context.getVariable(variableAndExpression[0]);
             if (variable == null) {
@@ -124,6 +131,21 @@ public ExpressionResult evaluate(EvaluationContext context) {
                     throw new EvaluationException(e.getMessage());
                 }
             }
+        } else if (type.equals(Type.REGISTRY)) {
+            ExpressionResult registryValue = registryAccessNode.evaluate(context);
+            try {
+                if (registryValue == null) {
+                    throw new EvaluationException("Could not find a JSON payload to evaluate the expression: " + expression);
+                } else if (!registryValue.isOMElement()) {
+                    throw new EvaluationException("Could not evaluate JSONPath expression: " + expression
+                            + " on non-JSON registry value");
+                }
+                expression = expression.startsWith(".") ? "$" + expression : "$." + expression;
+                result = JsonPath.parse(registryValue.asString()).read(expression);
+            } catch (PathNotFoundException e) {
+                // convert jsonPath error to native one
+                throw new EvaluationException(e.getMessage());
+            }
         }
         if (result instanceof JsonPrimitive) {
             return new ExpressionResult((JsonPrimitive) result);
diff --git a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PredefinedFunctionNode.java b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PredefinedFunctionNode.java
index bf0b08dfa1..5f70ba9cd3 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PredefinedFunctionNode.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/ast/PredefinedFunctionNode.java
@@ -67,8 +67,12 @@ private ExpressionResult handleNoArgumentFunctions() {
     }
 
     private ExpressionResult handleSingleArgumentFunctions(EvaluationContext context) {
-        ExpressionResult result = arguments.get(0).evaluate(context);
-        checkArguments(result, "source");
+        ExpressionResult result = null;
+        // do not evaluate the source for exists function - since we need to catch the exception
+        if (!functionName.equals(SynapseConstants.EXISTS)) {
+            result = arguments.get(0).evaluate(context);
+            checkArguments(result, "source");
+        }
         switch (functionName) {
             case SynapseConstants.LENGTH:
                 return handleLengthFunction(result);
@@ -112,6 +116,14 @@ private ExpressionResult handleSingleArgumentFunctions(EvaluationContext context
                 return handleFloatConversion(result);
             case SynapseConstants.BOOLEAN:
                 return handleBooleanConversion(result);
+            case SynapseConstants.REGISTRY:
+                return handleRegistryAccess(context, result, null);
+            case SynapseConstants.EXISTS:
+                return handleExistsCheck(context, arguments.get(0));
+            case SynapseConstants.OBJECT:
+                return convertToObject(result);
+            case SynapseConstants.ARRAY:
+                return convertToArray(result);
             default:
                 throw new EvaluationException("Invalid function: " + functionName + " with one argument");
         }
@@ -139,6 +151,8 @@ private ExpressionResult handleDoubleArgumentFunctions(EvaluationContext context
                 return handleBase64EncodeFunction(source, argument1);
             case SynapseConstants.URL_ENCODE:
                 return handleUrlEncodeFunction(source, argument1);
+            case SynapseConstants.REGISTRY:
+                return handleRegistryAccess(context, source, argument1);
             default:
                 throw new EvaluationException("Invalid function: " + functionName + " with two arguments");
         }
@@ -424,4 +438,54 @@ private ExpressionResult handleReplaceFunction(ExpressionResult source, Expressi
         throw new EvaluationException("Invalid argument provided for replace function. source: " + source.asString()
                 + ", argument1: " + argument1.asString() + ", argument2: " + argument2.asString());
     }
+
+    private ExpressionResult handleRegistryAccess(EvaluationContext ctx, ExpressionResult regKey,
+                                                  ExpressionResult propKey) {
+        if (regKey.isString()) {
+            if (propKey != null && propKey.isString()) {
+                String prop = ctx.getRegistryResourceProperty(regKey.asString(), propKey.asString());
+                if (prop != null) {
+                    return new ExpressionResult(prop);
+                }
+                throw new EvaluationException("Could not find the property: " + propKey.asString()
+                        + " in the registry resource: " + regKey.asString());
+            } else {
+                Object resource;
+                try {
+                    resource = ctx.getRegistryResource(regKey.asString());
+                } catch (UnsupportedEncodingException e) {
+                    throw new EvaluationException("Error retrieving the registry resource: " + regKey.asString());
+                }
+                if (resource != null) {
+                    return new ExpressionResult(resource.toString());
+                }
+                throw new EvaluationException("Could not find the registry resource: " + regKey.asString());
+            }
+        }
+        throw new EvaluationException("Invalid argument provided for registry function. regKey: " + regKey.asString()
+                + ", propKey: " + propKey.asString());
+    }
+
+    private ExpressionResult handleExistsCheck(EvaluationContext context, ExpressionNode expression) {
+        try {
+            ExpressionResult result = expression.evaluate(context);
+            return result != null ? new ExpressionResult(true) : new ExpressionResult(false);
+        } catch (EvaluationException e) {
+            return new ExpressionResult(false);
+        }
+    }
+
+    private ExpressionResult convertToObject(ExpressionResult result) {
+        if (result.isObject()) {
+            return new ExpressionResult(result.asJsonObject());
+        }
+        throw new EvaluationException("Argument cannot be converted to a JSON object");
+    }
+
+    private ExpressionResult convertToArray(ExpressionResult result) {
+        if (result.isArray()) {
+            return new ExpressionResult(result.asJsonArray());
+        }
+        throw new EvaluationException("Argument cannot be converted to a JSON array");
+    }
 }
diff --git a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/context/EvaluationContext.java b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/context/EvaluationContext.java
index 9bd65f02be..0e512b967c 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/context/EvaluationContext.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/context/EvaluationContext.java
@@ -17,15 +17,24 @@
  */
 package org.apache.synapse.util.synapse_path.context;
 
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMNode;
+import org.apache.axiom.om.OMText;
+import org.apache.axiom.om.impl.llom.OMTextImpl;
 import org.apache.commons.io.IOUtils;
 import org.apache.synapse.MessageContext;
 import org.apache.synapse.SynapseConstants;
 import org.apache.synapse.commons.json.JsonUtil;
 import org.apache.synapse.core.axis2.Axis2MessageContext;
+import org.apache.synapse.registry.Registry;
 
 import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.nio.charset.StandardCharsets;
+import java.util.Base64;
 import java.util.Map;
 import java.util.Objects;
+import java.util.Properties;
 
 
 import static org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS;
@@ -85,5 +94,36 @@ public Object getProperty(String proName, String scope) {
         }
         return null;
     }
-}
 
+    public Object getRegistryResource(String key) throws UnsupportedEncodingException {
+        if (synCtx != null && key != null && !key.isEmpty()) {
+            Registry registry = synCtx.getConfiguration().getRegistry();
+            if (registry != null) {
+                OMNode resource = registry.lookup(key);
+                if (resource != null) {
+                    if (resource instanceof OMText) {
+                        OMTextImpl omText = (OMTextImpl) resource;
+                        byte[] bytes = Base64.getDecoder().decode(omText.getText());
+                        return new String(bytes, StandardCharsets.UTF_8);
+                    } else if (resource instanceof OMElement) {
+                        return resource.toString();
+                    }
+                }
+            }
+        }
+        return null;
+    }
+
+    public String getRegistryResourceProperty(String key, String propName) {
+        if (synCtx != null && key != null && !key.isEmpty() && propName != null && !propName.isEmpty()) {
+            Registry registry = synCtx.getConfiguration().getRegistry();
+            if (registry != null) {
+                Properties properties = registry.getResourceProperties(key);
+                if (properties != null) {
+                    return properties.getProperty(propName);
+                }
+            }
+        }
+        return null;
+    }
+}
diff --git a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/visitor/ExpressionVisitor.java b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/visitor/ExpressionVisitor.java
index 437a174543..1c3bc5df5a 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/synapse_path/visitor/ExpressionVisitor.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/synapse_path/visitor/ExpressionVisitor.java
@@ -196,6 +196,18 @@ public ExpressionNode visitFunctionCall(ExpressionParser.FunctionCallContext ctx
             return new PredefinedFunctionNode(parameterList, SynapseConstants.INTEGER);
         } else if (ctx.ROUND() != null) {
             return new PredefinedFunctionNode(parameterList, SynapseConstants.ROUND);
+        } else if (ctx.REGISTRY() != null) {
+            if (ctx.registryAccess() != null && ctx.registryAccess().getChildCount() > 0) {
+                PredefinedFunctionNode node = new PredefinedFunctionNode(parameterList, SynapseConstants.REGISTRY);
+                return visitRegistryAccess(ctx.registryAccess(), node);
+            }
+            return new PredefinedFunctionNode(parameterList, SynapseConstants.REGISTRY);
+        } else if (ctx.EXISTS() != null) {
+            return new PredefinedFunctionNode(parameterList, SynapseConstants.EXISTS);
+        } else if (ctx.OBJECT() != null) {
+            return new PredefinedFunctionNode(parameterList, SynapseConstants.OBJECT);
+        } else if (ctx.ARRAY() != null) {
+            return new PredefinedFunctionNode(parameterList, SynapseConstants.ARRAY);
         }
         return null;
     }
@@ -236,7 +248,7 @@ public ExpressionNode visitVariableAccess(ExpressionParser.VariableAccessContext
                 expressionNodeMap.put(expressionContext.getText(), visit(expressionContext));
             }
         }
-        return new PayloadAccessNode(ctx.getText(), expressionNodeMap, true);
+        return new PayloadAccessNode(ctx.getText(), expressionNodeMap, PayloadAccessNode.Type.VARIABLE, null);
     }
 
     @Override
@@ -247,7 +259,19 @@ public ExpressionNode visitPayloadAccess(ExpressionParser.PayloadAccessContext c
                 expressionNodeMap.put(expressionContext.getText(), visit(expressionContext));
             }
         }
-        return new PayloadAccessNode(ctx.getText(), expressionNodeMap, false);
+        return new PayloadAccessNode(ctx.getText(), expressionNodeMap, PayloadAccessNode.Type.PAYLOAD, null);
+    }
+
+
+    public ExpressionNode visitRegistryAccess(ExpressionParser.RegistryAccessContext ctx,
+                                              PredefinedFunctionNode functionNode) {
+        Map<String, ExpressionNode> expressionNodeMap = new HashMap<>();
+        if (ctx.arrayIndex() != null) {
+            for (ExpressionParser.ArrayIndexContext expressionContext : ctx.arrayIndex()) {
+                expressionNodeMap.put(expressionContext.getText(), visit(expressionContext));
+            }
+        }
+        return new PayloadAccessNode(ctx.getText(), expressionNodeMap, PayloadAccessNode.Type.REGISTRY, functionNode);
     }
 
     @Override
diff --git a/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseJsonPath.java b/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseJsonPath.java
index 4b016a7555..f54cc80bac 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseJsonPath.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseJsonPath.java
@@ -195,6 +195,11 @@ public String stringValueOf(MessageContext synCtx) {
         return "";
     }
 
+    @Override
+    public Object objectValueOf(MessageContext synCtx) {
+        return null;
+    }
+
     public String stringValueOf(final InputStream jsonStream) {
         if (jsonStream == null) {
             return "";
diff --git a/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseXPath.java b/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseXPath.java
index 829c08476c..f6c50dba4b 100755
--- a/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseXPath.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapseXPath.java
@@ -528,6 +528,11 @@ public String stringValueOf(MessageContext synCtx) {
         return null;
     }
 
+    @Override
+    public Object objectValueOf(MessageContext synCtx) {
+        return null;
+    }
+
     /**
      * Specialized form of xpath evaluation function.An xpath evaluate() will be performed using two contexts
      * (ie:-soap-envelope and on Synapse Message Context). This is useful for evaluating xpath on a
diff --git a/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapsePath.java b/modules/core/src/main/java/org/apache/synapse/util/xpath/Synapse_Path.java
similarity index 82%
rename from modules/core/src/main/java/org/apache/synapse/util/xpath/SynapsePath.java
rename to modules/core/src/main/java/org/apache/synapse/util/xpath/Synapse_Path.java
index 6bde546e36..e5add9ff6f 100644
--- a/modules/core/src/main/java/org/apache/synapse/util/xpath/SynapsePath.java
+++ b/modules/core/src/main/java/org/apache/synapse/util/xpath/Synapse_Path.java
@@ -27,6 +27,7 @@
 import org.apache.synapse.MessageContext;
 
 import org.apache.synapse.SynapseConstants;
+import org.apache.synapse.config.xml.SynapsePath;
 import org.apache.synapse.util.synapse_path.ExpressionLexer;
 import org.apache.synapse.util.synapse_path.ExpressionParser;
 import org.apache.synapse.util.synapse_path.ast.ExpressionNode;
@@ -41,13 +42,13 @@
  * Represents a SIEL path in Synapse.
  * Syntax #[ + expression +  ] ex: expression="#[vars.test + 5]"
  */
-public class SynapsePath extends org.apache.synapse.config.xml.SynapsePath {
-    private static final Log log = LogFactory.getLog(SynapsePath.class);
+public class Synapse_Path extends SynapsePath {
+    private static final Log log = LogFactory.getLog(Synapse_Path.class);
     private final ExpressionNode expressionNode;
     private final EvaluationContext context;
     private final SyntaxErrorListener errorListener;
 
-    public SynapsePath(String SIELExpression) throws JaxenException {
+    public Synapse_Path(String SIELExpression) throws JaxenException {
         super(SIELExpression, org.apache.synapse.config.xml.SynapsePath.JSON_PATH, log);
 
         CharStream input = CharStreams.fromString(expression);
@@ -70,14 +71,26 @@ public SynapsePath(String SIELExpression) throws JaxenException {
     @Override
     public String stringValueOf(MessageContext synCtx) {
         context.setSynCtx(synCtx);
-        ExpressionResult result = null;
+        ExpressionResult result = evaluateExpression(context);
+        return result != null ? result.asString() : "";
+    }
+
+    @Override
+    public Object objectValueOf(MessageContext synCtx) {
+        context.setSynCtx(synCtx);
+        ExpressionResult result = evaluateExpression(context);
+        return result != null ? result.getValue() : null;
+    }
+
+    private ExpressionResult evaluateExpression(EvaluationContext context) {
+        ExpressionResult result;
         try {
             result = expressionNode.evaluate(context);
         } catch (EvaluationException e) {
             log.warn("Error evaluating expression: " + expression + " cause : " + e.getMessage());
             result = new ExpressionResult(SynapseConstants.UNKNOWN);
         }
-        return result != null ? result.asString() : "";
+        return result;
     }
 
     public SyntaxErrorListener getErrorListener() {
diff --git a/modules/core/src/test/java/org/apache/synapse/util/synapse_path/HeaderAndPropertyAccessTest.java b/modules/core/src/test/java/org/apache/synapse/util/synapse_path/HeaderAndPropertyAccessTest.java
index 3c09a17648..616969a3ed 100644
--- a/modules/core/src/test/java/org/apache/synapse/util/synapse_path/HeaderAndPropertyAccessTest.java
+++ b/modules/core/src/test/java/org/apache/synapse/util/synapse_path/HeaderAndPropertyAccessTest.java
@@ -20,7 +20,7 @@
 import org.apache.synapse.commons.json.JsonUtil;
 import org.apache.synapse.core.axis2.Axis2MessageContext;
 import org.apache.synapse.mediators.TestUtils;
-import org.apache.synapse.util.xpath.SynapsePath;
+import org.apache.synapse.util.xpath.Synapse_Path;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
@@ -108,89 +108,89 @@ public void setUp() throws Exception {
 
     @Test
     public void testTransportHeader() throws Exception {
-        SynapsePath testPath = new SynapsePath("headers.test");
+        Synapse_Path testPath = new Synapse_Path("headers.test");
         Assert.assertEquals("Hello World", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testTransportHeaderWithReservedName() throws Exception {
-        SynapsePath testPath = new SynapsePath("toLower(headers.\"toUpper\")");
+        Synapse_Path testPath = new Synapse_Path("toLower(headers.\"toUpper\")");
         Assert.assertEquals("hello world", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testTransportHeaderInFilter() throws Exception {
-        SynapsePath testPath = new SynapsePath("$..book[?(@.price > integer(headers.price))].title");
+        Synapse_Path testPath = new Synapse_Path("$..book[?(@.price > integer(headers.price))].title");
         Assert.assertEquals("[\"The Lord of the Rings\",\"To Kill a Mockingbird\"]", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testTransportHeaderWithSpecialChar() throws Exception {
-        SynapsePath testPath = new SynapsePath("toLower(headers.\"te st\") + \" World\"");
+        Synapse_Path testPath = new Synapse_Path("toLower(headers.\"te st\") + \" World\"");
         Assert.assertEquals("hello World", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testTransportHeaderNotExist() throws Exception {
-        SynapsePath testPath = new SynapsePath("headers.\"toUpper2\"");
+        Synapse_Path testPath = new Synapse_Path("headers.\"toUpper2\"");
         Assert.assertEquals(null, testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testTransportHeaderNumerical() throws Exception {
-        SynapsePath testPath = new SynapsePath("integer(headers.numerical)+ 4");
+        Synapse_Path testPath = new Synapse_Path("integer(headers.numerical)+ 4");
         Assert.assertEquals("404", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testAxis2Header() throws Exception {
-        SynapsePath testPath = new SynapsePath("attributes.axis2.test");
+        Synapse_Path testPath = new Synapse_Path("attr.axis2.test");
         Assert.assertEquals("Sic Mundus", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testAxis2HeaderWithExpression() throws Exception {
-        SynapsePath testPath = new SynapsePath("attributes.axis2.test + \" \" " +
+        Synapse_Path testPath = new Synapse_Path("attributes.axis2.test + \" \" " +
                 "+ attributes.axis2.test2");
         Assert.assertEquals("Sic Mundus Creatus Est", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testAxis2HeaderInFilter() throws Exception {
-        SynapsePath testPath = new SynapsePath("$..book[?(@.category == attributes.axis2.category)].title");
+        Synapse_Path testPath = new Synapse_Path("$..book[?(@.category == attributes.axis2.category)].title");
         Assert.assertEquals("[\"The Diary of a Young Girl\"]", testPath.stringValueOf(synCtx));
     }
     @Test
     public void testAxis2HeaderWithReservedName() throws Exception {
-        SynapsePath testPath = new SynapsePath("attributes.axis2.\"empty\"");
+        Synapse_Path testPath = new Synapse_Path("attributes.axis2.\"empty\"");
         Assert.assertEquals("Thus the world was created", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testSynapseHeader() throws Exception {
-        SynapsePath testPath = new SynapsePath("attributes.synapse.phrase");
+        Synapse_Path testPath = new Synapse_Path("attributes.synapse.phrase");
         Assert.assertEquals("Now I Am Become Death, the Destroyer of Worlds", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testSynapseHeaderWithFunction() throws Exception {
-        SynapsePath testPath = new SynapsePath("length(split(attributes.synapse.phrase, \" \"))");
+        Synapse_Path testPath = new Synapse_Path("length(split(attributes.synapse.phrase, \" \"))");
         Assert.assertEquals("9", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testSynapseHeaderInFilter() throws Exception {
-        SynapsePath testPath = new SynapsePath("$..book[?(@.title == attributes.synapse.\"selected book\")].price");
+        Synapse_Path testPath = new Synapse_Path("$..book[?(@.title == attributes.synapse.\"selected book\")].price");
         Assert.assertEquals("[7.99]", testPath.stringValueOf(synCtx));
     }
 
     @Test
     public void testNonExistingEmptyAndNull() throws Exception {
-        SynapsePath testPath = new SynapsePath("attributes.synapse.nonExisting");
+        Synapse_Path testPath = new Synapse_Path("attributes.synapse.nonExisting");
         Assert.assertEquals(null, testPath.stringValueOf(synCtx));
-        testPath = new SynapsePath("attributes.synapse.\"null\"");
+        testPath = new Synapse_Path("attributes.synapse.\"null\"");
         Assert.assertEquals(null, testPath.stringValueOf(synCtx));
-        testPath = new SynapsePath("attributes.synapse.\"empty\"");
+        testPath = new Synapse_Path("attributes.synapse.\"empty\"");
         Assert.assertEquals("", testPath.stringValueOf(synCtx));
     }
 }
diff --git a/modules/core/src/test/java/org/apache/synapse/util/synapse_path/PreDefinedFunctionsTest.java b/modules/core/src/test/java/org/apache/synapse/util/synapse_path/PreDefinedFunctionsTest.java
index c6565e110c..7d70d8c166 100644
--- a/modules/core/src/test/java/org/apache/synapse/util/synapse_path/PreDefinedFunctionsTest.java
+++ b/modules/core/src/test/java/org/apache/synapse/util/synapse_path/PreDefinedFunctionsTest.java
@@ -282,7 +282,9 @@ public void testIsArray() {
         Assert.assertEquals("true", TestUtils.evaluateExpression("isArray([\"34\"])"));
         Assert.assertEquals("true", TestUtils.evaluateExpressionWithPayloadAndVariables(
                 "isArray(payload)", 3, 1));
-        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("isString(null)"));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("isArray(null)"));
+        Assert.assertEquals("true", TestUtils.evaluateExpression("isArray(\"[1,2,{\\\"abc\\\":5}]\")"));
+        Assert.assertEquals("false", TestUtils.evaluateExpression("isArray(\"[1,2,{\\\"abc:5}]\")"));
     }
 
     @Test
@@ -295,6 +297,8 @@ public void testIsObject() {
         Assert.assertEquals("true", TestUtils.evaluateExpressionWithPayloadAndVariables(
                 "isObject(payload.store)", 2, 1));
         Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("isObject(null)"));
+        Assert.assertEquals("true", TestUtils.evaluateExpression("isObject(\"{\\\"hello\\\": \\\"world\\\"}\")"));
+        Assert.assertEquals("false", TestUtils.evaluateExpression("isObject(\"{\\\"hello: \\\"world\\\"}\")"));
     }
 
     @Test
@@ -350,4 +354,32 @@ public void testRound() {
                 "round(var.num1 + var.num2)", 0, 1));
         Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpressionWithPayload("round(payload)", 3));
     }
+
+    @Test
+    public void testExists() {
+        TestUtils.clearMessageContext();
+        Assert.assertEquals("false", TestUtils.evaluateExpression("exists(var.num1)"));
+        Assert.assertEquals("false", TestUtils.evaluateExpression("exists(null)"));
+        Assert.assertEquals("John", TestUtils.evaluateExpressionWithPayload(
+                "exists($.fullName) ? $.fullName : $.name",1));
+    }
+
+    @Test
+    public void testConvertToObject() {
+        Assert.assertEquals("{\"hello\":\"world\"}", TestUtils.evaluateExpressionWithPayload(
+                "object(\"{\\\"hello\\\":\\\"world\\\"}\")", 2));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("object(34)"));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("object(null)"));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpressionWithPayload("object(payload)", 3));
+    }
+
+    @Test
+    public void testConvertToArray() {
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("registry(\"Hello\").bla"));
+        Assert.assertEquals("[\"Hello\",\"World\"]", TestUtils.evaluateExpression(
+                "array(\"[\\\"Hello\\\",\\\"World\\\"]\")"));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("array(34)"));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpression("array(null)"));
+        Assert.assertEquals(SynapseConstants.UNKNOWN, TestUtils.evaluateExpressionWithPayload("array(payload)", 2));
+    }
 }
diff --git a/modules/core/src/test/java/org/apache/synapse/util/synapse_path/TestUtils.java b/modules/core/src/test/java/org/apache/synapse/util/synapse_path/TestUtils.java
index 4e4f114554..56ebff7e89 100644
--- a/modules/core/src/test/java/org/apache/synapse/util/synapse_path/TestUtils.java
+++ b/modules/core/src/test/java/org/apache/synapse/util/synapse_path/TestUtils.java
@@ -27,7 +27,7 @@
 import org.apache.synapse.core.axis2.Axis2MessageContext;
 import org.apache.synapse.util.synapse_path.exception.SyntaxErrorListener;
 import org.apache.synapse.util.synapse_path.visitor.ExpressionVisitor;
-import org.apache.synapse.util.xpath.SynapsePath;
+import org.apache.synapse.util.xpath.Synapse_Path;
 import org.jaxen.JaxenException;
 
 
@@ -149,7 +149,7 @@ public static String evaluateExpressionWithPayloadAndVariables(String expression
                     synCtx.setProperty(entry.getKey(), entry.getValue());
                 }
             }
-            SynapsePath synapsePath = new SynapsePath(expression);
+            Synapse_Path synapsePath = new Synapse_Path(expression);
             return synapsePath.stringValueOf(synCtx);
         } catch (JaxenException | AxisFault e) {
             throw new RuntimeException(e);