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

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
           
 



Copyright © The Apache Software Foundation. All Rights Reserved.