org.apache.sandesha
Interface IStorageManager

All Known Implementing Classes:
ClientStorageManager, ServerStorageManager

public interface IStorageManager

Interface for StorageManager. This is the interface for RMSource and RMDestination for the Storage. Any implementation of this interface can be used as the storage for Sandesha


Method Summary
 void addAcknowledgement(RMMessageContext rmMessageContext)
           
 void addCreateSequenceRequest(RMMessageContext rmMessageContext)
           
 void addCreateSequenceResponse(RMMessageContext rmMessageContext)
           
 void addIncomingSequence(java.lang.String seqId)
           
 void addOffer(java.lang.String msgID, java.lang.String offerID)
           
 void addOutgoingSequence(java.lang.String seqId)
           
 void addRequestedSequence(java.lang.String seqId)
           
 void addSendMsgNo(java.lang.String seqId, long msgNo)
           
 void addSequence(java.lang.String sequenceID)
           
 RMMessageContext checkForResponseMessage(java.lang.String sequenceId, java.lang.String requestMsgId)
           
 void clearStorage()
           
 java.lang.String getAcksTo(java.lang.String seqId)
           
 java.lang.String getKeyFromOutgoingSeqId(java.lang.String seqId)
           
 long getLastIncomingMsgNo(java.lang.String seqId)
           
 java.util.Map getListOfMessageNumbers(java.lang.String sequenceID)
           
 long getNextMessageNumber(java.lang.String sequenceID)
           
 RMMessageContext getNextMessageToProcess(java.lang.Object seq)
           
 RMMessageContext getNextMessageToSend()
           
 java.lang.Object getNextSeqToProcess()
           
 java.lang.String getOffer(java.lang.String msgID)
           
 java.lang.String getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)
           
 java.lang.String getOutgoingSeqOfMsg(java.lang.String msgId)
           
 boolean hasLastIncomingMsgReceived(java.lang.String seqId)
           
 void init()
           
 void insertFault(RMMessageContext rmMsgCtx)
           
 void insertIncomingMessage(RMMessageContext rmMessageContext)
           
 void insertOutgoingMessage(RMMessageContext rmMessageContext)
           
 void insertTerminateSeqMessage(RMMessageContext terminateSeqMessage)
           
 boolean isMessageExist(java.lang.String sequenceID, long messageNumber)
           
 boolean isRequestedSeqPresent(java.lang.String seqId)
           
 boolean isResponseSequenceExist(java.lang.String sequenceID)
           
 boolean isSentMsg(java.lang.String seqId, long msgNo)
           
 boolean isSequenceComplete(java.lang.String seqId)
           
 boolean isSequenceExist(java.lang.String sequenceID)
           
 void removeCallback()
           
 void sendAck(java.lang.String sequenceId)
           
 void setAcknowledged(java.lang.String seqID, long msgNumber)
           
 void setAckReceived(java.lang.String seqId, long msgNo)
           
 void setAcksTo(java.lang.String seqId, java.lang.String acksTo)
           
 boolean setApprovedOutSequence(java.lang.String oldOutsequenceId, java.lang.String newOutSequenceId)
           
 void setCallback(Callback callBack)
           
 void setTemporaryOutSequence(java.lang.String sequenceId, java.lang.String outSequenceId)
           
 void setTerminateReceived(java.lang.String seqId)
           
 void setTerminateSend(java.lang.String seqId)
           
 

Method Detail

init

public void init()

isSequenceExist

public boolean isSequenceExist(java.lang.String sequenceID)

isResponseSequenceExist

public boolean isResponseSequenceExist(java.lang.String sequenceID)

getNextSeqToProcess

public java.lang.Object getNextSeqToProcess()

getNextMessageToProcess

public RMMessageContext getNextMessageToProcess(java.lang.Object seq)

setAcknowledged

public void setAcknowledged(java.lang.String seqID,
                            long msgNumber)

addSequence

public void addSequence(java.lang.String sequenceID)

addCreateSequenceResponse

public void addCreateSequenceResponse(RMMessageContext rmMessageContext)

addCreateSequenceRequest

public void addCreateSequenceRequest(RMMessageContext rmMessageContext)

addAcknowledgement

public void addAcknowledgement(RMMessageContext rmMessageContext)

isMessageExist

public boolean isMessageExist(java.lang.String sequenceID,
                              long messageNumber)

getListOfMessageNumbers

public java.util.Map getListOfMessageNumbers(java.lang.String sequenceID)

getNextMessageToSend

public RMMessageContext getNextMessageToSend()

setTemporaryOutSequence

public void setTemporaryOutSequence(java.lang.String sequenceId,
                                    java.lang.String outSequenceId)

setApprovedOutSequence

public boolean setApprovedOutSequence(java.lang.String oldOutsequenceId,
                                      java.lang.String newOutSequenceId)

getNextMessageNumber

public long getNextMessageNumber(java.lang.String sequenceID)

insertOutgoingMessage

public void insertOutgoingMessage(RMMessageContext rmMessageContext)

insertIncomingMessage

public void insertIncomingMessage(RMMessageContext rmMessageContext)

checkForResponseMessage

public RMMessageContext checkForResponseMessage(java.lang.String sequenceId,
                                                java.lang.String requestMsgId)

insertTerminateSeqMessage

public void insertTerminateSeqMessage(RMMessageContext terminateSeqMessage)

setAckReceived

public void setAckReceived(java.lang.String seqId,
                           long msgNo)

insertFault

public void insertFault(RMMessageContext rmMsgCtx)

addSendMsgNo

public void addSendMsgNo(java.lang.String seqId,
                         long msgNo)

isSentMsg

public boolean isSentMsg(java.lang.String seqId,
                         long msgNo)

hasLastIncomingMsgReceived

public boolean hasLastIncomingMsgReceived(java.lang.String seqId)

getLastIncomingMsgNo

public long getLastIncomingMsgNo(java.lang.String seqId)

addOutgoingSequence

public void addOutgoingSequence(java.lang.String seqId)

addIncomingSequence

public void addIncomingSequence(java.lang.String seqId)

getOutgoingSeqOfMsg

public java.lang.String getOutgoingSeqOfMsg(java.lang.String msgId)

addRequestedSequence

public void addRequestedSequence(java.lang.String seqId)

isRequestedSeqPresent

public boolean isRequestedSeqPresent(java.lang.String seqId)

getOutgoingSeqenceIdOfIncomingMsg

public java.lang.String getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)

setTerminateSend

public void setTerminateSend(java.lang.String seqId)

setTerminateReceived

public void setTerminateReceived(java.lang.String seqId)

getKeyFromOutgoingSeqId

public java.lang.String getKeyFromOutgoingSeqId(java.lang.String seqId)

setAcksTo

public void setAcksTo(java.lang.String seqId,
                      java.lang.String acksTo)

getAcksTo

public java.lang.String getAcksTo(java.lang.String seqId)

setCallback

public void setCallback(Callback callBack)

removeCallback

public void removeCallback()

addOffer

public void addOffer(java.lang.String msgID,
                     java.lang.String offerID)

getOffer

public java.lang.String getOffer(java.lang.String msgID)

clearStorage

public void clearStorage()

isSequenceComplete

public boolean isSequenceComplete(java.lang.String seqId)

sendAck

public void sendAck(java.lang.String sequenceId)