org.apache.sandesha.storage.queue
Class IncomingSequence

java.lang.Object
  extended byorg.apache.sandesha.storage.queue.AbstractSequence
      extended byorg.apache.sandesha.storage.queue.IncomingSequence

public class IncomingSequence
extends AbstractSequence

Author:
Chamikara Jayalath, Jaliya Ekanayaka

Field Summary
 
Fields inherited from class org.apache.sandesha.storage.queue.AbstractSequence
sequenceId
 
Constructor Summary
IncomingSequence(java.lang.String sequenceId)
           
 
Method Summary
 void clearSequence(boolean yes)
           
 java.util.Set getAllKeys()
           
 long getFinalAckedTime()
           
 long getFinalMsgArrivedTime()
           
 long getLastMsgNumber()
           
 java.lang.String getMessageId(java.lang.Long key)
           
 RMMessageContext getMessageRelatingTo(java.lang.String relatesTo)
           
 java.util.List getNextMessagesToProcess()
           
 RMMessageContext getNextMessageToProcess()
           
 boolean hasLastMsgReceived()
           
 boolean hasMessage(java.lang.Long msgId)
           
 boolean hasProcessableMessages()
           
 boolean isSendAck()
           
 boolean isSequenceLocked()
           
 boolean isTerminateReceived()
           
 java.lang.Object putNewMessage(java.lang.Long key, RMMessageContext value)
          adds the message to map.
 void setFinalAckedTime(long finalAckedTime)
           
 void setFinalMsgArrivedTime(long finalMsgArrivedTime)
           
 void setLastMsg(long lastMsg)
           
 void setProcessLock(boolean lock)
           
 void setSendAck(boolean sendAck)
           
 void setTerminateReceived(boolean terminateReceived)
           
 
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
 

Constructor Detail

IncomingSequence

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

getFinalAckedTime

public long getFinalAckedTime()

setFinalAckedTime

public void setFinalAckedTime(long finalAckedTime)

getFinalMsgArrivedTime

public long getFinalMsgArrivedTime()

setFinalMsgArrivedTime

public void setFinalMsgArrivedTime(long finalMsgArrivedTime)

isSendAck

public boolean isSendAck()

setSendAck

public void setSendAck(boolean sendAck)

isTerminateReceived

public boolean isTerminateReceived()

setTerminateReceived

public void setTerminateReceived(boolean terminateReceived)

hasProcessableMessages

public boolean hasProcessableMessages()

putNewMessage

public java.lang.Object putNewMessage(java.lang.Long key,
                                      RMMessageContext value)
adds the message to map. Also adds a record to cache if needed.


getNextMessageToProcess

public RMMessageContext getNextMessageToProcess()

getNextMessagesToProcess

public java.util.List getNextMessagesToProcess()

hasMessage

public boolean hasMessage(java.lang.Long msgId)

clearSequence

public void clearSequence(boolean yes)

getAllKeys

public java.util.Set getAllKeys()

setProcessLock

public void setProcessLock(boolean lock)

isSequenceLocked

public boolean isSequenceLocked()

getMessageId

public java.lang.String getMessageId(java.lang.Long key)

getMessageRelatingTo

public RMMessageContext getMessageRelatingTo(java.lang.String relatesTo)

hasLastMsgReceived

public boolean hasLastMsgReceived()

getLastMsgNumber

public long getLastMsgNumber()

setLastMsg

public void setLastMsg(long lastMsg)