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)
|
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)