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   
 

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)
           
 



Copyright © 2005-2006 Apache Web Services. All Rights Reserved.