|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sandesha.storage.dao.SandeshaDatabaseDAO
Constructor Summary | |
SandeshaDatabaseDAO(byte endPoint)
|
Method Summary | |
boolean |
addIncomingSequence(java.lang.String sequenceId)
This adds a new entry in the storage to to hold messages of a perticular sequence that come in to the sandesha server/client |
void |
addLowPriorityMessage(RMMessageContext msg)
Adds a low priority message to the storage (e.g. |
boolean |
addMessageToIncomingSequence(java.lang.String sequenceId,
java.lang.Long msgNo,
RMMessageContext rmMessageContext)
This adds a incoming message to a area belonging to the given sequence in the queue. |
boolean |
addMessageToOutgoingSequence(java.lang.String sequenceId,
RMMessageContext rmMessageContext)
This adds the given message to the given sequence. |
void |
addOffer(java.lang.String msgID,
java.lang.String offerID)
Sets the offered incoming sequence, of a outgoing sequence. |
boolean |
addOutgoingSequence(java.lang.String sequenceId)
This adds a entry in the storage for holding the messages of the given outgoing sequence. |
boolean |
addPriorityMessage(RMMessageContext message)
Adds a priority message (e.g. |
void |
addRequestedSequence(java.lang.String seqId)
When a server or client sends a create sequence, it will be marked from this method. |
void |
addSendMsgNo(java.lang.String seqId,
long msgNo)
The message will be added to a sent list (the list holds the messages that were sent at least once) |
RMMessageContext |
checkForResponseMessage(java.lang.String requestId,
java.lang.String seqId)
When the messageId of therequest message (e.g. |
void |
clear()
clears the storage. |
java.lang.String |
getAcksTo(java.lang.String seqId)
gets the acksTo value |
java.util.Set |
getAllReceivedMsgNumsOfIncomingSeq(java.lang.String sequenceId)
This reutns a set of message numbers with all the message numbers of incoming sequence. |
java.lang.String |
getKeyFromIncomingSequenceId(java.lang.String incomingSeqID)
The client side will not be able to have sequenceId as a key for storing request messages. |
java.lang.String |
getKeyFromOutgoingSequenceId(java.lang.String outgoingSeqID)
This asks for the above key (the key used to hold messages) given the outgoing sequece id. |
long |
getLastIncomingMsgNo(java.lang.String seqId)
Asks for the last message of the incoming sequence (if it has been received) |
RMMessageContext |
getNextLowPriorityMessageContextToSend()
Asks the storage for the next low priority message (if there is any) |
RMMessageContext |
getNextMsgContextToProcess(java.lang.Object seq)
This tries to get the next message to be sent from the given outgoing sequence If these is no message to be sent in the given sequence, null will be returned. |
long |
getNextOutgoingMessageNumber(java.lang.String sequenceId)
This gives the next message number, outgoing storage of the given sequence esxpects. |
RMMessageContext |
getNextOutgoingMsgContextToSend()
Gets the next possible message to be sent from the queue. |
RMMessageContext |
getNextPriorityMessageContextToSend()
This checks the priority messages to see weather there is any one to be sent (either for the first time or a retransmission) |
java.lang.String |
getOffer(java.lang.String msgID)
Gets the offered incoming sequence, of outgoing sequence. |
java.lang.Object |
getRandomSeqToProcess()
|
java.lang.String |
getSequenceOfOutSequence(java.lang.String outsequenceId)
this gives the seqId which is used to hold the messages of which the outsequence entry has been set to the value outsequenceId. |
boolean |
hasLastIncomingMsgReceived(java.lang.String seqId)
Can be used to ckeck weather the last message has been received in the incoming sequence. |
boolean |
isAllIncommingTerminateReceived()
Use this to check weather the terminate message of all sequences (incoming) has been received. |
boolean |
isAllOutgoingTerminateSent()
Checks weather the terminate message of all out going sequences have been sent. |
boolean |
isIncomingMessageExists(java.lang.String sequenceId,
java.lang.Long msgNo)
This checks in the given incoming sequence to see weather a message of the given message no exists |
boolean |
isIncomingSequenceExists(java.lang.String sequenceId)
This checks weather there is a entry for the given incoming sequence in the queue. |
boolean |
isIncommingTerminateReceived(java.lang.String seqId)
|
boolean |
isOutgoingSequenceExists(java.lang.String sequenceId)
Checks weather a entry for the given outgoing sequence exists in the queue. |
boolean |
isOutgoingTerminateSent(java.lang.String seqId)
|
boolean |
isRequestedSeqPresent(java.lang.String seqId)
Check weather the given sequence id is one of the requested once (see 'addRequestedSequence') |
boolean |
isSentMsg(java.lang.String seqId,
long msgNo)
Asks from the storage weather the given message has been sent at least once |
void |
markOutgoingMessageToDelete(java.lang.String sequenceId,
java.lang.Long msgNumber)
This outgoing message will be marked as deleted. |
void |
removeAllAcks(java.lang.String sequenceID)
|
void |
removeCreateSequenceMsg(java.lang.String messageId)
This checks the priority queue for a message if given messageid and moves it to the bin |
java.lang.String |
searchForSequenceId(java.lang.String messageId)
Tries to give the sequence id of the outgoing message with the given message id |
void |
sendAck(java.lang.String sequenceId)
|
void |
setAckReceived(java.lang.String seqId,
long msgNo)
Tells to the rtorage that the given message of given sequence was acked. |
void |
setAcksTo(java.lang.String seqId,
java.lang.String acksTo)
Set the acks to of the given sequence. |
void |
setOutSequence(java.lang.String sequenceId,
java.lang.String outSequenceId)
This sets the outgoing sequence. |
void |
setOutSequenceApproved(java.lang.String sequenceID,
boolean approved)
This sets a flag in the queue to indicate that the outSequence of the perticular message set (stored with the id seqId) has been set correctly. |
void |
setTerminateReceived(java.lang.String seqId)
Sets a incoming sequence of messages as terminate received. |
void |
setTerminateSend(java.lang.String seqId)
Sets this after sending the terminate sequence message. |
void |
updateFinalMessageArrivedTime(java.lang.String sequenceID)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SandeshaDatabaseDAO(byte endPoint)
Method Detail |
public boolean addIncomingSequence(java.lang.String sequenceId)
ISandeshaDAO
addIncomingSequence
in interface ISandeshaDAO
public boolean addOutgoingSequence(java.lang.String sequenceId)
ISandeshaDAO
addOutgoingSequence
in interface ISandeshaDAO
public boolean addPriorityMessage(RMMessageContext message)
ISandeshaDAO
addPriorityMessage
in interface ISandeshaDAO
public RMMessageContext getNextPriorityMessageContextToSend()
ISandeshaDAO
getNextPriorityMessageContextToSend
in interface ISandeshaDAO
public boolean addMessageToIncomingSequence(java.lang.String sequenceId, java.lang.Long msgNo, RMMessageContext rmMessageContext)
ISandeshaDAO
addMessageToIncomingSequence
in interface ISandeshaDAO
public boolean addMessageToOutgoingSequence(java.lang.String sequenceId, RMMessageContext rmMessageContext)
ISandeshaDAO
addMessageToOutgoingSequence
in interface ISandeshaDAO
public boolean isIncomingSequenceExists(java.lang.String sequenceId)
ISandeshaDAO
isIncomingSequenceExists
in interface ISandeshaDAO
public boolean isOutgoingSequenceExists(java.lang.String sequenceId)
ISandeshaDAO
isOutgoingSequenceExists
in interface ISandeshaDAO
public boolean isIncomingMessageExists(java.lang.String sequenceId, java.lang.Long msgNo)
ISandeshaDAO
isIncomingMessageExists
in interface ISandeshaDAO
public RMMessageContext getNextMsgContextToProcess(java.lang.Object seq)
ISandeshaDAO
getNextMsgContextToProcess
in interface ISandeshaDAO
public RMMessageContext getNextOutgoingMsgContextToSend()
ISandeshaDAO
getNextOutgoingMsgContextToSend
in interface ISandeshaDAO
public java.lang.Object getRandomSeqToProcess()
getRandomSeqToProcess
in interface ISandeshaDAO
public java.util.Set getAllReceivedMsgNumsOfIncomingSeq(java.lang.String sequenceId)
ISandeshaDAO
getAllReceivedMsgNumsOfIncomingSeq
in interface ISandeshaDAO
public void setOutSequence(java.lang.String sequenceId, java.lang.String outSequenceId)
ISandeshaDAO
setOutSequence
in interface ISandeshaDAO
public void setOutSequenceApproved(java.lang.String sequenceID, boolean approved)
ISandeshaDAO
setOutSequenceApproved
in interface ISandeshaDAO
public java.lang.String getSequenceOfOutSequence(java.lang.String outsequenceId)
ISandeshaDAO
getSequenceOfOutSequence
in interface ISandeshaDAO
public void removeCreateSequenceMsg(java.lang.String messageId)
ISandeshaDAO
removeCreateSequenceMsg
in interface ISandeshaDAO
public long getNextOutgoingMessageNumber(java.lang.String sequenceId)
ISandeshaDAO
getNextOutgoingMessageNumber
in interface ISandeshaDAO
public RMMessageContext checkForResponseMessage(java.lang.String requestId, java.lang.String seqId)
ISandeshaDAO
checkForResponseMessage
in interface ISandeshaDAO
public java.lang.String searchForSequenceId(java.lang.String messageId)
ISandeshaDAO
searchForSequenceId
in interface ISandeshaDAO
public void markOutgoingMessageToDelete(java.lang.String sequenceId, java.lang.Long msgNumber)
ISandeshaDAO
markOutgoingMessageToDelete
in interface ISandeshaDAO
public void setAckReceived(java.lang.String seqId, long msgNo)
ISandeshaDAO
setAckReceived
in interface ISandeshaDAO
public void addLowPriorityMessage(RMMessageContext msg)
ISandeshaDAO
addLowPriorityMessage
in interface ISandeshaDAO
public RMMessageContext getNextLowPriorityMessageContextToSend()
ISandeshaDAO
getNextLowPriorityMessageContextToSend
in interface ISandeshaDAO
public void addSendMsgNo(java.lang.String seqId, long msgNo)
ISandeshaDAO
addSendMsgNo
in interface ISandeshaDAO
public boolean isSentMsg(java.lang.String seqId, long msgNo)
ISandeshaDAO
isSentMsg
in interface ISandeshaDAO
public boolean hasLastIncomingMsgReceived(java.lang.String seqId)
ISandeshaDAO
hasLastIncomingMsgReceived
in interface ISandeshaDAO
public long getLastIncomingMsgNo(java.lang.String seqId)
ISandeshaDAO
getLastIncomingMsgNo
in interface ISandeshaDAO
public void addRequestedSequence(java.lang.String seqId)
ISandeshaDAO
addRequestedSequence
in interface ISandeshaDAO
public boolean isRequestedSeqPresent(java.lang.String seqId)
ISandeshaDAO
isRequestedSeqPresent
in interface ISandeshaDAO
public java.lang.String getKeyFromIncomingSequenceId(java.lang.String incomingSeqID)
ISandeshaDAO
getKeyFromIncomingSequenceId
in interface ISandeshaDAO
public java.lang.String getKeyFromOutgoingSequenceId(java.lang.String outgoingSeqID)
ISandeshaDAO
getKeyFromOutgoingSequenceId
in interface ISandeshaDAO
public void setTerminateSend(java.lang.String seqId)
ISandeshaDAO
setTerminateSend
in interface ISandeshaDAO
public void setTerminateReceived(java.lang.String seqId)
ISandeshaDAO
setTerminateReceived
in interface ISandeshaDAO
public boolean isAllOutgoingTerminateSent()
ISandeshaDAO
isAllOutgoingTerminateSent
in interface ISandeshaDAO
public boolean isAllIncommingTerminateReceived()
ISandeshaDAO
isAllIncommingTerminateReceived
in interface ISandeshaDAO
public void setAcksTo(java.lang.String seqId, java.lang.String acksTo)
ISandeshaDAO
setAcksTo
in interface ISandeshaDAO
public java.lang.String getAcksTo(java.lang.String seqId)
ISandeshaDAO
getAcksTo
in interface ISandeshaDAO
public void addOffer(java.lang.String msgID, java.lang.String offerID)
ISandeshaDAO
addOffer
in interface ISandeshaDAO
public java.lang.String getOffer(java.lang.String msgID)
ISandeshaDAO
getOffer
in interface ISandeshaDAO
public void clear()
ISandeshaDAO
clear
in interface ISandeshaDAO
public boolean isOutgoingTerminateSent(java.lang.String seqId)
isOutgoingTerminateSent
in interface ISandeshaDAO
public boolean isIncommingTerminateReceived(java.lang.String seqId)
isIncommingTerminateReceived
in interface ISandeshaDAO
public void updateFinalMessageArrivedTime(java.lang.String sequenceID)
updateFinalMessageArrivedTime
in interface ISandeshaDAO
public void sendAck(java.lang.String sequenceId)
sendAck
in interface ISandeshaDAO
public void removeAllAcks(java.lang.String sequenceID)
removeAllAcks
in interface ISandeshaDAO
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |