|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sandesha.client.ClientStorageManager
This is the storage manager for Client side in Sandesha Provides the access points for the SandeshaQueue.
Field Summary | |
protected static Log |
log
|
Constructor Summary | |
ClientStorageManager()
|
Method Summary | |
void |
addAcknowledgement(RMMessageContext rmMessageContext)
SimpleAxisServer will use this method to add acks for the application responses received from the server side. |
void |
addCreateSequenceRequest(RMMessageContext rmMessageContext)
This will be used by the RMSender to add the create sequence request. |
void |
addCreateSequenceResponse(RMMessageContext rmMessageContext)
This will be used both by the Sender and the SimpleAxisServer to set the create sequence responses. |
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)
|
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)
Get a Map of messages. |
long |
getNextMessageNumber(java.lang.String sequenceID)
This will be used by the RMSender when adding messages. |
RMMessageContext |
getNextMessageToProcess(java.lang.Object seq)
|
RMMessageContext |
getNextMessageToSend()
This will be used by the sender. |
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)
Check the existance of a message. |
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 oldSeqId,
java.lang.String newSeqId)
This will be used by the Client Listener and the Sender to set the proper sequenceID |
void |
setCallback(Callback cb)
|
void |
setTemporaryOutSequence(java.lang.String sequenceId,
java.lang.String outSequenceId)
This will be used by the RMSender when adding messages to the Queue. |
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 ClientStorageManager()
Method Detail |
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 getNextMessageToProcess(java.lang.Object seq)
getNextMessageToProcess
in interface IStorageManager
public void setAcknowledged(java.lang.String seqID, long msgNumber)
setAcknowledged
in interface IStorageManager
public void addSequence(java.lang.String sequenceID)
addSequence
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 boolean isMessageExist(java.lang.String sequenceID, long messageNumber)
isMessageExist
in interface IStorageManager
public java.util.Map getListOfMessageNumbers(java.lang.String sequenceID)
getListOfMessageNumbers
in interface IStorageManager
public RMMessageContext getNextMessageToSend()
getNextMessageToSend
in interface IStorageManager
public void setTemporaryOutSequence(java.lang.String sequenceId, java.lang.String outSequenceId)
setTemporaryOutSequence
in interface IStorageManager
public boolean setApprovedOutSequence(java.lang.String oldSeqId, java.lang.String newSeqId)
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 void addOutgoingSequence(java.lang.String sequenceId)
addOutgoingSequence
in interface IStorageManager
public void addIncomingSequence(java.lang.String sequenceId)
addIncomingSequence
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 void addRequestedSequence(java.lang.String seqId)
addRequestedSequence
in interface IStorageManager
public boolean isRequestedSeqPresent(java.lang.String seqId)
isRequestedSeqPresent
in interface IStorageManager
public boolean isSentMsg(java.lang.String seqId, long msgNo)
isSentMsg
in interface IStorageManager
public java.lang.String getOutgoingSeqOfMsg(java.lang.String msgId)
getOutgoingSeqOfMsg
in interface IStorageManager
public java.lang.String getOutgoingSeqenceIdOfIncomingMsg(RMMessageContext msg)
getOutgoingSeqenceIdOfIncomingMsg
in interface IStorageManager
public void setTerminateSend(java.lang.String seqId)
setTerminateSend
in interface IStorageManager
public void setTerminateReceived(java.lang.String seqId)
setTerminateReceived
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 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 setCallback(Callback cb)
setCallback
in interface IStorageManager
public void removeCallback()
removeCallback
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 |