|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sandesha2.util.SandeshaUtil
Contains utility methods that are used in many plases of Sandesha2.
Constructor Summary | |
SandeshaUtil()
|
Method Summary | |
static org.apache.axis2.context.MessageContext |
createNewRelatedMessageContext(RMMsgContext referenceRMMessage,
org.apache.axis2.description.AxisOperation operation)
|
static java.util.ArrayList |
getAckRangeArrayList(java.lang.String msgNoStr,
org.apache.axiom.soap.SOAPFactory factory,
java.lang.String rmNamespaceValue)
Used to convert a message number list (a comma seperated list of message numbers) into a set of AcknowledgementRanges. |
static java.util.ArrayList |
getArrayListFromMsgsString(java.lang.String str)
|
static java.util.ArrayList |
getArrayListFromString(java.lang.String str)
|
static SandeshaPropertyBean |
getDefaultPropertyBean(org.apache.axis2.engine.AxisConfiguration axisConfiguration)
|
static java.util.ArrayList |
getExecutionChainFromString(java.lang.String executionChainStr,
org.apache.axis2.context.ConfigurationContext configContext)
|
static java.lang.String |
getExecutionChainString(java.util.ArrayList executionChain)
|
static java.lang.String |
getInternalSequenceID(java.lang.String to,
java.lang.String sequenceKey)
|
static java.lang.String |
getMessageTypeString(int messageType)
|
static java.lang.String |
getOutgoingSideInternalSequenceID(java.lang.String sequenceID)
|
static SandeshaPropertyBean |
getPropertyBean(org.apache.axis2.description.AxisDescription axisDescription)
|
static javax.xml.namespace.QName |
getQNameFromString(java.lang.String qnameStr)
|
static java.lang.String |
getRMVersion(java.lang.String propertyKey,
org.apache.axis2.context.ConfigurationContext configurationContext)
|
static StorageManager |
getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context)
Used to obtain the storage Manager Implementation. |
static java.lang.String |
getSequenceIDFromInternalSequenceID(java.lang.String internalSequenceID,
org.apache.axis2.context.ConfigurationContext configurationContext)
|
static java.lang.String |
getSequenceIDFromRMMessage(RMMsgContext rmMessageContext)
|
static java.lang.String |
getSequenceProperty(java.lang.String id,
java.lang.String name,
org.apache.axis2.context.ConfigurationContext context)
|
static java.lang.String |
getServerSideIncomingSeqIdFromInternalSeqId(java.lang.String internalSequenceId)
|
static int |
getSOAPVersion(org.apache.axiom.soap.SOAPEnvelope envelope)
|
static java.util.ArrayList |
getSplittedMsgNoArraylist(java.lang.String str)
|
static java.lang.String |
getStringFromQName(javax.xml.namespace.QName name)
|
static java.lang.String |
getUUID()
Create a new UUID. |
static boolean |
isAllMsgsAckedUpto(long highestInMsgNo,
java.lang.String internalSequenceID,
org.apache.axis2.context.ConfigurationContext configCtx)
|
static boolean |
isDuplicateDropRequiredMsgType(int rmMessageType)
|
static boolean |
isGloballyProcessableMessageType(int type)
|
static boolean |
isRetriableOnFaults(org.apache.axis2.context.MessageContext msgCtx)
|
static boolean |
isRMGlobalMessage(org.apache.axis2.context.MessageContext msgCtx)
|
static void |
printSOAPEnvelope(org.apache.axiom.soap.SOAPEnvelope envelope,
java.io.OutputStream out)
|
static java.util.ArrayList |
sort(java.util.ArrayList list)
|
static void |
startInvokerForTheSequence(org.apache.axis2.context.ConfigurationContext context,
java.lang.String sequenceID)
|
static void |
startSenderForTheSequence(org.apache.axis2.context.ConfigurationContext context,
java.lang.String sequenceID)
|
static void |
stopInvoker(org.apache.axis2.context.ConfigurationContext context)
|
static void |
stopSender(org.apache.axis2.context.ConfigurationContext context)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SandeshaUtil()
Method Detail |
public static java.lang.String getUUID()
public static java.util.ArrayList getAckRangeArrayList(java.lang.String msgNoStr, org.apache.axiom.soap.SOAPFactory factory, java.lang.String rmNamespaceValue) throws SandeshaException
msgNoStr
- factory
-
SandeshaException
public static java.util.ArrayList sort(java.util.ArrayList list)
public static void startSenderForTheSequence(org.apache.axis2.context.ConfigurationContext context, java.lang.String sequenceID)
public static void stopSender(org.apache.axis2.context.ConfigurationContext context)
public static void startInvokerForTheSequence(org.apache.axis2.context.ConfigurationContext context, java.lang.String sequenceID)
public static void stopInvoker(org.apache.axis2.context.ConfigurationContext context)
public static java.lang.String getMessageTypeString(int messageType)
public static boolean isGloballyProcessableMessageType(int type)
public static boolean isDuplicateDropRequiredMsgType(int rmMessageType)
public static java.util.ArrayList getSplittedMsgNoArraylist(java.lang.String str)
public static java.lang.String getServerSideIncomingSeqIdFromInternalSeqId(java.lang.String internalSequenceId) throws SandeshaException
SandeshaException
public static StorageManager getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context) throws SandeshaException
context
-
SandeshaException
public static int getSOAPVersion(org.apache.axiom.soap.SOAPEnvelope envelope) throws SandeshaException
SandeshaException
public static boolean isRMGlobalMessage(org.apache.axis2.context.MessageContext msgCtx)
public static boolean isRetriableOnFaults(org.apache.axis2.context.MessageContext msgCtx)
public static org.apache.axis2.context.MessageContext createNewRelatedMessageContext(RMMsgContext referenceRMMessage, org.apache.axis2.description.AxisOperation operation) throws SandeshaException
SandeshaException
public static SandeshaPropertyBean getDefaultPropertyBean(org.apache.axis2.engine.AxisConfiguration axisConfiguration) throws SandeshaException
SandeshaException
public static java.util.ArrayList getArrayListFromString(java.lang.String str) throws SandeshaException
SandeshaException
public static java.util.ArrayList getArrayListFromMsgsString(java.lang.String str) throws SandeshaException
SandeshaException
public static java.lang.String getInternalSequenceID(java.lang.String to, java.lang.String sequenceKey)
public static java.lang.String getOutgoingSideInternalSequenceID(java.lang.String sequenceID)
public static java.lang.String getSequenceIDFromInternalSequenceID(java.lang.String internalSequenceID, org.apache.axis2.context.ConfigurationContext configurationContext) throws SandeshaException
SandeshaException
public static javax.xml.namespace.QName getQNameFromString(java.lang.String qnameStr) throws SandeshaException
SandeshaException
public static java.lang.String getStringFromQName(javax.xml.namespace.QName name)
public static java.lang.String getExecutionChainString(java.util.ArrayList executionChain)
public static java.util.ArrayList getExecutionChainFromString(java.lang.String executionChainStr, org.apache.axis2.context.ConfigurationContext configContext) throws SandeshaException
SandeshaException
public static void printSOAPEnvelope(org.apache.axiom.soap.SOAPEnvelope envelope, java.io.OutputStream out) throws SandeshaException
SandeshaException
public static java.lang.String getRMVersion(java.lang.String propertyKey, org.apache.axis2.context.ConfigurationContext configurationContext) throws SandeshaException
propertyKey
- for the client side - internalSequenceID, for the server side -
sequenceIDconfigurationContext
-
SandeshaException
public static java.lang.String getSequenceProperty(java.lang.String id, java.lang.String name, org.apache.axis2.context.ConfigurationContext context) throws SandeshaException
SandeshaException
public static boolean isAllMsgsAckedUpto(long highestInMsgNo, java.lang.String internalSequenceID, org.apache.axis2.context.ConfigurationContext configCtx) throws SandeshaException
SandeshaException
public static SandeshaPropertyBean getPropertyBean(org.apache.axis2.description.AxisDescription axisDescription) throws SandeshaException
SandeshaException
public static java.lang.String getSequenceIDFromRMMessage(RMMsgContext rmMessageContext)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |