public class SequencedQueue extends BoundedWorkQueue
Modifier and Type | Field and Description |
---|---|
protected java.util.ArrayList |
statusCbL |
cpm, numberElementsInQueue, queue, queueMaxSize, queueName, WAIT_TIMEOUT
Constructor and Description |
---|
SequencedQueue(int aQueueSize,
java.lang.String aQueueName,
CPMEngine aCpmEngine)
Initialize this queue
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
dequeue()
Removes an object from the front of the queue according to FIFO model.
|
java.lang.Object |
dequeue(long aTimeout)
Returns an object from the queue.
|
protected void |
doNotifyListeners(java.lang.Object aCas,
EntityProcessStatus aEntityProcStatus)
Notifies all configured listeners.
|
void |
invalidate(CAS[] aCasObjectList) |
enqueue, getCapacity, getCurrentSize, getName
public SequencedQueue(int aQueueSize, java.lang.String aQueueName, CPMEngine aCpmEngine)
aQueueSize
- -
the size of the queueaQueueName
- -
the name of the queueaCpmEngine
- -
reference to the CPEpublic java.lang.Object dequeue()
dequeue
in class BoundedWorkQueue
public java.lang.Object dequeue(long aTimeout)
dequeue
in class BoundedWorkQueue
aTimeout
- -
max millis to wait for an objectpublic void invalidate(CAS[] aCasObjectList)
invalidate
in class BoundedWorkQueue
protected void doNotifyListeners(java.lang.Object aCas, EntityProcessStatus aEntityProcStatus)
aCas
- -
Cas to pass to listenerisCasObject
- -
true is Cas is of type CASaEntityProcStatus
- -
status object containing exceptions and trace infoCopyright © 2013. All Rights Reserved.