Modifier and Type | Method and Description |
---|---|
SendInfo |
AS2Manager.prepareAS2MessageForSend(Message msg,
Partner partner)
Create an AS2 message using the current Message and its attachments, and sets the destination URL as of the
selected partner.
|
SendInfo |
AS2Manager.prepareAS2MessageForSend(Message msg,
String partnerID)
Create an AS2 message using the current Message and its attachments, and sets the destination URL as of the
selected partner.
|
void |
AS2Manager.prepareAsyncMDNForSend(Message asyncMdn,
ReceiveInfo rcvInfo)
Prepare an asynchronous MDN message to be sent by populating the payload (i.e.
|
void |
PersistenceService.preparedMDNForSend(ReceiveInfo rcvInfo,
Message msg)
Record the preparation of a MDN to be sent back
|
void |
PersistenceService.preparedMessageForSend(SendInfo sndInfo,
Message msg)
Record the preparation of an AS2 message for sending to a partner
|
AsyncMDNInfo |
AS2Manager.processAsyncMDN(Message msg)
Routine to process a new asynchronous MDN received for a message sent out by us, requesting an asynchronous MDN.
|
void |
AS2Manager.processAsyncMDNSendResult(Message msg)
Notify the outcome of the asynchronous MDN send operation
|
ReceiveInfo |
AS2Manager.processIncomingAS2Message(Message msg)
Routine to process a new AS2 message received over HTTP/S.
|
SyncResponseInfo |
AS2Manager.processSyncResponse(Message msg)
Routine to process the synchronous response received for a AS2 send operation (i.e.
|
void |
PersistenceService.receivedAS2Message(ReceiveInfo rcvInfo,
Message msg,
List<AttachmentDetails> attachments)
Persist a received AS2 Message
|
void |
PersistenceService.receivedASyncMDN(AsyncMDNInfo rcvInfo,
Message msg,
List<AttachmentDetails> attachments)
Persist a received asynchronous MDN
|
void |
PersistenceService.receivedSyncMDN(SyncResponseInfo rcvInfo,
Message msg,
List<AttachmentDetails> attachments)
Persist a received synchronous MDN
|
void |
AS2Manager.recordSendFailure(Message msg)
Record an AS2 message send failure - to be used to notify about asynchronous MDN send failures as well as AS2
message send failures
|
Modifier and Type | Method and Description |
---|---|
void |
WSSecurityManager.addDigestUsernameTokenAuthentication(Message msg,
String username,
String password)
Add a WS-Security Username Token authentication element to the request, with a nonce, created and hashed password
|
void |
WSSecurityManager.addDigestUsernameTokenAuthenticationWithTimestamp(Message msg,
String username,
String password)
Add a WS-Security Username Token authentication element and a Timestamp element to the request,
with a nonce, created and hashed password
|
void |
WSSecurityManager.addPlainUsernameTokenAuthenticationWithTimestamp(Message msg,
String username,
String password)
Add a WS-Security Username Token authentication element and a Timestamp elemtn to the request,
with a nonce, created and hashed password
|
void |
WSSecurityManager.addUsernameTokenAuthentication(Message msg,
String username,
String password,
boolean hashed,
boolean addNonceAndCreated,
boolean includeTimestamp)
Add a WS-Security Username Token authentication element to the request
|
void |
WSSecurityManager.addUsernameTokenAuthentication(Message msg,
String username,
String password,
boolean hashed,
boolean addNonceAndCreated,
boolean includeTimestamp,
boolean mustUnderstand)
Add a WS-Security Username Token authentication element to the request
|
void |
WSSecurityManager.removeSecurityHeader(Message msg)
Remove the WS-Security header from a message
|
void |
WSSecurityManager.signMessage(Message msg,
String signAlias,
String signAlgo,
String digestAlgo)
Secure the message with signature
|
void |
WSSecurityManager.timestampAndEncryptMessage(Message msg,
String encryptionAlias)
Secure message with a timestamp and encrypt - using default timestamp TTL of 5 minutes and key size of 256
|
void |
WSSecurityManager.timestampAndEncryptMessage(Message msg,
String encryptionAlias,
long millis,
String algo)
Secure message with a timestamp and encrypt - using specified timestamp TTL
|
void |
WSSecurityManager.timestampAndSignMessage(Message msg,
String signatureAlias)
Secure message with a timestamp and signature - using default timestamp TTL of 5 minutes
|
void |
WSSecurityManager.timestampAndSignMessage(Message msg,
String signatureAlias,
long millis)
Secure message with a timestamp and signature - using specified timestamp TTL
|
void |
WSSecurityManager.timestampMessage(Message msg)
Secure message with a timestamp - using default timestamp TTL of 5 minutes
|
void |
WSSecurityManager.timestampMessage(Message msg,
long millis)
Secure message with a timestamp - using specified timestamp TTL
|
void |
WSSecurityManager.timestampSignAndEncryptMessage(Message msg,
String encryptionAlias,
String signatureAlias)
Secure message with a timestamp, signature and encrypt body - using default timestamp TTL of 5 minutes and keysize of 256
|
void |
WSSecurityManager.timestampSignAndEncryptMessage(Message msg,
String encryptionAlias,
String signatureAlias,
long millis,
String algo)
Secure message with a timestamp, signature and encrypt body - using specified timestamp TTL
|
void |
WSSecurityManager.verifySignedMessage(Message msg,
boolean remove)
Verify that the message is valid using public key certificates
|
void |
WSSecurityManager.verifyTimestampedAndEncryptedMessage(Message msg,
boolean remove)
Verify that the message is timestamped and encrypted
|
void |
WSSecurityManager.verifyTimestampedAndSignedMessage(Message msg,
boolean remove)
Verify that the message is timestamped and signed
|
void |
WSSecurityManager.verifyTimestampedEncryptedAndSignedMessage(Message msg,
boolean remove)
Verify that the message is timestamped, encrypted and signed
|
void |
WSSecurityManager.verifyTimestampedMessage(Message msg,
boolean remove)
Verify that the message is timestamped and the timestamp valid
|
void |
WSSecurityManager.verifyUsernameTokenAuthentication(Message msg)
Verify that the message contains UsernameToken authentication information, and that its valid
|
void |
WSSecurityManager.verifyUsernameTokenAuthentication(Message msg,
boolean remove)
Verify that the message contains UsernameToken authentication information, and that its valid
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.cloneMessage()
Clone the current message with transport headers and without properties or payload.
|
Message |
Message.cloneMessageAsChild()
Creates a clone of the current message as the child of that message - without transport headers or payload.
|
Message |
Message.createDefaultResponseMessage()
Create the default response message to this message
|
Message |
Message.createDefaultResponseMessageAsChild()
Create the default response message to this message and attached it as a child of the current message
|
Message |
Mediation.sendAndReceiveResponse(Message msg,
String endpointName,
Message responseMsg)
Send the message - msg to the given endpoint to and populate the response data to the response message - responseMsg
|
Modifier and Type | Method and Description |
---|---|
MessageFile |
Mediation.acquireTempMessageFile(Message message)
Acquires a
MessageFile from the default file cache, to be used for message processing needs. |
void |
Message.addMessageForRelease(Message m)
Link a Message for GC along with this message
|
void |
Mediation.callTemplate(Message msg,
String templateInstance)
Calls the specified template instance for the given message
|
void |
Mediation.callTemplateAsynchronously(Message msg,
String templateInstance)
Calls the specified template instance asynchronously for the given message
|
void |
Mediation.callTemplates(Message msg,
List<String> templateInstances)
Calls the specified list of template instances for the given message in-order, unless any of the templates drops
the message, in which case the message flow will completely be abandoned
|
void |
Mediation.dropMessage(Message m)
Mark this message as a 'Dropped' message.
|
abstract void |
AbstractJavaSequence.execute(Message msg,
Mediation mediation)
Executes the Java code sequence with the available message
|
void |
JavaCodeSnippetSequence.execute(Message msg,
Mediation mediation)
Executes the Java code snippet sequence with the message
|
<T> T |
Mediation.getSpringBean(String id,
Class<? extends T> clazz,
Message msg)
Get the Spring bean with the given ID from the [Spring] configuration
|
void |
Mediation.invokeSequence(Message msg,
String sequenceName)
Invoke another sequence from within a sequence
|
Future<Boolean> |
Mediation.invokeSequenceAsynchronously(Message msg,
String sequenceName)
Invoke another sequence asynchronously and returns a
Future
object with boolean type
Use caution, especially about async resource clearing, and concurrent execution |
void |
Mediation.invokeSequences(Message msg,
List<String> sequenceIDs)
Invoke a list of named sequences from within a parent sequence.
|
Future<Boolean> |
Mediation.invokeService(Message msg,
String proxyService)
Invokes the specified service with the given message asynchronously, if the specified service responds to this
request message the response will be sent to the outSequence of the calling proxy service
|
Future<Boolean> |
Mediation.invokeService(Message msg,
String proxyService,
boolean propagateTransaction)
Invokes the specified service with the given message asynchronously, optionally propagating the transactional
context currently active; if the specified service responds to this request message the response will be sent
to the outSequence of the calling proxy service
Note: This is an advanced API method, and should be used carefully.
|
String |
Mediation.readFullPayloadAsString(Message m)
Return the complete current message payload as a String
NOTE: Serializing large messages into Strings can have a Memory, Performance and GC impact
|
byte[] |
Mediation.readPayloadAsByteArray(Message m)
Return the current message payload as a byte[] limited to 100K
|
Map |
Mediation.readPayloadAsMap(Message m)
Return the current message payload as a Map where possible
|
String |
Mediation.readPayloadAsString(Message m)
Return the current message payload as a String limited to 8K
|
<T> T |
Mediation.readPayloadAsTypedObject(Message m,
Class<T> type)
Reads the current message payload as a Java Object of the given type
|
Document |
Mediation.readPayloadAsXMLDocument(Message m)
Return the current message payload as a XML Document where possible, else throw an IllegalArgumentException
|
MessageFile |
Mediation.resetPayloadToNewMessageFile(Message message)
Acquires a
MessageFile from the default file cache and set it as the current payload of the given message. |
void |
Mediation.savePayloadToFile(Message m,
String filePath)
Save the current message payload into the specified file
|
Message |
Mediation.sendAndReceiveResponse(Message msg,
String endpointName,
Message responseMsg)
Send the message - msg to the given endpoint to and populate the response data to the response message - responseMsg
|
void |
Mediation.sendResponse(Message msg,
int code)
Trigger off sending the current payload as a synchronous response message for the currently processing message
If the response for the message has already been submitted, any duplicates calls are silently ignored
|
void |
Mediation.sendResponseAndDrop(Message m,
int code)
Trigger off sending the current payload as a synchronous response message for the currently processing message,
and stop processing this message thereafter.
|
void |
Mediation.sendToEndpoint(Message m,
String endpointName)
Send the current message to the endpoint with the given name.
|
void |
Mediation.setPayloadFromByteArray(Message m,
byte[] bytes)
Set the payload of the current message to the byte array passed
|
void |
Mediation.setPayloadFromDataHandler(Message m,
DataHandler dh)
Set the payload of the current message to the DataHandler passed in
|
void |
Mediation.setPayloadFromFile(Message m,
String filePath)
Set the current payload of the message as the content of the given file
|
<K,V> void |
Mediation.setPayloadFromMap(Message m,
Map<K,V> map)
Set the payload of the current message to the Map passed in
|
void |
Mediation.setPayloadFromObject(Message m,
Object obj)
Set the payload of the current message to the Java Object passed in
|
void |
Mediation.setPayloadFromString(Message m,
String text)
Set the payload of the current message to the given String
|
void |
Mediation.setPayloadFromXMLDocument(Message m,
Document doc)
Set the payload of the current message to the XML Document passed in
|
Modifier and Type | Method and Description |
---|---|
void |
MessageAggregator.aggregate(Message msg)
Aggregate the current message according to configuration of the aggregator instance.
|
void |
MessageAggregator.beginTimer(Message m)
Begin timer to process expired messages for aggregated responses to this message
|
void |
XQuerySupport.transformMessage(Message msg,
String fileName)
Transform message with the given XQuery and replace the payload with the result
|
void |
XQuerySupport.transformMessage(Message msg,
String fileName,
Map<String,Object> params)
Transform message with the given XQuery and replace the payload with the result
|
ResponseValidator.ResponseType |
ResponseValidator.validateResponse(Message msg) |
Modifier and Type | Method and Description |
---|---|
Message |
MessageEvent.getMessage()
Gets the message object of the event
|
Modifier and Type | Method and Description |
---|---|
static FlowType |
FlowType.fromMessage(Message message)
Constructs the
FlowType of the current message |
void |
AbstractMessageInterceptor.sendResponse(int code,
String content,
Message message,
Map<String,String> headers)
Sends the response back to the client and it is expected to drop the message and hence the interceptor logic
should return false if this method is invoked by the interceptor.
|
Constructor and Description |
---|
MessageEvent(Message message,
FlowPoint flowPoint,
String sequence,
String endpoint)
Constructs the message event with the specified properties
|
Modifier and Type | Method and Description |
---|---|
Message |
HL7Support.createAckResponse(Message msg)
Creates the default ACK HL7 MLLP response message and binds that to the UltraESB message API to return a new
response message that is understood by the UltraESB messaging API
|
Message |
HL7Support.createErrorResponse(Message msg,
String ackStatus,
int errorCode,
String errorMessage)
Creates the default ERROR HL7 MLLP response message and binds that to the UltraESB message API to return a new
response message that is understood by the UltraESB messaging API
|
Message |
HL7Support.createErrorResponse(Message msg,
String ackStatus,
String errorMessage)
Creates the default ERROR HL7 MLLP response message and binds that to the UltraESB message API to return a new
response message that is understood by the UltraESB messaging API
|
Modifier and Type | Method and Description |
---|---|
void |
XMLSupport.addAttributeToElements(Message msg,
String exprn,
String qName,
String nsUri,
String value,
String[]... ns)
Add an attribute to one or more elements selected by an XPath expression
e.g.
|
void |
EmailSupport.addBCCAddress(Message msg,
String email)
Adds a BCC email address to the given message to be used when sending the message out via the email transport
|
void |
EmailSupport.addBCCAddresses(Message msg,
List<String> emails)
Adds a list of BCC email addresses to the given message to be used when sending out via email transport
|
void |
EmailSupport.addCCAddress(Message msg,
String email)
Adds a CC email address to the given message to be used when sending out via email transport
|
void |
EmailSupport.addCCAddresses(Message msg,
List<String> emails)
Adds a list of CC email addresses to the given message to be used when sending out via email transport
|
void |
XMLSupport.addElementsAsChild(Message msg,
String expression,
String qualifiedTagName,
String namespace,
String[]... ns)
Inserts Element as a child to the specified elements pointed by an xpath expression
|
void |
HTTPSupport.addPreemptiveBasicAuthentication(Message msg,
String username,
String password)
Adds an HTTP transport header for pre-emptive basic authentication for this message.
|
void |
HTTPSupport.addPreemptiveBasicAuthentication(Message msg,
String username,
String password,
String charset,
boolean proxy)
Adds an HTTP transport header for pre-emptive basic authentication for this message.
|
void |
HTTPSupport.addRequestParameter(Message msg,
String name,
String value)
Add an outgoing query parameter with the given name
|
void |
SOAPSupport.addSoapAction(Message msg,
String action)
Add a SOAPAction transport header to the message
|
void |
SOAPSupport.addStringAsSoapHeader(Message msg,
String name,
String uri,
String content)
Adds a String as a new SOAP header
|
void |
XMLSupport.addTextElementsAsChild(Message msg,
String expression,
String qualifiedTagName,
String namespace,
String elementContent,
String[]... ns)
Inserts Text Element as a child to the specified elements pointed by an xpath expression
|
void |
JSONSupport.aggregateAndProcess(Message msg,
String aggregatePath,
String aggregatedSequence,
boolean ignoreErrors) |
void |
XMLSupport.aggregateWithBean(String beanName,
Message msg)
Aggregate message using the Split-Aggregation Spring bean configuration
|
void |
AuditSupport.auditLog(Message msg)
Audit log the given message with the
AuditSupport.AuditMode.COMPLETE |
void |
AuditSupport.auditLog(Message msg,
AuditSupport.AuditMode mode)
Audit log the given message with the given audit mode
|
void |
AuditSupport.auditLog(Message msg,
AuditSupport.AuditMode mode,
Map<String,String> properties)
Audit log the given message with the given audit mode, including the given additional properties.
|
void |
AuditSupport.auditLog(Message msg,
AuditSupport.AuditSeverity auditSeverity,
String auditDescription)
Audit log the given audit message with the given audit severity.
|
void |
AuditSupport.auditLog(Message msg,
String tag)
Audit log the given message with the
AuditSupport.AuditMode.COMPLETE with the given tag |
void |
AuditSupport.auditLog(Message msg,
String tag,
AuditSupport.AuditMode mode)
Audit log the given message with the given audit mode, and the tag
|
void |
AuditSupport.auditLog(Message msg,
String subject,
AuditSupport.AuditMode mode,
Map<String,String> properties)
Audit log the given message with the given audit mode, including the given additional properties.
|
void |
AuditSupport.auditLog(Message msg,
String tag,
String subject,
AuditSupport.AuditMode mode,
AuditSupport.AuditType type,
String auditDescription,
AuditSupport.AuditSeverity auditSeverity,
String projectName,
String username,
Map<String,String> properties)
Audit log the given message with the given message including tag, subject, mode, type, audit description,
severity, project id and properties.
|
void |
AuditSupport.auditLog(Message msg,
String tag,
String subject,
AuditSupport.AuditMode mode,
Map<String,String> properties)
Audit log the given message with the given audit mode, including the given additional properties and the tag.
|
void |
XMLSupport.convertDOMToSoap11(Message m)
Converts a DOM message to SOAP 1.1 by wrapping the message in a SOAP envelope and body
|
void |
XMLSupport.convertDOMToSoap12(Message m)
Converts a DOM message to SOAP 1.2 by wrapping the message in a SOAP envelope and body
|
void |
FastInfosetSupport.convertFIToSOAP(Message m)
Convert the payload of the current message from a FastInfoset binary to a SOAP message.
|
void |
FastInfosetSupport.convertFIToXML(Message m)
Convert the payload of the current message from a FastInfoset binary to an XML message (Note the XML
payload is still kept as a RawFileMessage by default and maybe converted into a DOM message if required)
|
void |
XMLSupport.convertFromFI(Message m)
Convert the payload of the current message from a FastInfoset binary to an XML message
(Note the XML payload is still kept as a RawFileMessage by default and maybe converted into a DOM message if required)
|
void |
JSONSupport.convertJSONToStream(Message m,
Object o)
Convert an untyped Object (e.g.
|
void |
XMLSupport.convertSoapToDOM(Message m)
Converts a SOAP message to DOM (POX) by stripping out the SOAP Envelope and Body and Header
|
void |
FastInfosetSupport.convertSOAPToFI(Message m)
Convert the SOAP message into a FastInfoset binary message
|
<T> T |
JAXBSupport.convertSOAPToJAXBObject(Message msg,
Class<? extends T> clazz)
Converts a SOAP payload into a JAXB Object.
|
<T> T |
SOAPSupport.convertSOAPToJAXBObject(Message msg,
Class<? extends T> clazz)
Converts a SOAP payload into a JAXB Object.
|
void |
JSONSupport.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 |
SOAPSupport.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 |
JSONSupport.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
|
void |
SOAPSupport.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
|
void |
XMLSupport.convertToDOM(Message m)
Convert the current message into a DOMMessage
|
void |
XMLSupport.convertToFI(Message m)
Convert the XML message into a FastInfoset binary message
|
JSONMessage |
JSONSupport.convertToJSONMessage(Message m) |
void |
ProtocolBufferSupport.convertToProtocolBuffer(Message message,
Class typeClass)
Convert the given
message to a message of type
ProtocolBufferMessage with a protocol buffer
Message type passed in with the typeClass . |
void |
ProtocolBufferSupport.convertToProtocolBuffer(Message message,
String descFile)
Convert the given
message to a message of type
ProtocolBufferMessage with a protocol buffer
DynamicMessage as the message type. |
<T> T |
JSONSupport.convertToTypedJSON(Message m,
Class<? extends T> clazz)
Convert the current message into a Typed JSON Object
|
Map<String,Object> |
JSONSupport.convertToUntypedJSON(Message m)
Convert the current message into an untyped JSON MapMessage
|
void |
FastInfosetSupport.convertXMLToFI(Message m)
Convert the XML message into a FastInfoset binary message
|
<T> T |
JAXBSupport.convertXMLToJAXBObject(Message msg,
Class<? extends T> clazz)
Converts a XML payload into a JAXB Object.
|
<T> T |
XMLSupport.convertXMLToJAXBObject(Message msg,
Class<? extends T> clazz)
Converts a XML payload into a JAXB Object.
|
<T> T |
JAXBSupport.convertXMLToJAXBObject(Message msg,
String contextPath,
Class<? extends T> clazz)
Converts a XML payload into a JAXB Object.
|
<T> T |
XMLSupport.convertXMLToJAXBObject(Message msg,
String contextPath,
Class<? extends T> clazz)
Converts a XML payload into a JAXB Object.
|
void |
JSONSupport.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 |
XMLSupport.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 |
JSONSupport.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
|
void |
XMLSupport.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
|
Message |
HL7Support.createAckResponse(Message msg)
Creates the default ACK HL7 MLLP response message and binds that to the UltraESB message API to return a new
response message that is understood by the UltraESB messaging API
|
Message |
HL7Support.createErrorResponse(Message msg,
String ackStatus,
int errorCode,
String errorMessage)
Creates the default ERROR HL7 MLLP response message and binds that to the UltraESB message API to return a new
response message that is understood by the UltraESB messaging API
|
Message |
HL7Support.createErrorResponse(Message msg,
String ackStatus,
String errorMessage)
Creates the default ERROR HL7 MLLP response message and binds that to the UltraESB message API to return a new
response message that is understood by the UltraESB messaging API
|
void |
XMLSupport.deleteAttributes(Message msg,
String exprn,
String[]... ns)
Deletes the specified attribute/s
e.g.
|
void |
XMLSupport.deleteElements(Message msg,
String expression,
String[]... ns)
Delete Elements pointed by an xpath expression
|
void |
SOAPSupport.deleteSoapHeader(Message msg,
String name,
String uri)
Delete a SOAP header and its descendants
|
void |
JSONSupport.enrichPayload(Message msg,
String key,
Object value) |
void |
JSONSupport.enrichPayloadAtPath(Message msg,
String path,
String key,
Object value) |
NodeList |
XMLSupport.extractAsNodeListUsingXPath(Message m,
String exprn,
String[]... ns)
Evaluate the given XPath expression against the XML payload, and return result as a NodeList
This method converts the current payload into a DOMMessage
|
String |
XMLSupport.extractAsStringUsingXPath(Message m,
String exprn,
String[]... ns)
Evaluate the given XPath expression against the XML payload, and return result as a String
This method converts the current payload into a DOMMessage
|
<T> T |
JSONSupport.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
|
boolean |
XMLSupport.filter(Message m,
String exprn,
String[]... ns)
Evaluate the given boolean XPath expression over the XML payload
|
boolean |
XMLSupport.filter(Message m,
String exprn,
String regex,
String[]... ns)
Evaluate the given XPath expression over the XML payload and compare the resulting String value with the
regular expression for a match.
|
String |
XMLSupport.getAttribute(Message msg,
String exprn,
String[]... ns)
Get attribute value e.g.
|
String[] |
HTTPSupport.getAuthenticatedRolesArray(Message msg)
Retrieved the the authenticated user roles of the given message as a String array
|
String |
HTTPSupport.getAuthenticatedRolesString(Message msg)
Retrieved the the authenticated user roles as a serialized String of the given message
|
String |
HTTPSupport.getAuthenticatedUsername(Message msg)
Gets the authenticated username of the given message
|
String |
HTTPSupport.getCookie(Message msg,
String name)
Return the value of the cookie with the given name
|
String |
SwiftSupport.getFieldValue(Message msg,
String field)
Gets the value of the given field or null if that field is not found.
|
String[] |
SwiftSupport.getFieldValues(Message msg,
String field)
Gets all values for a given field.
|
String |
HTTPSupport.getFirstRequestParameter(Message msg,
String key)
Return the first request query parameter with the given name
|
String |
HTTPSupport.getJvmRoute(Message msg)
Return the jvmRoute from the JSESSIONID cookie or jsessionid URL parameter of an HTTP/S request
|
String |
HTTPSupport.getLocalAddress(Message msg)
Gets the local address of the network interface via which the given message has been received to the ESB
|
int |
HTTPSupport.getLocalPort(Message msg)
Gets the local socket port used in receiving the current message
|
<T> T |
ProtocolBufferSupport.getMessage(Message message,
Class<T> typeClass)
Gets the protocol buffer message as a parsed message of type T from the given
message . |
HttpConstants.Method |
HTTPSupport.getMethod(Message msg)
Retrieves the given methods receiving HTTP method, could be one of;
HttpConstants.Method.GET
HttpConstants.Method.POST
HttpConstants.Method.PUT
HttpConstants.Method.DELETE
HttpConstants.Method.HEAD
HttpConstants.Method.OPTIONS
HttpConstants.Method.PATCH
|
WebSocketMessage.Opcode |
WebSocketSupport.getOpcode(Message msg) |
String[] |
WebSocketSupport.getOriginatedPeerLogicalGroups(Message msg) |
String |
WebSocketSupport.getOriginatedPeerSubscribedPath(Message msg) |
String |
WebSocketSupport.getOriginPeerID(Message msg) |
Document |
XMLSupport.getPayloadAsDOM(Message m)
Returns payload of the message as a DOM Document
|
int |
WebSocketSupport.getPayloadLength(Message msg) |
String |
HTTPSupport.getQueryString(Message msg)
Gives a String representation of URL query parameters of the given message received over HTTP/S transport.
|
long |
HTTPSupport.getReceivedEntitySize(Message msg)
Retrieves the size of the received HTTP entity of the given message - This is only available for requests and
responses received and not for messages about to be sent out
|
String |
FileSupport.getReceivedFileName(Message msg)
Retrieves the filename from which this message has been constructed provided that this message is received via
the file transport or as an AS2 message
|
String |
FileSupport.getReceivedFilePath(Message msg)
Retrieves the file path from which this message has been constructed provided that this message is received via
the file transport
|
long |
HTTPSupport.getReceivedHeaderSize(Message msg)
Retrieves the size of the received header over HTTP, of the given message - This is only available for requests
and responses received and not for messages about to be sent out
|
long |
HTTPSupport.getReceivedMessageSize(Message msg)
Retrieves the size of the received message over HTTP, of the given message - This is only available for requests
and responses received and not for messages about to be sent out
|
String |
HTTPSupport.getRemoteAddress(Message msg)
Gets the remote address of the given message
|
int |
HTTPSupport.getRemotePort(Message msg)
Gets the remote port of the given message
|
Map<String,List<String>> |
HTTPSupport.getRequestParameterMap(Message msg)
Return the query parameters as a Map
|
List<String> |
HTTPSupport.getRequestParameterValues(Message msg,
String key)
Return the list of query parameters for the given name/key
|
String |
JMSSupport.getSentMessageId(Message msg)
Retrieves the message id sent for the last JMS destination of the given message
|
String |
JMSSupport.getSentProviderURL(Message msg)
Retrieves the provider URL of the last sent JMS destination
|
String |
HTTPSupport.getServiceURL(Message msg)
Retrieves the service URL of the given message as seen at the message arrival to the ESB
|
String |
SOAPSupport.getSoapAction(Message msg)
Return the SOAPAction transport header
|
String |
SOAPSupport.getSoapAddressingAction(Message msg)
Get the WSA Action header
|
String |
SOAPSupport.getSoapAddressingFaultTo(Message msg)
Get the WSA FaultTo header
|
String |
SOAPSupport.getSoapAddressingFrom(Message msg)
Get the WSA From header
|
String |
SOAPSupport.getSoapAddressingMessageID(Message msg)
Get the WSA MessageID header
|
String |
SOAPSupport.getSoapAddressingReplyTo(Message msg)
Get the WSA ReplyTo header
|
String |
SOAPSupport.getSoapAddressingTo(Message msg)
Get the WSA To header
|
String |
SOAPSupport.getSoapFaultCode(Message msg)
Extract the SOAP 1.1 Fault/faultcode or SOAP 1.2 Fault/Code/Value if exists
|
String |
SOAPSupport.getSoapFaultDetail(Message msg)
Extract the SOAP 1.1 detail or SOAP 1.2 Detail if exists
|
String |
SOAPSupport.getSoapFaultString(Message msg)
Extract the SOAP 1.1 Fault/faultstring or SOAP 1.2 Reason/Text if exists
|
String |
SOAPSupport.getSoapHeaderAsString(Message msg,
String namespace,
String name)
Extract the SOAP 1.1/1.2 header value as a String
|
Map<QName,String> |
SOAPSupport.getSoapHeadersAsStrings(Message m)
Extract the SOAP 1.1/1.2 header values as a Strings
|
String |
XMLSupport.getTextElement(Message msg,
String exprn,
String[]... ns)
Get text element value for given XPath
|
void |
XMLSupport.insertTextElementsAfter(Message msg,
String expression,
String qualifiedTagName,
String namespace,
String elementContent,
String[]... ns)
Inserts an element/elements after the specified element pointed by the XPATH, to the current message.
|
void |
XMLSupport.insertTextElementsBefore(Message msg,
String expression,
String qualifiedTagName,
String namespace,
String elementContent,
String[]... ns)
Inserts an element/elements before the specified element pointed by the XPATH, to the current message.
|
boolean |
ThrottleSupport.isAllowed(Message message)
Implementer should implement the throttling logic within this.
|
boolean |
ThrottleSupport.isAllowed(String key,
Message message)
Throttling method implementation which takes in a category/key for evaluation - such as username, group, IP etc.
|
boolean |
HTTPSupport.isHessian(Message msg)
Check the message content type to see if it indicates a Hessian message
|
boolean |
XACMLSupport.isPermitted(String xacmlBeanId,
Message msg)
Is message allowed permission by the XACML processor bean selected.
|
boolean |
XACMLSupport.isPermitted(String xacmlBeanId,
String issuer,
Map<String,Object> custom,
Message msg)
Is message allowed permission by the XACML processor bean selected.
|
boolean |
JMSSupport.isRedelivery(Message msg)
Is this message a redelivery?
|
boolean |
SOAPSupport.isSoap(Message msg)
Check the message content type to see if it indicates a SOAP 1.1 or 1.2 message serialized as XML
|
boolean |
SOAPSupport.isSoap11(Message msg)
Check the message content type to see if it indicates a SOAP 1.1 message serialized as XML
|
boolean |
SOAPSupport.isSoap12(Message msg)
Check the message content type to see if it indicates a SOAP 1.2 message serialized as XML
|
void |
XMLSupport.mergeXMLAttachmentsUnderElement(Message msg,
String rootElemName)
Replace the current XML payload with a top level element as specified, and merge the payloads
from the current body, and attachments underneath that
|
void |
XMLSupport.mergeXMLAttachmentsUnderElement(Message msg,
String rootElemName,
String rootNS)
Replace the current XML payload with a top level element as specified, and merge the payloads
from the current body, and attachments underneath that
|
void |
JSONSupport.processBasicJSONDataServiceRequest(Message msg,
String dataSvcBeanName,
String dataSourceName)
Process request message as a basic JSON data service request.
|
String |
HL7Support.readPayloadAsString(Message msg)
Reads the HL7 payload as a String
|
boolean |
XMLSupport.remove(Message m,
String exprn,
String[]... ns)
Remove the XPath expression specified node from the XML payload.
|
List<String> |
HTTPSupport.removeRequestParameter(Message msg,
String key)
Remove the request query parameter with the given name
|
void |
SOAPSupport.removeSoapHeader(Message msg,
String name,
String uri)
Removes the specified SOAP header and its descendants if any from the payload
|
void |
XMLSupport.replaceAttributes(Message msg,
String expression,
String value,
String[]... ns)
Replaces the specified attribute/s value
|
void |
SOAPSupport.replaceStringAsSoapHeader(Message msg,
String name,
String uri,
String content)
Replace String based SOAP header
|
void |
XMLSupport.replaceTextElements(Message msg,
String expression,
String elementContent,
String[]... ns)
Replace Text Elements pointed by an xpath expression
|
void |
XMLSupport.retainElementAsPayload(Message m,
String exprn,
String[]... ns)
Replace the current XML payload with the resulting element from the XPath expression result
|
void |
FIXSupport.sendOrderCancelRequest(Message m,
String cancelOrderID,
String symbol,
Character side,
Date transactionTime,
String cancelText)
Requests the cancelation of all of the remaining quantity of an existing order.
|
void |
FIXSupport.sendReject(Message m,
int sessionRejectReason)
The reject message should be issued when a message is received but cannot be properly processed
due to a session-level rule violation
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP11Stream(Message msg,
Object jaxb)
Serialize a JAXB Object as a SOAP 1.1 Stream message
|
void |
SOAPSupport.serializeJAXBObjectAsSOAP11Stream(Message msg,
Object jaxb)
Serialize a JAXB Object as a SOAP 1.1 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP11Stream(Message msg,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a SOAP 1.1 Stream message
|
void |
SOAPSupport.serializeJAXBObjectAsSOAP11Stream(Message msg,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a SOAP 1.1 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP11Stream(Message msg,
String contextPath,
Object jaxb)
Serialize a JAXB Object as a SOAP 1.1 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP11Stream(Message msg,
String contextPath,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a SOAP 1.1 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP12Stream(Message msg,
Object jaxb)
Serialize a JAXB Object as a SOAP 1.2 Stream message
|
void |
SOAPSupport.serializeJAXBObjectAsSOAP12Stream(Message msg,
Object jaxb)
Serialize a JAXB Object as a SOAP 1.2 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP12Stream(Message msg,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a SOAP 1.2 Stream message
|
void |
SOAPSupport.serializeJAXBObjectAsSOAP12Stream(Message msg,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a SOAP 1.2 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP12Stream(Message msg,
String contextPath,
Object jaxb)
Serialize a JAXB Object as a SOAP 1.2 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsSOAP12Stream(Message msg,
String contextPath,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a SOAP 1.2 Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsXMLStream(Message msg,
Object jaxb)
Serialize a JAXB Object as a XML Stream message
|
void |
XMLSupport.serializeJAXBObjectAsXMLStream(Message msg,
Object jaxb)
Serialize a JAXB Object as a XML Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsXMLStream(Message msg,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a XML Stream message
|
void |
XMLSupport.serializeJAXBObjectAsXMLStream(Message msg,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a XML Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsXMLStream(Message msg,
String contextPath,
Object jaxb)
Serialize a JAXB Object as a XML Stream message
|
void |
XMLSupport.serializeJAXBObjectAsXMLStream(Message msg,
String contextPath,
Object jaxb)
Serialize a JAXB Object as a XML Stream message
|
void |
JAXBSupport.serializeJAXBObjectAsXMLStream(Message msg,
String contextPath,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a XML Stream message
|
void |
XMLSupport.serializeJAXBObjectAsXMLStream(Message msg,
String contextPath,
Object jaxb,
String rootElement,
String uri)
Serialize a JAXB Object as a XML Stream message
|
void |
HTTPSupport.setAuthenticationCredentials(Message msg,
String username,
String password)
Sets the authentication username and password to be used by HTTP authenticators
|
void |
HTTPSupport.setAuthenticationCredentials(Message msg,
String username,
String password,
String scheme)
Sets the authentication username and password and scheme to be used by HTTP authenticators
|
void |
HTTPSupport.setCookie(Message msg,
String name,
String value)
Set a HTTP cookie on the message
|
void |
HTTPSupport.setCookie(Message msg,
String name,
String value,
String path,
int age)
Set a HTTP cookie on the message
|
void |
HTTPSupport.setCookie(Message msg,
String name,
String value,
String path,
String domain,
int age,
boolean secure)
Set a HTTP cookie on the message
|
void |
FileSupport.setFileName(Message msg,
String fileName)
Sets the name of the file to be used to send the message out via the file transport
|
void |
HTTPSupport.setForcedHost(Message msg,
String hostName)
Forces the specified host name for any HTTP request going out after this call through the HTTP transport
|
void |
HTTPSupport.setForwardUrlPostfix(Message msg,
String postfix)
Appends the given postfix to the HTTP url of the given message
|
void |
EmailSupport.setFromAddress(Message msg,
String email)
Sets the SMTP from address for the given message to be used in sending the message out via the email transport
|
void |
ProtocolBufferSupport.setMessage(Message message,
Object object)
Sets the message of a protocol buffer message, from either a type of a protocol buffer Message interface or a
protocol buffer Message.Builder interface into the given
message . |
void |
HTTPSupport.setMethod(Message msg,
HttpConstants.Method method)
Sets the HTTP method for the current message effective for the next HTTP send action
|
void |
HTTPSupport.setNTLMAuthenticationCredentials(Message msg,
String username,
String password,
String domain,
String workstation)
Sets the authentication username and password to be used by HTTP authenticators
|
void |
XMLSupport.setPayloadFromDOM(Message m,
Document doc)
Set the payload of the message with the DOM Document
|
void |
SOAPSupport.setPayloadToSOAP11Fault(Message m,
String code,
String faultString,
String detail)
Set the payload of the current message to a SOAP 1.1 fault message with the given code, faultString and detail
|
void |
SOAPSupport.setPayloadToSOAP12Fault(Message m,
String code,
String reason,
String detail)
Set the payload of the current message to a SOAP 1.2 fault message with the given code, reason and detail
|
void |
WebSocketSupport.setRecipientLogicalGroups(Message msg,
List<String> logicalGroupList)
Marks the message to be sent to all the WebSocketPeers which belongs to
given logical groups.
|
void |
WebSocketSupport.setRecipientPeers(Message msg,
String... peerIdList)
Marks the message to be sent to all the WebSocketPeers which corresponds
to the given peerIds.
|
void |
WebSocketSupport.setRecipientSubscriberPaths(Message msg,
List<String> subscriberPathList)
Marks a message to be sent to all the WebSocketPeers which are connected to
given subscriber paths.
|
void |
EmailSupport.setSMTPCredentials(Message msg,
String user,
String password)
Sets and overrides any already defined SMTP credentials to the given message to be used in sending the message
out via the SMTP transport
|
void |
EmailSupport.setSubject(Message msg,
String subject)
Sets the email subject for the outgoing message via the email transport
|
void |
JSONSupport.splitAndProcess(Message msg,
String splitPath,
String sequenceName,
boolean ignoreErrors,
SplitGroupingCriteria criteria,
long aggregationTimeout,
boolean parallel) |
void |
JSONSupport.splitAndProcess(Message msg,
String splitPath,
String sequenceName,
boolean ignoreErrors,
SplitGroupingCriteria criteria,
long aggregationTimeout,
boolean parallel,
ScheduledExecutorService threadPool) |
void |
XMLSupport.splitAndProcess(Message msg,
String exprn,
String sequenceName,
boolean ignoreErrors,
String[]... ns)
Split current message into multiple messages using the given XPath expression, and hand over each such
message to the given sequence
|
void |
XMLSupport.splitWithBean(String beanName,
Message msg)
Split message using the Split-Aggregation Spring bean configuration
|
void |
FileSupport.storeMessage(Message msg,
String filePath)
Stores the given message payload into a file described by the given file URL
|
void |
LogSupport.tracePayload(Message msg,
org.adroitlogic.logging.api.Logger logger,
String... suffix)
Writes the message payload to a file
if trace is enabled for the given logger and '/tmp/trace' directory exists
|
void |
LogSupport.tracePayload(Message msg,
String... suffix)
Writes the message payload to a file
if trace is enabled for the system logger and '/tmp/trace' directory exists
|
void |
XMLSupport.transform(Message msg,
String xsltFilename)
Transform the message payload by XSLT (without any parameters), assuming a non DOM result and assuming that the
complete message payload will be used as the source of the transformation, and the result will replace the
complete message payload
|
void |
XMLSupport.transform(Message msg,
String xsltFilename,
String exprn,
boolean domResult,
Map<String,Object> parameters,
String[]... ns)
Transform the message payload by XSLT
|
void |
XMLSupport.transform(Message msg,
String xsltFilename,
String exprn,
String[]... ns)
Transform the message payload by XSLT (without any parameters), assuming a non DOM result
|
void |
XMLSupport.validate(Message m,
String... schemas)
Validate the current message against one or more schemas
If validation failed, this will throw a
BusRuntimeException with details of the XSD validation failures |
void |
XMLSupport.validate(Message m,
String[] schemas,
String exprn,
String[]... ns)
Validate the current message - or an element of it selected via an XPath expression - against one or more schemas
If validation failed, this will throw a
BusRuntimeException with details of the XSD validation failures |
void |
XMLSupport.validateAll(Message m,
String[] schemas,
String exprn,
String[]... ns)
Validate the current message - or all elements of it selected via an XPath expression - against one or more schemas
If validation failed, this will throw a
BusRuntimeException with details of the XSD validation failures |
void |
SwiftSupport.validateMessage(Message msg,
boolean networkRulesEnable)
Validates the original Swift MT message in the payload including its headers.
|
void |
SwiftSupport.validateMessageWithType(Message msg,
boolean networkRulesEnable,
int messageType)
Validates the original Swift MT message in the payload including its headers.
|
void |
XMLSupport.wrapPayload(Message msg,
String elementName,
String namespace)
Wrap the XML payload with an outer element
|
Modifier and Type | Method and Description |
---|---|
static String |
SplitterUtil.findAggregationStatus(Message message)
Gives the aggregation status of an aggregated message
|
static String |
SplitterUtil.findSplitKey(Message message)
Gives the split key of a splitted message
|
Modifier and Type | Method and Description |
---|---|
void |
MessageStatistics.recordResponse(Message message)
Deprecated.
Records the information of the response went back to the caller
|
void |
ESMessageStatistics.recordResponse(Message message)
Collect metrics which are relevant to the received message
|
Copyright © 2010–2016 AdroitLogic. All rights reserved.