Uses of Class
org.apache.sandesha2.storage.StorageManager

Packages that use StorageManager
org.apache.sandesha2   
org.apache.sandesha2.msgprocessors   
org.apache.sandesha2.storage.inmemory   
org.apache.sandesha2.util   
org.apache.sandesha2.workers   
 

Uses of StorageManager in org.apache.sandesha2
 

Methods in org.apache.sandesha2 with parameters of type StorageManager
static void MessageValidator.validateIncomingMessage(RMMsgContext rmMsg, StorageManager storageManager)
           
 

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.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.
static RMMsgContext RMMsgCreator.createMakeConnectionMessage(RMMsgContext referenceRMMessage, RMSequenceBean bean, java.lang.String makeConnectionSeqId, java.lang.String makeConnectionAnonURI, StorageManager storageManager)
           
static RMMsgContext RMMsgCreator.createTerminateSequenceMessage(RMMsgContext referenceRMMessage, RMSBean rmsBean, StorageManager storageManager)
          Creates a new TerminateSequence message.
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 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 void FaultManager.makeInvalidAcknowledgementFault(RMMsgContext rmMsgCtx, SequenceAcknowledgement sequenceAcknowledgement, AcknowledgementRange acknowledgementRange, StorageManager storageManager, boolean piggybackedMessage)
          Makes an InvalidAcknowledgement fault.
static Transaction AcknowledgementManager.piggybackAcksIfPresent(RMMsgContext rmMessageContext, StorageManager storageManager, Transaction transaction)
          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 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 void TerminateManager.terminateSendingSide(RMSBean rmsBean, StorageManager storageManager)
          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
           
 



Copyright © 2007 Apache Web Services Project. All Rights Reserved.