|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use StorageManager | |
---|---|
org.apache.sandesha2.msgprocessors | |
org.apache.sandesha2.storage.inmemory | |
org.apache.sandesha2.storage.jdbc | |
org.apache.sandesha2.util | |
org.apache.sandesha2.workers |
Uses of StorageManager in org.apache.sandesha2.msgprocessors |
---|
Methods in org.apache.sandesha2.msgprocessors with parameters of type StorageManager | |
---|---|
static void |
MakeConnectionProcessor.replyToPoll(RMMsgContext pollMessage,
SenderBean matchingMessage,
StorageManager storageManager,
boolean pending,
java.lang.String makeConnectionNamespace,
Transaction transaction)
|
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.storage.jdbc |
---|
Subclasses of StorageManager in org.apache.sandesha2.storage.jdbc | |
---|---|
class |
PersistentStorageManager
A Storage Manager implementation for managing Sandesha2 beans. |
Uses of StorageManager in org.apache.sandesha2.util |
---|
Methods in org.apache.sandesha2.util that return StorageManager | |
---|---|
static StorageManager |
SandeshaUtil.getInMemoryStorageManager(org.apache.axis2.context.ConfigurationContext context)
|
static StorageManager |
SandeshaUtil.getPermanentStorageManager(org.apache.axis2.context.ConfigurationContext context)
|
static StorageManager |
SandeshaUtil.getSandeshaStorageManager(org.apache.axis2.context.ConfigurationContext context,
org.apache.axis2.description.AxisDescription description)
Used to obtain the storage Manager Implementation. |
StorageManager |
WSRMMessageSender.getStorageManager()
|
Methods in org.apache.sandesha2.util with parameters of type StorageManager | |
---|---|
static void |
AcknowledgementManager.addAckBeanEntry(RMMsgContext ackRMMsgContext,
java.lang.String sequenceId,
long timeToSend,
StorageManager storageManager)
|
static void |
TerminateManager.addTerminateSequenceMessage(RMMsgContext referenceMessage,
java.lang.String internalSequenceID,
java.lang.String outSequenceId,
StorageManager storageManager)
|
static boolean |
MessageRetransmissionAdjuster.adjustRetransmittion(RMMsgContext rmMsgCtx,
SenderBean retransmitterBean,
org.apache.axis2.context.ConfigurationContext configContext,
StorageManager storageManager)
|
static void |
TerminateManager.checkAndTerminate(org.apache.axis2.context.ConfigurationContext configurationContext,
StorageManager storageManager,
RMSBean rmsBean)
|
static boolean |
FaultManager.checkForInvalidAcknowledgement(RMMsgContext ackRMMessageContext,
SequenceAcknowledgement sequenceAcknowledgement,
StorageManager storageManager,
RMSBean rmsBean,
boolean piggybackedMessage)
Check weather the Acknowledgement is invalid and generate a fault if it is. |
static void |
FaultManager.checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage,
StorageManager storageManager)
Check weather the LastMessage number has been exceeded and generate the fault if it is. |
static boolean |
FaultManager.checkForUnknownSequence(RMMsgContext rmMessageContext,
java.lang.String sequenceID,
StorageManager storageManager,
boolean piggybackedMessage)
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) |
static void |
TerminateManager.cleanReceivingSideAfterInvocation(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.cleanReceivingSideOnTerminateMessage(org.apache.axis2.context.ConfigurationContext configContext,
java.lang.String sequenceId,
StorageManager storageManager)
Called by the receiving side to remove data related to a sequence. e.g. |
static RMMsgContext |
RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage,
RMSBean rmsBean,
StorageManager storageManager)
Creates a new TerminateSequence message. |
static void |
SandeshaUtil.executeAndStore(RMMsgContext rmMsgContext,
java.lang.String storageKey,
StorageManager manager)
|
static void |
SequenceManager.finalizeTimedOutSequence(java.lang.String internalSequenceID,
org.apache.axis2.context.MessageContext messageContext,
StorageManager storageManager)
|
static RMMsgContext |
AcknowledgementManager.generateAckMessage(RMMsgContext referenceRMMessage,
RMDBean rmdBean,
java.lang.String sequenceId,
StorageManager storageManager,
boolean serverSide)
|
static long |
SandeshaUtil.getLastMessageNumber(java.lang.String internalSequenceID,
StorageManager storageManager)
|
static RMDBean |
SandeshaUtil.getRMDBeanFromSequenceId(StorageManager storageManager,
java.lang.String sequenceID)
|
static RMSBean |
SandeshaUtil.getRMSBeanFromInternalSequenceId(StorageManager storageManager,
java.lang.String internalSequenceID)
|
static RMSBean |
SandeshaUtil.getRMSBeanFromSequenceId(StorageManager storageManager,
java.lang.String sequenceID)
|
static java.lang.String |
SandeshaUtil.getSequenceIDFromInternalSequenceID(java.lang.String internalSequenceID,
StorageManager storageManager)
|
static java.lang.String |
SequenceManager.getSpecVersion(org.apache.axis2.context.MessageContext applicationMessage,
StorageManager storageManager)
|
static boolean |
SequenceManager.hasSequenceTimedOut(RMSBean rmsBean,
java.lang.String internalSequenceId,
StorageManager storageManager)
|
static boolean |
SandeshaUtil.isAllMsgsAckedUpto(long highestInMsgNo,
java.lang.String internalSequenceId,
StorageManager storageManager)
|
static RMSBean |
SandeshaUtil.isLinkedToReallocatedRMSBean(StorageManager storageManager,
java.lang.String internalSeqID)
|
static void |
FaultManager.makeInvalidAcknowledgementFault(RMMsgContext rmMsgCtx,
SequenceAcknowledgement sequenceAcknowledgement,
Range acknowledgementRange,
StorageManager storageManager,
boolean piggybackedMessage,
org.apache.axis2.addressing.EndpointReference acksToEPR)
Makes an InvalidAcknowledgement fault. |
static void |
SandeshaUtil.modifyExecutionChainForStoring(org.apache.axis2.context.MessageContext message,
StorageManager manager)
|
static void |
AcknowledgementManager.piggybackAcksIfPresent(RMMsgContext rmMessageContext,
StorageManager storageManager)
Piggybacks any available acks of the same sequence to the given application message. |
static org.apache.axis2.engine.Handler.InvocationResponse |
FaultManager.processMessagesForFaults(RMMsgContext rmMsgCtx,
StorageManager storageManager)
|
static void |
SandeshaUtil.reallocateMessagesToNewSequence(StorageManager storageManager,
RMSBean oldRMSBean,
java.util.List<org.apache.axis2.context.MessageContext> msgsToSend,
Transaction transaction)
ReallocateMessages to a new sequence |
static RMSBean |
SequenceManager.setupNewClientSequence(org.apache.axis2.context.MessageContext firstAplicationMsgCtx,
java.lang.String internalSequenceId,
StorageManager storageManager)
|
static RMDBean |
SequenceManager.setupNewSequence(RMMsgContext createSequenceMsg,
StorageManager storageManager,
SecurityManager securityManager,
SecurityToken token)
Set up a new inbound sequence, triggered by the arrival of a create sequence message. |
static boolean |
TerminateManager.terminateSendingSide(RMSBean rmsBean,
StorageManager storageManager,
boolean reallocate,
Transaction transaction)
This is called by the sending side to clean data related to a sequence. |
static void |
TerminateManager.timeOutSendingSideSequence(java.lang.String internalSequenceId,
StorageManager storageManager)
|
Uses of StorageManager in org.apache.sandesha2.workers |
---|
Fields in org.apache.sandesha2.workers declared as StorageManager | |
---|---|
protected StorageManager |
SandeshaThread.storageManager
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |