|
AdroitLogic UltraESB v1.7.0 | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
HTTPSupport.addPreemptiveBasicAuthentication(Message, String, String, String, boolean)
Adds an HTTP transport header for pre-emptive basic authentication for this message.
Note: Pre-emptive basic authentication will perform better than basic authentication after an initial
request fails with an HTTP 401 authentication required response. However, basic authentication will
not be secure as digest authentication or other such mechanisms. It is reccomended that basic authentication
if used, should be over an SSL secured connection - in which case the authentication security would be
acceptable
HTTPSupport.addPreemptiveBasicAuthentication(Message, String, String)
Adds an HTTP transport header for pre-emptive basic authentication for this message.
Note: Pre-emptive basic authentication will perform better than basic authentication after an initial
request fails with an HTTP 401 authentication required response. However, basic authentication will
not be secure as digest authentication or other such mechanisms. It is reccomended that basic authentication
if used, should be over an SSL secured connection - in which case the authentication security would be
acceptable
MessageListener used by the UltraESB AMQP transport to receive messages from the AMQP broker and inject to
the proxy services after creating a UltraESB API message.XMLSupport.convertFromFI(Message) or
SOAPSupport.convertFromFI(Message)
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)
JSONSupport.convertJSONToStream(Message, Object)
Convert an untyped Object (e.g. Map holding a JSON payload) to a streamed (file based) message
SOAPSupport.convertSOAPToJSONStream(Message) or
JSONSupport.convertSOAPToJSONStream(Message)
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
SOAPSupport.convertSOAPToJSONStream(Message, javax.xml.namespace.QName, boolean) or
JSONSupport.convertSOAPToJSONStream(Message, javax.xml.namespace.QName, boolean)
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
XMLSupport.convertToDOM(Message)
Convert the current message into a DOMMessage
XMLSupport.convertToFI(Message) or
SOAPSupport.convertToFI(Message)
Convert the XML message into a FastInfoset binary message
message to a message of type
ProtocolBufferMessage with a protocol buffer
DynamicMessage as the message type.
message to a message of type
ProtocolBufferMessage with a protocol buffer
Message type passed in with the typeClass.
JSONSupport.convertToTypedJSON(Message, Class)
Convert the current message into a Typed JSON Object
JSONSupport.convertToUntypedJSON(Message)
Convert the current message into an untyped JSON MapMessage
XMLSupport.convertXMLToJSONStream(Message) or
JSONSupport.convertXMLToJSONStream(Message)
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
XMLSupport.convertXMLToJSONStream(Message, javax.xml.namespace.QName, boolean) or
JSONSupport.convertXMLToJSONStream(Message, javax.xml.namespace.QName, boolean)
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
XMLSupport.createDOMDocument()
Create a new DOM Document object and return
XMLSupport.extractAsNodeListUsingXPath(Message, String, String[][])
Evaluate the given XPath expression against the XML payload, and return result as a NodeList
This method converts the current payload into a DOMMessage
XMLSupport.extractAsStringUsingXPath(Message, String, String[][]) or
SOAPSupport.extractAsStringUsingXPath(Message, String, String[][])
Evaluate the given XPath expression against the XML payload, and return result as a String
This method converts the current payload into a DOMMessage
XMLSupport.filter(Message, String, String[][], String) or
SOAPSupport.filter(Message, String, String[][], String)
Evaluate the given XPath expression over the XML payload and compare the resulting String value with the
regular expression for a match. This method converts the current payload into a DOMMessage
XMLSupport.filter(Message, String, String[][]) or
SOAPSupport.filter(Message, String, String[][])
Evaluate the given boolean XPath expression over the XML payload
HTTPSupport.getCookie(Message, String)
Return the value of the cookie with the given name
DateSupport.getDateFromISO8601String(String)
Returns a java.util.Date from an ISO8601 compliant date string yyyy-MM-dd
DateSupport.getDateFromUTCString(String)
Returns a java.util.Date from a UTC date string of the form yyyy-MM-dd'T'HH:mm:ss'Z'
CachingSupport.getDistributedCache()
Applicable only when the clustering is enabled and deployed as a cluster. Characteristics of
the cache returned by this method is equal to the cache that of Mediation.getLocalCache() but
this replicates the content across the nodes in the cluster.
Not like the local equivalent to which you can put any thing, this only accepts
Serializable content as both key and value of the entries in the cache. This
is because the content you put has to be serialized as the cache needs to replicate the
content using RMI.
If the node is starting up later in the cluster, (i.e. it joins a cluster with a state) the node bootstraps the cache content from one of its arbitrarily selected peers.
CachingSupport.getDistributedPermanentCache()
Applicable only when the clustering is enabled and deployed as a cluster. Characteristics of
the cache returned by this method is equal to the cache that of
Mediation.getLocalPermanentCache() but this replicates the content across the nodes in the
cluster.
Not like the local equivalent to which you can put any thing, this only accepts
Serializable content as both key and value of the entries in the cache. This
is because the content you put has to be serialized as the cache needs to replicate the
content using RMI.
You should take extra care about the content life cycle, as the cache doesn't expire the entries that you put. If the node is starting up later in the cluster, (i.e. it joins a cluster with a state) the node bootstraps the cache content from one of its arbitrarily selected peers. Because of the above bootstrap, not like in the local equivalent unless the complete cluster goes off the content will be preserved even on a System/JVM restart on a single node, as it will bootstrap it's cache content from a peer in the cluster.
CachingSupport.getDistributedPersistentCache()
Applicable only when the clustering is enabled and deployed as a cluster. Characteristics of
the cache returned by this method is equal to the cache that of
Mediation.getLocalPersistentCache() but this replicates the content across the nodes in the
cluster.
Not like the local equivalent to which you can put any thing, this only accepts
Serializable content as both key and value of the entries in the cache. This
is because the content you put has to be serialized as the cache needs to replicate the
content using RMI.
You should take extra care about the content life cycle, as the cache doesn't expire the entries that you put. If the node is starting up later in the cluster, (i.e. it joins a cluster with a state) the node bootstraps the cache content from one of its arbitrarily selected peers.
DateSupport.getISO8601FormattedString(java.util.Date)
Returns an ISO8601 compliant date string as yyyy-MM-dd
HTTPSupport.getJvmRoute(Message)
Return the jvmRoute from the JSESSIONID cookie or jsessionid URL parameter of an HTTP/S request
Cache instance which is available locally in the node, and expires it's
entries in a given time.
CachingSupport.getLocalCache()
Gets the Cache instance which is available locally in the node, and expires it's
entries in a given time. It also has a time to live and nothing is guaranteed to be present
in this cache. If you need your content to be present through out the session, use the
Mediation.getLocalPermanentCache() to get the cache which will give you the permanent cache.
This cache overflows the content to disk in case of exceeding the in-memory cache size, which defaults to 10000 entries. How ever after storing another 1000 entries in the disk, the cache will permanently overflow, which sniffs something wrong in your mediation, as the content in this cache is automatically cleared in the expiration time.
Cache instance which is available locally in the node, and keeps its
contents in the cache within a session.
CachingSupport.getLocalPermanentCache()
Gets the Cache instance which is available locally in the node, and keeps its
contents in the cache within a session. The contents in this cache will never be expired but
they are not persisted, so they will be lost at a System/JVM restart. If you want content to
be available across JVM sessions, use Mediation.getLocalPersistentCache() instead.
You should be using this with care, as the content life cycle is not managed by the cache it is your responsibility to manage the cache content life cycle. Otherwise you might get into a resource exhaustion. This cache overflows the content to disk in case of exceeding the in-memory cache size, which defaults to 1000 entries, while there is no limit to the content which will be overflowed to disk
Cache instance which is available locally in the node, and keeps its
contents in the cache forever across the sessions.
CachingSupport.getLocalPersistentCache()
Gets the Cache instance which is available locally in the node, and keeps its
contents in the cache forever across the sessions. In other words the content will be
persisted to the disk.
Once again you should be extra careful about the usage, as the content will be there even after a system/JVM restart. It is possible to crash the disk space and the data persisted in the disk be lost and the cache is not handling that case as it really cannot do anything for the data corruption. This cache by default keeps only 100 entries in-memory and it off-loads the content to disk and loads the content from disk depending on the demand for those entries.
You could treat this as a NO-SQL persistent store, available locally in your node. If you
want the content to be available among the cluster in the case of a clustered deployment, use
the Mediation.getDistributedPersistentCache()
message.
SOAPSupport.getSoapAction(Message)
Return the SOAPAction transport header
SOAPSupport.getSoapAddressingAction(Message)
Get the WSA Action header
SOAPSupport.getSoapAddressingFaultTo(Message)
Get the WSA FaultTo header
SOAPSupport.getSoapAddressingFrom(Message)
Get the WSA From header
SOAPSupport.getSoapAddressingMessageID(Message)
Get the WSA MessageID header
SOAPSupport.getSoapAddressingReplyTo(Message)
Get the WSA ReplyTo header
SOAPSupport.getSoapAddressingTo(Message)
Get the WSA To header
SOAPSupport.getSoapFaultCode(Message)
Extract the SOAP 1.1 Fault/faultcode or SOAP 1.2 Fault/Code/Value if exists
SOAPSupport.getSoapFaultDetail(Message)
Extract the SOAP 1.1 detail or SOAP 1.2 Detail if exists
SOAPSupport.getSoapFaultString(Message)
Extract the SOAP 1.1 Fault/faultstring or SOAP 1.2 Reason/Text if exists
SOAPSupport.getSoapHeaderAsString(Message, String, String)
Extract the SOAP 1.1/1.2 header value as a String
SOAPSupport.getSoapHeadersAsStrings(Message)
Extract the SOAP 1.1/1.2 header values as a Strings
DateSupport.getSQLDateFromISO8601String(String)
Returns a java.sql.Date from an ISO8601 compliant date string yyyy-MM-dd
DateSupport.getSQLDateFromUTCString(String)
Returns a java.sql.Date from a UTC date string of the form yyyy-MM-dd'T'HH:mm:ss'Z'
ThrottleSupport defined in the UltraESB
configuration with the given bean identifier.
LOCAL_TEMP
LOCAL_PERMANENT
LOCAL_PERSISTENT
DISTRIBUTED_TEMP
DISTRIBUTED_PERMANENT
DISTRIBUTED_PERSISTENT
DateSupport.getUTFFormattedString(java.util.Date)
Returns a UTC formatted date string as yyyy-MM-dd'T'HH:mm:ss'Z'
DISTRIBUTED_TEMP
DISTRIBUTED_PERMANENT
DISTRIBUTED_PERSISTENT
HTTPSupport.isHessian(Message)
Check the message content type to see if it indicates a Hessian message
XACMLSupport.isPermitted(String, Message)
Is message allowed permission by the XACML processor bean selected. Automatically maps the following HTTP
related transport properties to the specified attribute names
action-id -> msg.getMessageProperty(HttpConstants.METHOD)
subject-id -> msg.getMessageProperty(HttpConstants.USERNAME)
role -> msg.getMessageProperty(HttpConstants.USERROLES) as a String[]
client-dn -> msg.getMessageProperty(HttpConstants.SSL_CLIENT_DN)
resource-id -> msg.getMessageProperty(HttpConstants.SERVICE_URL)
XACMLSupport.isPermitted(String, java.util.Map)
Is message allowed permission by the XACML processor bean selected.
XACMLSupport.isPermitted(String, String, java.util.Map, Message)
Is message allowed permission by the XACML processor bean selected.
SOAPSupport.isSoap(Message)
Check the message content type to see if it indicates a SOAP 1.1 or 1.2 message serialized as XML
XMLSupport.mergeXMLAttachmentsUnderElement(Message, String)
Replace the current XML payload with a top level element as specified, and merge the payloads
from the current body, and attachments underneath that
XMLSupport.mergeXMLAttachmentsUnderElement(Message, String, String)
Replace the current XML payload with a top level element as specified, and merge the payloads
from the current body, and attachments underneath that
JSONSupport.processBasicJSONDataServiceRequest(Message, String, String)
Process request message as a basic JSON data service request. The response would be generated by executing the
specified queries of the JSON Data Service bean definition
XMLSupport.remove(Message, String, String[][]) or
SOAPSupport.remove(Message, String, String[][])
Remove the XPath expression specified node from the XML payload. This method converts the current payload of the
message into a DOMMessage
ResponseValidator
interface that will decide, if a response should be accepted as valid from this endpoint
XMLSupport.retainElementAsPayload(Message, String, String[][])
Replace the current XML payload with the resulting element from the XPath expression result
HTTPSupport.setCookie(Message, String, String, String, String, int, boolean)
Set a HTTP cookie on the message
HTTPSupport.setCookie(Message, String, String, String, int)
Set a HTTP cookie on the message
HTTPSupport.setCookie(Message, String, String)
Set a HTTP cookie on the message
message.
SOAPSupport.setPayloadToSOAP11Fault(Message, String, String, String)
Set the payload of the current message to a SOAP 1.1 fault message with the given code, faultString and detail
SOAPSupport.setPayloadToSOAP12Fault(Message, String, String, String)
Set the payload of the current message to a SOAP 1.2 fault message with the given code, reason and detail
SO_TIMEOUT) in milliseconds,
which is the timeout for waiting for data or, put differently,
a maximum period inactivity between two consecutive data packets).
XMLSupport.splitAndProcess(Message, String, String[][], String, boolean) or
SOAPSupport.splitAndProcess(Message, String, String[][], String, boolean)
Split current message into multiple messages using the given XPath expression, and hand over each such
message to the given sequence
XMLSupport.transform(Message, String, String, String[][], boolean, java.util.Map) or
SOAPSupport.transform(Message, String, String, String[][], boolean, java.util.Map)
Transform the message payload by XSLT
XMLSupport.transform(Message, String, String, String[][])
SOAPSupport.transform(Message, String, String, String[][])
Transform the message payload by XSLT (without any parameters), assuming a non DOM result
XMLSupport.transform(Message, String)
SOAPSupport.transform(Message, String)
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
SOAPSupport.validate(Message, String[], String, String[][]) or
XMLSupport.validate(Message, String[], String, String[][])
Validate the current message - or an element of it selected via an XPath expression - against one or more schemas
SOAPSupport.validate(Message, String[]) or
XMLSupport.validate(Message, String[])
Validate the current message against one or more schemas
SOAPSupport.validate(Message, String) or
XMLSupport.validate(Message, String)
Validate the current message against one single schema
|
Copyright (c) 2010-2012 AdroitLogic Private Ltd. All rights reserved. | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||