public interface JSONSupport
Modifier and Type | Method and Description |
---|---|
void |
aggregateAndProcess(Message msg,
java.lang.String aggregatePath,
java.lang.String aggregatedSequence,
boolean ignoreErrors) |
void |
convertJSONToStream(Message m,
java.lang.Object o)
Convert an untyped Object (e.g.
|
void |
convertSOAPToJSONStream(Message m)
Convert the current SOAP message payload (which maybe available as any format such as raw file or DOM etc)
into a file based JSON stream
|
void |
convertSOAPToJSONStream(Message m,
javax.xml.namespace.QName staringElement,
boolean retainNSPrefixes)
Convert the current SOAP message payload (which maybe available as any format such as raw file or DOM etc)
into a file based JSON stream
|
JSONMessage |
convertToJSONMessage(Message m) |
java.lang.Object |
convertToTypedJSON(Message m,
java.lang.Class clazz)
Convert the current message into a Typed JSON Object
|
java.util.Map |
convertToUntypedJSON(Message m)
Convert the current message into an untyped JSON MapMessage
|
void |
convertXMLToJSONStream(Message m)
Convert the current XML message payload (which maybe available as any format such as raw file or DOM etc)
into a file based JSON stream
|
void |
convertXMLToJSONStream(Message m,
javax.xml.namespace.QName staringElement,
boolean retainNSPrefixes)
Convert the current XML message payload (which maybe available as any format such as raw file or DOM etc)
into a file based JSON stream
|
JSONMessage |
createJacksonMessage(java.io.InputStream is)
Creates a new Jackson based JSON message from the given input stream
|
void |
enrichPayload(Message msg,
java.lang.String key,
java.lang.Object value) |
void |
enrichPayloadAtPath(Message msg,
java.lang.String path,
java.lang.String key,
java.lang.Object value) |
java.lang.Object |
extractUsingJSONPath(Message msg,
java.lang.String exprn)
Evaluate the given JSONPath expression against the JSON payload, and return result
This method converts the current payload into a JSONMessage
Find more on JsonPath expressions @see json-path
|
java.lang.Object |
extractUsingJSONPath(java.lang.String jsonString,
java.lang.String exprn)
Evaluate the given JSONPath expression against the JSON payload, and return result.
|
void |
processBasicJSONDataServiceRequest(Message msg,
java.lang.String dataSvcBeanName,
java.lang.String dataSourceName)
Process request message as a basic JSON data service request.
|
void |
splitAndProcess(Message msg,
java.lang.String splitPath,
java.lang.String sequenceName,
boolean ignoreErrors,
SplitGroupingCriteria criteria,
long aggregationTimeout,
boolean parallel) |
void |
splitAndProcess(Message msg,
java.lang.String splitPath,
java.lang.String sequenceName,
boolean ignoreErrors,
SplitGroupingCriteria criteria,
long aggregationTimeout,
boolean parallel,
java.util.concurrent.ScheduledExecutorService threadPool) |
void convertSOAPToJSONStream(Message m)
m
- the message to be convertedvoid convertXMLToJSONStream(Message m, javax.xml.namespace.QName staringElement, boolean retainNSPrefixes)
m
- the message to be convertedstaringElement
- an optional starting element to begin conversion (e.g. first element of the SOAP body)retainNSPrefixes
- retain the namespace prefixes into JSON names for elementsvoid convertXMLToJSONStream(Message m)
m
- the message to be convertedvoid convertSOAPToJSONStream(Message m, javax.xml.namespace.QName staringElement, boolean retainNSPrefixes)
m
- the message to be convertedstaringElement
- an optional starting element to begin conversion (e.g. first element of the SOAP body)retainNSPrefixes
- retain the namespace prefixes into JSON names for elementsvoid convertJSONToStream(Message m, java.lang.Object o)
m
- current message to hold final streamo
- untyped object to convert to JSONjava.util.Map convertToUntypedJSON(Message m)
m
- the current message to be transformedJSONMessage convertToJSONMessage(Message m)
java.lang.Object convertToTypedJSON(Message m, java.lang.Class clazz)
m
- the current message to be transformedclazz
- the class of the return messagevoid processBasicJSONDataServiceRequest(Message msg, java.lang.String dataSvcBeanName, java.lang.String dataSourceName) throws java.lang.Exception
msg
- the request messagedataSvcBeanName
- the name of the bean defining the JSON data servicedataSourceName
- the name of the data source beanjava.lang.Exception
- on an errorvoid splitAndProcess(Message msg, java.lang.String splitPath, java.lang.String sequenceName, boolean ignoreErrors, SplitGroupingCriteria criteria, long aggregationTimeout, boolean parallel) throws java.lang.Exception
java.lang.Exception
void splitAndProcess(Message msg, java.lang.String splitPath, java.lang.String sequenceName, boolean ignoreErrors, SplitGroupingCriteria criteria, long aggregationTimeout, boolean parallel, java.util.concurrent.ScheduledExecutorService threadPool) throws java.lang.Exception
java.lang.Exception
void aggregateAndProcess(Message msg, java.lang.String aggregatePath, java.lang.String aggregatedSequence, boolean ignoreErrors)
void enrichPayload(Message msg, java.lang.String key, java.lang.Object value)
void enrichPayloadAtPath(Message msg, java.lang.String path, java.lang.String key, java.lang.Object value)
java.lang.Object extractUsingJSONPath(java.lang.String jsonString, java.lang.String exprn)
jsonString
- string containing an JSON payloadexprn
- the JSONPath expression to evaluate against the message payloadjava.lang.Object extractUsingJSONPath(Message msg, java.lang.String exprn)
msg
- the current messageexprn
- the JSONPath expression to evaluate against the message payloadJSONMessage createJacksonMessage(java.io.InputStream is)
is
- the input stream to be used for creating the Jackson based JSON message