|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sandesha.server.ServerStorageManager
ServerStorageManager is the access point for the SandeshaQueue from server side.
Field Summary | |
protected static Log |
log
|
Constructor Summary | |
ServerStorageManager()
|
Method Summary | |
void |
addAcknowledgement(RMMessageContext rmMessageContext)
|
void |
addCreateSequenceRequest(RMMessageContext rmMessageContext)
|
void |
addCreateSequenceResponse(RMMessageContext rmMessageContext)
|
void |
addIncomingSequence(java.lang.String sequenceId)
|
void |
addOffer(java.lang.String msgID,
java.lang.String offerID)
|
void |
addOutgoingSequence(java.lang.String sequenceId)
|
void |
addRequestedSequence(java.lang.String seqId)
|
void |
addSendMsgNo(java.lang.String seqId,
long msgNo)
|
void |
addSequence(java.lang.String sequenceId)
Will be used to add a new Sequence Hash to the In Queue. |
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)
This gives a sorted(by keys) map of messageIds present for a sequence. |
long |
getNextMessageNumber(java.lang.String sequenceID)
|
RMMessageContext |
getNextMessageToProcess(java.lang.Object seq)
A very important method. |
RMMessageContext |
getNextMessageToSend()
This is used to get a random message from the out queue Basically server sender will use this. |
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 msg)
|
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)
Used to find out weather the sequence with this id has already been created. |
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 createSeqId,
java.lang.String newOutSequenceId)
|
void |
setCallback(Callback cb)
|
void |
setTemporaryOutSequence(java.lang.String sequenceId,
java.lang.String outSequenceId)
|
void |
setTerminateReceived(java.lang.String seqId)
|
void |
setTerminateSend(java.lang.String seqId)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static Log log
Constructor Detail |
public ServerStorageManager()
Method Detail |
public void setTerminateSend(java.lang.String seqId)
setTerminateSend
in interface IStorageManager
public void setTerminateReceived(java.lang.String seqId)
setTerminateReceived
in interface IStorageManager
public RMMessageContext getNextMessageToProcess(java.lang.Object seq)
getNextMessageToProcess
in interface IStorageManager
public void setAcknowledged(java.lang.String seqID, long msgNumber)
setAcknowledged
in interface IStorageManager
public void init()
init
in interface IStorageManager
public boolean isSequenceExist(java.lang.String sequenceID)
isSequenceExist
in interface IStorageManager
public boolean isResponseSequenceExist(java.lang.String sequenceID)
isResponseSequenceExist
in interface IStorageManager
public java.lang.Object getNextSeqToProcess()
getNextSeqToProcess
in interface IStorageManager
public RMMessageContext getNextMessageToSend()
getNextMessageToSend
in interface IStorageManager
public void addSequence(java.lang.String sequenceId)
addSequence
in interface IStorageManager
public java.util.Map getListOfMessageNumbers(java.lang.String sequenceID)
getListOfMessageNumbers
in interface IStorageManager
public boolean isMessageExist(java.lang.String sequenceID, long messageNumber)
isMessageExist
in interface IStorageManager
public void addCreateSequenceResponse(RMMessageContext rmMessageContext)
addCreateSequenceResponse
in interface IStorageManager
public void addCreateSequenceRequest(RMMessageContext rmMessageContext)
addCreateSequenceRequest
in interface IStorageManager
public void addAcknowledgement(RMMessageContext rmMessageContext)
addAcknowledgement
in interface IStorageManager
public void setTemporaryOutSequence(java.lang.String sequenceId, java.lang.String outSequenceId)
setTemporaryOutSequence
in interface IStorageManager
public boolean setApprovedOutSequence(java.lang.String createSeqId, java.lang.String newOutSequenceId)
setApprovedOutSequence
in interface IStorageManager
public long getNextMessageNumber(java.lang.String sequenceID)
getNextMessageNumber
in interface IStorageManager
public void insertOutgoingMessage(RMMessageContext msg)
insertOutgoingMessage
in interface IStorageManager
public void insertIncomingMessage(RMMessageContext rmMessageContext)
insertIncomingMessage
in interface IStorageManager
public RMMessageContext checkForResponseMessage(java.lang.String sequenceId, java.lang.String requestMsgId)
checkForResponseMessage
in interface IStorageManager
public void insertTerminateSeqMessage(RMMessageContext terminateSeqMessage)
insertTerminateSeqMessage
in interface IStorageManager
public void setAckReceived(java.lang.String seqId, long msgNo)
setAckReceived
in interface IStorageManager
public void insertFault(RMMessageContext rmMsgCtx)
insertFault
in interface IStorageManager
public void addSendMsgNo(java.lang.String seqId, long msgNo)
addSendMsgNo
in interface IStorageManager
public boolean isSentMsg(java.lang.String seqId, long msgNo)
isSentMsg
in interface IStorageManager
public void addOutgoingSequence(java.lang.String sequenceId)
addOutgoingSequence
in interface IStorageManager
public void addIncomingSequence(java.lang.String sequenceId)
addIncomingSequence
in interface IStorageManager
public java.lang.String getOutgoingSeqOfMsg(java.lang.String msgId)
getOutgoingSeqOfMsg
in interface IStorageManager
public void addRequestedSequence(java.lang.String seqId)
addRequestedSequence
in interface IStorageManager
public boolean isRequestedSeqPresent(java.lang.String seqId)
isRequestedSeqPresent
in interface IStorageManager
public java.lang.String getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)
getOutgoingSeqenceIdOfIncomingMsg
in interface IStorageManager
public long getLastIncomingMsgNo(java.lang.String seqId)
getLastIncomingMsgNo
in interface IStorageManager
public boolean hasLastIncomingMsgReceived(java.lang.String seqId)
hasLastIncomingMsgReceived
in interface IStorageManager
public java.lang.String getKeyFromOutgoingSeqId(java.lang.String seqId)
getKeyFromOutgoingSeqId
in interface IStorageManager
public void setAcksTo(java.lang.String seqId, java.lang.String acksTo)
setAcksTo
in interface IStorageManager
public java.lang.String getAcksTo(java.lang.String seqId)
getAcksTo
in interface IStorageManager
public void setCallback(Callback cb)
setCallback
in interface IStorageManager
public void removeCallback()
removeCallback
in interface IStorageManager
public void addOffer(java.lang.String msgID, java.lang.String offerID)
addOffer
in interface IStorageManager
public java.lang.String getOffer(java.lang.String msgID)
getOffer
in interface IStorageManager
public void clearStorage()
clearStorage
in interface IStorageManager
public boolean isSequenceComplete(java.lang.String seqId)
isSequenceComplete
in interface IStorageManager
public void sendAck(java.lang.String sequenceId)
sendAck
in interface IStorageManager
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |