org.apache.sandesha.storage.queue
Class IncomingSequence
java.lang.Object
org.apache.sandesha.storage.queue.AbstractSequence
org.apache.sandesha.storage.queue.IncomingSequence
- public class IncomingSequence
- extends AbstractSequence
- Author:
- Chamikara Jayalath, Jaliya Ekanayaka
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IncomingSequence
public IncomingSequence(java.lang.String sequenceId)
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)