problem:
We need to develop the policy routing flow based on the incoming message What is the way to do the content based routing and condition based routing in OAG.
For example I have two (may be more) types of JSON message response from a service . I want to set the message based on the JSON response from service . What is the way to develop in this in OAG. .
Here is the two JOSN response from service that OAG is calling .
JSOA Type-1
==========================================
{"soapenv:Envelope":{"@xmlns:soapenv":"http://schemas.xmlsoap.org/soap/envelope/","env:Header":{"@xmlns:env":"http://schemas.xmlsoap.org/soap/envelope/","wsse:Security":{"@xmlns:wsse":"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd"}},"env:Body":{"@xmlns:env":"http://schemas.xmlsoap.org/soap/envelope/","mes:createUserAccountResponse":{"@xmlns:mes":"http://celgene.com/security/messages_v2","mes:createUserAccountOutput":{"mes:status":"SUCCESS"}}}}}
JSON Type-2
==========================================
{"soapenv:Envelope": {"@xmlns:soapenv": "http://schemas.xmlsoap.org/soap/envelope/", "env:Header": {"@xmlns:env": "http://schemas.xmlsoap.org/soap/envelope/"}, "env:Body": {"@xmlns:env": "http://schemas.xmlsoap.org/soap/envelope/", "env:Fault": {"@xmlns:xs": "http://www.w3.org/2001/XMLSchema", "@xmlns:xsi": "http://www.w3.org/2001/XMLSchema-instance", "faultcode": "soapenv:Server", "faultstring": null, "detail": {"java:UserAlreadyExistsException": {"@xmlns:java": "http://celgene.com/security/exceptions_v2", "java:message": "UserAlreadyExists" }}}}}
For JSON Msg 1 I want to set the message
==========================================
{"Message": "User Created successfully"}
For JSON Msg 2 I want to set the message
==========================================
{"Message": "UserAlreadyExists"}
SOLUTION:
We can implement this using the Scripting Language filter as follows:
function invoke(msg) {
// get the body as JsonNode
var node = com.vordel.mime.JSONBody.getJSON(msg);
// get the root
var root = node.path("soapenv:Envelope");
// get the value of reference from body
var envBody = root.path("env:Body");
// get the value of reference from Fault
var envFault = envBody.path("env:Fault");
if (envFault .size() != 0)
{
// Follow the line for the message with error
// get the value of reference from detail
var detail = envFault.path("detail");
// get the value of reference from UserAlreadyExistsException
var javaUser = detail.path("java:UserAlreadyExistsException");
// get the value of reference from message
var javaMessage = javaUser.path("java:message");
// get the text value
var message = javaMessage.getTextValue();
// put the data in the result
msg.put("message", "UserAlreadyExists");
return true;
}
// get the value of reference from createUserAccountResponse
var mesCreateUserAccountResponse = envBody.path("mes:createUserAccountResponse");
if (mesCreateUserAccountResponse .size() !=0)
{
// Follow the line for the Success
// get the value of reference from mesCreateUserAccountResponse
var mesCreateUserAccountOutput = mesCreateUserAccountResponse.path("mes:createUserAccountOutput");
// get the value of reference from mesCreateUserAccountOutput
var mesStatus = mesCreateUserAccountOutput.path("mes:status");
// get the text value
var message = mesStatus.getTextValue();
// put the data in the result
msg.put("message", "User Created successfully");
return true;
}
}
