public class SequencedQueue extends BoundedWorkQueue
Modifier and Type | Field and Description |
---|---|
protected ArrayList |
statusCbL |
cpm, numberElementsInQueue, queue, queueMaxSize, queueName, WAIT_TIMEOUT
Constructor and Description |
---|
SequencedQueue(int aQueueSize,
String aQueueName,
CPMEngine aCpmEngine)
Initialize this queue
|
Modifier and Type | Method and Description |
---|---|
Object |
dequeue()
Removes an object from the front of the queue according to FIFO model.
|
Object |
dequeue(long aTimeout)
Returns an object from the queue.
|
protected void |
doNotifyListeners(Object aCas,
EntityProcessStatus aEntityProcStatus)
Notifies all configured listeners.
|
void |
invalidate(CAS[] aCasObjectList) |
enqueue, getCapacity, getCurrentSize, getName
protected ArrayList statusCbL
public Object dequeue()
dequeue
in class BoundedWorkQueue
public 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(Object aCas, EntityProcessStatus aEntityProcStatus)
aCas
- -
Cas to pass to listeneraEntityProcStatus
- -
status object containing exceptions and trace infoCopyright © 2006–2016 The Apache Software Foundation. All rights reserved.