|
|||||||||||
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 RMMsgContext |
createResponseRMMessage(RMMsgContext referenceRMMessage)
|
static org.apache.axis2.soap.SOAPEnvelope |
createSOAPMessage(org.apache.axis2.context.MessageContext msgContext,
java.lang.String soapNamespaceURI)
|
static java.util.ArrayList |
getAckRangeArrayList(java.lang.String msgNoStr,
org.apache.axis2.soap.SOAPFactory factory)
Used to convert a message number list (a comma seperated list of message numbers) into a set of AcknowledgementRanges. |
static java.lang.String |
getMessageTypeString(int messageType)
|
static StorageManager |
getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context)
Used to obtain the storage Manager Implementation. |
static java.lang.String |
getServerSideIncomingSeqIdFromInternalSeqId(java.lang.String internalSequenceId)
|
static java.lang.String |
getServerSideInternalSeqIdFromIncomingSeqId(java.lang.String incomingSequenceId)
|
static int |
getSOAPVersion(org.apache.axis2.soap.SOAPEnvelope envelope)
|
static java.util.ArrayList |
getSplittedMsgNoArraylist(java.lang.String str)
|
static org.apache.axis2.context.MessageContext |
getStoredMessageContext(java.lang.String key)
Retrieve the MessageContexts saved by the above method. |
static java.lang.String |
getUUID()
Create a new UUID. |
static boolean |
isDuplicateDropRequiredMsgType(int rmMessageType)
|
static boolean |
isGloballyProcessableMessageType(int type)
|
static boolean |
isRMGlobalMessage(org.apache.axis2.context.MessageContext msgCtx)
|
static java.util.ArrayList |
sort(java.util.ArrayList list)
|
static void |
startInvokerIfStopped(org.apache.axis2.context.ConfigurationContext context)
|
static void |
startSenderIfStopped(org.apache.axis2.context.ConfigurationContext context)
|
static java.lang.String |
storeMessageContext(org.apache.axis2.context.MessageContext ctx)
Used to store message context objects. |
static boolean |
verifySequenceCompletion(java.util.Iterator ackRangesIterator,
long lastMessageNo)
|
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.axis2.soap.SOAPFactory factory) throws SandeshaException
msgNoStr
- factory
-
SandeshaException
public static java.util.ArrayList sort(java.util.ArrayList list)
public static java.lang.String storeMessageContext(org.apache.axis2.context.MessageContext ctx) throws SandeshaException
ctx
-
SandeshaException
public static org.apache.axis2.context.MessageContext getStoredMessageContext(java.lang.String key)
key
-
public static void startSenderIfStopped(org.apache.axis2.context.ConfigurationContext context)
public static void startInvokerIfStopped(org.apache.axis2.context.ConfigurationContext context)
public static boolean verifySequenceCompletion(java.util.Iterator ackRangesIterator, long lastMessageNo)
public static org.apache.axis2.soap.SOAPEnvelope createSOAPMessage(org.apache.axis2.context.MessageContext msgContext, java.lang.String soapNamespaceURI) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
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)
public static java.lang.String getServerSideInternalSeqIdFromIncomingSeqId(java.lang.String incomingSequenceId)
public static StorageManager getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context) throws SandeshaException
context
-
SandeshaException
public static int getSOAPVersion(org.apache.axis2.soap.SOAPEnvelope envelope) throws SandeshaException
SandeshaException
public static boolean isRMGlobalMessage(org.apache.axis2.context.MessageContext msgCtx)
public static RMMsgContext createResponseRMMessage(RMMsgContext referenceRMMessage) throws SandeshaException
SandeshaException
public static org.apache.axis2.context.MessageContext createNewRelatedMessageContext(RMMsgContext referenceRMMessage, org.apache.axis2.description.AxisOperation operation) throws SandeshaException
SandeshaException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |