|
|||||||||||
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.addressing.EndpointReference |
cloneEPR(org.apache.axis2.addressing.EndpointReference epr)
|
static org.apache.axis2.context.MessageContext |
cloneMessageContext(org.apache.axis2.context.MessageContext oldMsg)
|
static org.apache.axis2.context.MessageContext |
createNewRelatedMessageContext(RMMsgContext referenceRMMessage,
org.apache.axis2.description.AxisOperation operation)
|
static void |
executeAndStore(RMMsgContext rmMsgContext,
java.lang.String storageKey)
|
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 org.apache.axis2.description.AxisModule |
getAxisModule()
|
static SandeshaPolicyBean |
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 StorageManager |
getInMemoryStorageManager(org.apache.axis2.context.ConfigurationContext context)
|
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 StorageManager |
getPermanentStorageManager(org.apache.axis2.context.ConfigurationContext context)
|
static PollingManager |
getPollingManager(org.apache.axis2.context.ConfigurationContext configurationContext)
|
static SandeshaPolicyBean |
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,
StorageManager storageManager)
|
static StorageManager |
getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context,
org.apache.axis2.description.AxisDescription description)
Used to obtain the storage Manager Implementation. |
static SecurityManager |
getSecurityManager(org.apache.axis2.context.ConfigurationContext context)
|
static java.lang.String |
getSequenceIDFromInternalSequenceID(java.lang.String internalSequenceID,
StorageManager storageManager)
|
static java.lang.String |
getSequenceIDFromRMMessage(RMMsgContext rmMessageContext)
|
static java.lang.String |
getSequenceProperty(java.lang.String id,
java.lang.String name,
StorageManager storageManager)
|
static java.lang.String |
getSequencePropertyKey(RMMsgContext rmMsgContext)
This returns the Key used when store SequencePropertyBeans for the passed message. |
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 sequencePropertyKey,
StorageManager storageManager)
|
static boolean |
isAnonymousURI(java.lang.String address)
|
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 boolean |
isWSRMAnonymousReplyTo(java.lang.String replyTo)
|
static void |
modifyExecutionChainForStoring(org.apache.axis2.context.MessageContext message)
|
static void |
printSOAPEnvelope(org.apache.axiom.soap.SOAPEnvelope envelope,
java.io.OutputStream out)
|
static void |
setAxisModule(org.apache.axis2.description.AxisModule module)
|
static void |
shedulePollingRequest(java.lang.String sequenceId,
org.apache.axis2.context.ConfigurationContext configurationContext)
|
static java.util.ArrayList |
sort(java.util.ArrayList list)
|
static void |
startInvokerForTheSequence(org.apache.axis2.context.ConfigurationContext context,
java.lang.String sequenceID)
|
static void |
startPollingManager(org.apache.axis2.context.ConfigurationContext configurationContext)
|
static void |
startSenderForTheSequence(org.apache.axis2.context.ConfigurationContext context,
java.lang.String sequenceID)
|
static void |
stopInvoker(org.apache.axis2.context.ConfigurationContext context)
|
static void |
stopPollingManager(org.apache.axis2.context.ConfigurationContext configurationContext)
|
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 org.apache.axis2.description.AxisModule getAxisModule()
public static void setAxisModule(org.apache.axis2.description.AxisModule module)
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 startPollingManager(org.apache.axis2.context.ConfigurationContext configurationContext) throws SandeshaException
SandeshaException
public static void stopPollingManager(org.apache.axis2.context.ConfigurationContext configurationContext)
public static PollingManager getPollingManager(org.apache.axis2.context.ConfigurationContext configurationContext)
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, org.apache.axis2.description.AxisDescription description) throws SandeshaException
context
-
SandeshaException
public static StorageManager getInMemoryStorageManager(org.apache.axis2.context.ConfigurationContext context) throws SandeshaException
SandeshaException
public static StorageManager getPermanentStorageManager(org.apache.axis2.context.ConfigurationContext context) throws SandeshaException
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 SandeshaPolicyBean 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, StorageManager storageManager) 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, StorageManager storageManager) throws SandeshaException
propertyKey
- for the client side - internalSequenceID, for the server side -
sequenceID
SandeshaException
public static java.lang.String getSequenceProperty(java.lang.String id, java.lang.String name, StorageManager storageManager) throws SandeshaException
SandeshaException
public static boolean isAllMsgsAckedUpto(long highestInMsgNo, java.lang.String sequencePropertyKey, StorageManager storageManager) throws SandeshaException
SandeshaException
public static SandeshaPolicyBean getPropertyBean(org.apache.axis2.description.AxisDescription axisDescription) throws SandeshaException
SandeshaException
public static java.lang.String getSequenceIDFromRMMessage(RMMsgContext rmMessageContext) throws SandeshaException
SandeshaException
public static SecurityManager getSecurityManager(org.apache.axis2.context.ConfigurationContext context) throws SandeshaException
SandeshaException
public static java.lang.String getSequencePropertyKey(RMMsgContext rmMsgContext) throws org.apache.axis2.AxisFault
rmMsgContext
-
org.apache.axis2.AxisFault
public static boolean isWSRMAnonymousReplyTo(java.lang.String replyTo)
public static boolean isAnonymousURI(java.lang.String address)
public static void executeAndStore(RMMsgContext rmMsgContext, java.lang.String storageKey) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static void modifyExecutionChainForStoring(org.apache.axis2.context.MessageContext message)
public static org.apache.axis2.context.MessageContext cloneMessageContext(org.apache.axis2.context.MessageContext oldMsg) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static void shedulePollingRequest(java.lang.String sequenceId, org.apache.axis2.context.ConfigurationContext configurationContext) throws SandeshaException
SandeshaException
public static org.apache.axis2.addressing.EndpointReference cloneEPR(org.apache.axis2.addressing.EndpointReference epr)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |