org.apache.sandesha.storage.queue
Class OutgoingSequence

java.lang.Object
  extended byorg.apache.sandesha.storage.queue.AbstractSequence
      extended byorg.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.


Field Summary
 boolean terminateSent
           
 
Fields inherited from class org.apache.sandesha.storage.queue.AbstractSequence
sequenceId
 
Constructor Summary
OutgoingSequence(java.lang.String sequenceId)
           
 
Method Summary
 void addMsgToSendList(long msgNo)
           
 void clearSequence(boolean yes)
           
 RMMessageContext deleteMessage(java.lang.Long msgId)
           
 java.util.Set getAllKeys()
           
 long getLastMsgNumber()
           
 java.lang.String getMessageId(java.lang.Long key)
           
 RMMessageContext getNextMessageToSend()
          Returns the next deliverable message if has any.
 java.lang.String getOutSequenceId()
           
 java.util.List getReceivedMsgNumbers()
           
 boolean hasLastMsgReceived()
           
 boolean hasMessage(java.lang.Long key)
           
 boolean hasMessageWithId(java.lang.String msgId)
           
 boolean hasResponse()
           
 boolean isAckComplete()
           
 boolean isMessagePresent(java.lang.String msgId)
           
 boolean isMsgInSentList(long msgNo)
           
 boolean isOutSeqApproved()
           
 boolean isTerminateSent()
           
 boolean markMessageDeleted(java.lang.Long messageNo)
           
 long nextMessageNumber()
           
 java.lang.Object putNewMessage(RMMessageContext msg)
          adds the message to map.
 void setAckReceived(long msgNo)
           
 void setHasResponse(boolean hasResponse)
           
 void setLastMsg(long lastMsg)
           
 void setOutSeqApproved(boolean b)
           
 void setOutSequenceId(java.lang.String string)
           
 void setTerminateSent(boolean terminateSent)
           
 
Methods inherited from class org.apache.sandesha.storage.queue.AbstractSequence
getSequenceId, setSequenceId
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

terminateSent

public boolean terminateSent
Constructor Detail

OutgoingSequence

public OutgoingSequence(java.lang.String sequenceId)
Method Detail

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)