public interface JSONSupport
Modifier and Type | Method and Description |
---|---|
void |
aggregateAndProcess(Message msg,
String aggregatePath,
String aggregatedSequence,
boolean ignoreErrors) |
void |
convertJSONToStream(Message m,
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,
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) |
<T> T |
convertToTypedJSON(Message m,
Class<? extends T> clazz)
Convert the current message into a Typed JSON Object
|
Map<String,Object> |
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,
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(InputStream is)
Creates a new Jackson based JSON message from the given input stream
|
void |
enrichPayload(Message msg,
String key,
Object value) |
void |
enrichPayloadAtPath(Message msg,
String path,
String key,
Object value) |
<T> T |
extractUsingJSONPath(Message msg,
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
|
<T> T |
extractUsingJSONPath(String jsonString,
String exprn)
Evaluate the given JSONPath expression against the JSON payload, and return result.
|
void |
processBasicJSONDataServiceRequest(Message msg,
String dataSvcBeanName,
String dataSourceName)
Process request message as a basic JSON data service request.
|
void |
splitAndProcess(Message msg,
String splitPath,
String sequenceName,
boolean ignoreErrors,
SplitGroupingCriteria criteria,
long aggregationTimeout,
boolean parallel) |
void |
splitAndProcess(Message msg,
String splitPath,
String sequenceName,
boolean ignoreErrors,
SplitGroupingCriteria criteria,
long aggregationTimeout,
boolean parallel,
ScheduledExecutorService threadPool) |
void convertSOAPToJSONStream(Message m)
m
- the message to be convertedvoid convertXMLToJSONStream(Message m, 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, 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, Object o)
m
- current message to hold final streamo
- untyped object to convert to JSONMap<String,Object> convertToUntypedJSON(Message m)
m
- the current message to be transformedJSONMessage convertToJSONMessage(Message m)
<T> T convertToTypedJSON(Message m, Class<? extends T> clazz)
m
- the current message to be transformedclazz
- the class of the return messagevoid processBasicJSONDataServiceRequest(Message msg, String dataSvcBeanName, String dataSourceName) throws Exception
msg
- the request messagedataSvcBeanName
- the name of the bean defining the JSON data servicedataSourceName
- the name of the data source beanException
- on an errorvoid splitAndProcess(Message msg, String splitPath, String sequenceName, boolean ignoreErrors, SplitGroupingCriteria criteria, long aggregationTimeout, boolean parallel) throws Exception
Exception
void splitAndProcess(Message msg, String splitPath, String sequenceName, boolean ignoreErrors, SplitGroupingCriteria criteria, long aggregationTimeout, boolean parallel, ScheduledExecutorService threadPool) throws Exception
Exception
void aggregateAndProcess(Message msg, String aggregatePath, String aggregatedSequence, boolean ignoreErrors)
<T> T extractUsingJSONPath(String jsonString, String exprn)
jsonString
- string containing an JSON payloadexprn
- the JSONPath expression to evaluate against the message payload<T> T extractUsingJSONPath(Message msg, String exprn)
msg
- the current messageexprn
- the JSONPath expression to evaluate against the message payloadJSONMessage createJacksonMessage(InputStream is)
is
- the input stream to be used for creating the Jackson based JSON messageCopyright © 2010–2016 AdroitLogic. All rights reserved.