org.apache.sandesha.storage.queue
Class OutgoingSequence
java.lang.Object
org.apache.sandesha.storage.queue.AbstractSequence
org.apache.sandesha.storage.queue.OutgoingSequence
- public class OutgoingSequence
- extends AbstractSequence
This class works as a hash map for storing response messages until they are
sent.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
terminateSent
public boolean terminateSent
OutgoingSequence
public OutgoingSequence(java.lang.String sequenceId)
hasResponse
public boolean hasResponse()
setHasResponse
public void setHasResponse(boolean hasResponse)
isTerminateSent
public boolean isTerminateSent()
setTerminateSent
public void setTerminateSent(boolean terminateSent)
isOutSeqApproved
public boolean isOutSeqApproved()
setOutSeqApproved
public void setOutSeqApproved(boolean b)
getOutSequenceId
public java.lang.String getOutSequenceId()
setOutSequenceId
public void setOutSequenceId(java.lang.String string)
putNewMessage
public java.lang.Object putNewMessage(RMMessageContext msg)
- adds the message to map.
getNextMessageToSend
public RMMessageContext getNextMessageToSend()
- Returns the next deliverable message if has any. Otherwise returns null.
hasMessage
public boolean hasMessage(java.lang.Long key)
clearSequence
public void clearSequence(boolean yes)
getAllKeys
public java.util.Set getAllKeys()
getMessageId
public java.lang.String getMessageId(java.lang.Long key)
deleteMessage
public RMMessageContext deleteMessage(java.lang.Long msgId)
markMessageDeleted
public boolean markMessageDeleted(java.lang.Long messageNo)
nextMessageNumber
public long nextMessageNumber()
isMessagePresent
public boolean isMessagePresent(java.lang.String msgId)
hasMessageWithId
public boolean hasMessageWithId(java.lang.String msgId)
getReceivedMsgNumbers
public java.util.List getReceivedMsgNumbers()
setAckReceived
public void setAckReceived(long msgNo)
isAckComplete
public boolean isAckComplete()
addMsgToSendList
public void addMsgToSendList(long msgNo)
isMsgInSentList
public boolean isMsgInSentList(long msgNo)
hasLastMsgReceived
public boolean hasLastMsgReceived()
getLastMsgNumber
public long getLastMsgNumber()
setLastMsg
public void setLastMsg(long lastMsg)