|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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)
|
Method Detail |
public boolean addIncomingSequence(java.lang.String sequenceId)
public boolean addOutgoingSequence(java.lang.String sequenceId)
public boolean addPriorityMessage(RMMessageContext message)
public RMMessageContext getNextPriorityMessageContextToSend()
public boolean addMessageToIncomingSequence(java.lang.String sequenceId, java.lang.Long msgNo, RMMessageContext rmMessageContext)
public boolean addMessageToOutgoingSequence(java.lang.String sequenceId, RMMessageContext rmMessageContext)
public boolean isIncomingSequenceExists(java.lang.String sequenceId)
public boolean isOutgoingSequenceExists(java.lang.String sequenceId)
public boolean isIncomingMessageExists(java.lang.String sequenceId, java.lang.Long msgNo)
public RMMessageContext getNextMsgContextToProcess(java.lang.Object seq)
public RMMessageContext getNextOutgoingMsgContextToSend()
public java.lang.Object getRandomSeqToProcess()
public java.util.Set getAllReceivedMsgNumsOfIncomingSeq(java.lang.String sequenceId)
public void setOutSequence(java.lang.String sequenceId, java.lang.String outSequenceId)
public void setOutSequenceApproved(java.lang.String sequenceID, boolean approved)
public java.lang.String getSequenceOfOutSequence(java.lang.String outsequenceId)
public void removeCreateSequenceMsg(java.lang.String messageId)
public long getNextOutgoingMessageNumber(java.lang.String sequenceId)
public RMMessageContext checkForResponseMessage(java.lang.String requestId, java.lang.String seqId)
public java.lang.String searchForSequenceId(java.lang.String messageId)
public void markOutgoingMessageToDelete(java.lang.String sequenceId, java.lang.Long msgNumber)
public void setAckReceived(java.lang.String seqId, long msgNo)
public void addLowPriorityMessage(RMMessageContext msg)
public RMMessageContext getNextLowPriorityMessageContextToSend()
public void addSendMsgNo(java.lang.String seqId, long msgNo)
public boolean isSentMsg(java.lang.String seqId, long msgNo)
public boolean hasLastIncomingMsgReceived(java.lang.String seqId)
public long getLastIncomingMsgNo(java.lang.String seqId)
public void addRequestedSequence(java.lang.String seqId)
public boolean isRequestedSeqPresent(java.lang.String seqId)
public java.lang.String getKeyFromIncomingSequenceId(java.lang.String incomingSeqID)
public java.lang.String getKeyFromOutgoingSequenceId(java.lang.String outgoingSeqID)
public void setTerminateSend(java.lang.String seqId)
public void setTerminateReceived(java.lang.String seqId)
public boolean isAllOutgoingTerminateSent()
public boolean isAllIncommingTerminateReceived()
public void setAcksTo(java.lang.String seqId, java.lang.String acksTo)
public java.lang.String getAcksTo(java.lang.String seqId)
public void addOffer(java.lang.String msgID, java.lang.String offerID)
public java.lang.String getOffer(java.lang.String msgID)
public void clear()
public boolean isOutgoingTerminateSent(java.lang.String seqId)
public boolean isIncommingTerminateReceived(java.lang.String seqId)
public void updateFinalMessageArrivedTime(java.lang.String sequenceID)
public void sendAck(java.lang.String sequenceId)
public void removeAllAcks(java.lang.String sequenceID)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |