public class MessageContextImpl extends java.lang.Object implements MessageContext
| Modifier and Type | Class and Description |
|---|---|
static class |
MessageContextImpl.ParseResult |
static class |
MessageContextImpl.TransformationResult |
| Constructor and Description |
|---|
MessageContextImpl() |
| Modifier and Type | Method and Description |
|---|---|
int |
dbExecuteUpdate(java.lang.String dataSourceName, java.lang.String sql) |
void |
deleteFromDB(DataObject dataObject, java.lang.String destinationMessageType, java.lang.String dataSourceName) |
LookupContext |
getLookupContext() |
TransformContext |
getTransformationContext() |
Message |
lookupMessage(java.lang.String messageType) |
MessageContextImpl.ParseResult |
parseBinaryMessage(byte[] message, java.lang.String messageType, boolean throwOnError) |
DataObject |
persistToDB(DataObject dataObject, java.lang.String destinationMessageType, java.lang.String dataSourceName) |
DataObjectSection |
queryDB(java.lang.String messageType, java.lang.String dataSourceName, java.lang.String queryName, java.lang.String parameters) |
SerializationResult<byte[]> |
serializeToBytes(DataObject message, java.lang.String destinationMessageType, boolean throwOnError) |
SerializationResult<java.lang.String> |
serializeToString(DataObject message, java.lang.String destinationMessageType, boolean throwOnError) |
MessageContextImpl.TransformationResult |
transform(DataObject message, java.lang.String mappingName) |
XmlErrors |
validateMessage(DataObject message, java.lang.String messageType) |
XmlErrors |
validateMessage(java.lang.String ruleSetName, DataObject message, java.lang.String messageType) |
void |
validateMessageThrowOnException(DataObject message, java.lang.String messageType) |
void |
validateMessageThrowOnException(java.lang.String ruleSetName, DataObject message, java.lang.String messageType) |
public MessageContextImpl()
throws javax.naming.NamingException
javax.naming.NamingExceptionpublic Message lookupMessage(java.lang.String messageType)
throws javax.naming.NamingException
javax.naming.NamingExceptionpublic void validateMessageThrowOnException(DataObject message,
java.lang.String messageType)
throws javax.naming.NamingException,
java.rmi.RemoteException,
TransformException,
UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionUnsupportedMessageTypeExceptionpublic void validateMessageThrowOnException(java.lang.String ruleSetName,
DataObject message,
java.lang.String messageType)
throws javax.naming.NamingException,
java.rmi.RemoteException,
TransformException,
UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionUnsupportedMessageTypeExceptionpublic XmlErrors validateMessage(DataObject message,
java.lang.String messageType)
throws javax.naming.NamingException,
java.rmi.RemoteException,
UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionUnsupportedMessageTypeExceptionpublic XmlErrors validateMessage(java.lang.String ruleSetName,
DataObject message,
java.lang.String messageType)
throws javax.naming.NamingException,
java.rmi.RemoteException,
UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionUnsupportedMessageTypeExceptionpublic MessageContextImpl.ParseResult parseBinaryMessage(byte[] message, java.lang.String messageType, boolean throwOnError) throws javax.naming.NamingException, java.rmi.RemoteException, TransformException, ParseException, UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionParseExceptionUnsupportedMessageTypeExceptionpublic SerializationResult<java.lang.String> serializeToString(DataObject message, java.lang.String destinationMessageType, boolean throwOnError) throws javax.naming.NamingException, java.rmi.RemoteException, TransformException, SerializationException, UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionSerializationExceptionUnsupportedMessageTypeExceptionpublic SerializationResult<byte[]> serializeToBytes(DataObject message, java.lang.String destinationMessageType, boolean throwOnError) throws javax.naming.NamingException, java.rmi.RemoteException, TransformException, SerializationException, UnsupportedMessageTypeException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionSerializationExceptionUnsupportedMessageTypeExceptionpublic MessageContextImpl.TransformationResult transform(DataObject message, java.lang.String mappingName) throws javax.naming.NamingException, java.rmi.RemoteException, TransformException, UnsupportedMessageTypeException
message -mappingName -javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionUnsupportedMessageTypeExceptionpublic DataObject persistToDB(DataObject dataObject,
java.lang.String destinationMessageType,
java.lang.String dataSourceName)
throws javax.naming.NamingException,
java.rmi.RemoteException,
TransformException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionpublic void deleteFromDB(DataObject dataObject,
java.lang.String destinationMessageType,
java.lang.String dataSourceName)
throws javax.naming.NamingException,
java.rmi.RemoteException,
TransformException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionpublic DataObjectSection queryDB(java.lang.String messageType,
java.lang.String dataSourceName,
java.lang.String queryName,
java.lang.String parameters)
throws javax.naming.NamingException,
java.rmi.RemoteException,
TransformException
javax.naming.NamingExceptionjava.rmi.RemoteExceptionTransformExceptionpublic int dbExecuteUpdate(java.lang.String dataSourceName,
java.lang.String sql)
throws TransformException
TransformExceptionpublic TransformContext getTransformationContext()
public LookupContext getLookupContext()