|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use StorageManager | |
org.apache.sandesha2 | |
org.apache.sandesha2.msgprocessors | |
org.apache.sandesha2.storage.inmemory | |
org.apache.sandesha2.util |
Uses of StorageManager in org.apache.sandesha2 |
Methods in org.apache.sandesha2 with parameters of type StorageManager | |
static void |
MessageValidator.validateMessage(RMMsgContext rmMsg,
StorageManager storageManager)
|
Uses of StorageManager in org.apache.sandesha2.msgprocessors |
Methods in org.apache.sandesha2.msgprocessors with parameters of type StorageManager | |
void |
ApplicationMsgProcessor.sendAckIfNeeded(RMMsgContext rmMsgCtx,
java.lang.String messagesStr,
StorageManager storageManager)
|
void |
ApplicationMsgProcessor.addCreateSequenceMessage(RMMsgContext referenceRMMsg,
java.lang.String sequencePropertyKey,
java.lang.String internalSequenceId,
org.apache.axis2.addressing.EndpointReference acksTo,
StorageManager storageManager)
|
Uses of StorageManager in org.apache.sandesha2.storage.inmemory |
Subclasses of StorageManager in org.apache.sandesha2.storage.inmemory | |
class |
InMemoryStorageManager
|
Uses of StorageManager in org.apache.sandesha2.util |
Methods in org.apache.sandesha2.util that return StorageManager | |
static StorageManager |
SandeshaUtil.getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context,
org.apache.axis2.description.AxisDescription description)
Used to obtain the storage Manager Implementation. |
static StorageManager |
SandeshaUtil.getInMemoryStorageManager(org.apache.axis2.context.ConfigurationContext context)
|
static StorageManager |
SandeshaUtil.getPermanentStorageManager(org.apache.axis2.context.ConfigurationContext context)
|
Methods in org.apache.sandesha2.util with parameters of type StorageManager | |
static void |
TerminateManager.cleanReceivingSideOnTerminateMessage(org.apache.axis2.context.ConfigurationContext configContext,
java.lang.String sequencePropertyKey,
java.lang.String sequenceId,
StorageManager storageManager)
Called by the receiving side to remove data related to a sequence. |
static void |
TerminateManager.cleanReceivingSideAfterInvocation(org.apache.axis2.context.ConfigurationContext configContext,
java.lang.String sequencePropertyKey,
java.lang.String sequenceId,
StorageManager storageManager)
When InOrder invocation is anabled this had to be called to clean the data left by the above method. |
static void |
TerminateManager.terminateSendingSide(org.apache.axis2.context.ConfigurationContext configContext,
java.lang.String sequencePropertyKey,
java.lang.String internalSequenceID,
boolean serverSide,
StorageManager storageManager)
This is called by the sending side to clean data related to a sequence. |
static void |
TerminateManager.timeOutSendingSideSequence(org.apache.axis2.context.ConfigurationContext context,
java.lang.String sequencePropertyKey,
java.lang.String internalSequenceId,
boolean serverside,
StorageManager storageManager)
|
static void |
TerminateManager.addTerminateSequenceMessage(RMMsgContext referenceMessage,
java.lang.String outSequenceId,
java.lang.String sequencePropertyKey,
StorageManager storageManager)
|
static void |
AcknowledgementManager.piggybackAcksIfPresent(RMMsgContext rmMessageContext,
StorageManager storageManager)
Piggybacks any available acks of the same sequence to the given application message. |
static RMMsgContext |
AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage,
java.lang.String sequencePropertyKey,
java.lang.String sequenceId,
StorageManager storageManager)
|
static java.lang.String |
SandeshaUtil.getSequenceIDFromInternalSequenceID(java.lang.String internalSequenceID,
StorageManager storageManager)
|
static java.lang.String |
SandeshaUtil.getRMVersion(java.lang.String propertyKey,
StorageManager storageManager)
|
static java.lang.String |
SandeshaUtil.getSequenceProperty(java.lang.String id,
java.lang.String name,
StorageManager storageManager)
|
static boolean |
SandeshaUtil.isAllMsgsAckedUpto(long highestInMsgNo,
java.lang.String sequencePropertyKey,
StorageManager storageManager)
|
static RMMsgContext |
RMMsgCreator.createCreateSeqMsg(RMMsgContext applicationRMMsg,
java.lang.String sequencePropertyKey,
org.apache.axis2.addressing.EndpointReference acksToEPR,
StorageManager storageManager)
Create a new CreateSeqnence message. |
static RMMsgContext |
RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage,
java.lang.String sequenceId,
java.lang.String sequencePropertyKey,
StorageManager storageManager)
Creates a new TerminateSequence message. |
static RMMsgContext |
RMMsgCreator.createCreateSeqResponseMsg(RMMsgContext createSeqMessage,
org.apache.axis2.context.MessageContext outMessage,
java.lang.String newSequenceID,
StorageManager storageManager)
Create a new CreateSequenceResponse message. |
static RMMsgContext |
RMMsgCreator.createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg,
org.apache.axis2.context.MessageContext outMessage,
StorageManager storageManager)
|
static RMMsgContext |
RMMsgCreator.createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg,
org.apache.axis2.context.MessageContext outMessage,
StorageManager storageManager)
|
static void |
RMMsgCreator.addAckMessage(RMMsgContext applicationMsg,
java.lang.String sequencePropertyKey,
java.lang.String sequenceId,
StorageManager storageManager)
Adds an ack message to the given application message. |
static RMMsgContext |
RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage,
java.lang.String makeConnectionSeqId,
java.lang.String makeConnectionAnonURI,
StorageManager storageManager)
|
static java.lang.String |
SequenceManager.setupNewSequence(RMMsgContext createSequenceMsg,
StorageManager storageManager)
|
static void |
SequenceManager.setupNewClientSequence(org.apache.axis2.context.MessageContext firstAplicationMsgCtx,
java.lang.String sequencePropertyKey,
java.lang.String specVersion,
StorageManager storageManager)
|
static void |
SequenceManager.updateLastActivatedTime(java.lang.String sequencePropertyKey,
StorageManager storageManager)
Takes the internalSeqID as the param. |
static long |
SequenceManager.getLastActivatedTime(java.lang.String propertyKey,
StorageManager storageManager)
|
static boolean |
SequenceManager.hasSequenceTimedOut(java.lang.String propertyKey,
RMMsgContext rmMsgCtx,
StorageManager storageManager)
|
static long |
SequenceManager.getOutGoingSequenceAckedMessageCount(java.lang.String sequencePropertyKey,
StorageManager storageManager)
|
static boolean |
SequenceManager.isOutGoingSequenceCompleted(java.lang.String internalSequenceID,
StorageManager storageManager)
|
static boolean |
SequenceManager.isIncomingSequenceCompleted(java.lang.String sequenceID,
StorageManager storageManager)
|
SandeshaException |
FaultManager.checkForCreateSequenceRefused(org.apache.axis2.context.MessageContext createSequenceMessage,
StorageManager storageManager)
Check weather the CreateSequence should be refused and generate the fault if it should. |
SandeshaException |
FaultManager.checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage,
StorageManager storageManager)
Check weather the LastMessage number has been exceeded and generate the fault if it is. |
SandeshaException |
FaultManager.checkForUnknownSequence(RMMsgContext rmMessageContext,
java.lang.String sequenceID,
StorageManager storageManager)
Check whether a Sequence message (a) belongs to a unknown sequence (generates an UnknownSequence fault) (b) message number exceeds a predifined limit ( genenrates a Message Number Rollover fault) |
SandeshaException |
FaultManager.checkForInvalidAcknowledgement(RMMsgContext ackRMMessageContext,
StorageManager storageManager)
Check weather the Acknowledgement is invalid and generate a fault if it is. |
SandeshaException |
FaultManager.checkForSequenceClosed(RMMsgContext referenceRMMessage,
java.lang.String sequenceID,
StorageManager storageManager)
|
SandeshaException |
FaultManager.getFault(RMMsgContext referenceRMMsgContext,
FaultData data,
java.lang.String addressingNamespaceURI,
StorageManager storageManager)
Adds the necessary Fault elements as properties to the message context. |
static boolean |
MessageRetransmissionAdjuster.adjustRetransmittion(RMMsgContext rmMsgCtx,
SenderBean retransmitterBean,
org.apache.axis2.context.ConfigurationContext configContext,
StorageManager storageManager)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |