public class PublishQueue<T extends PublishedPointVO>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private PublisherRT<T> |
owner |
protected java.util.LinkedList<PublishQueueEntry<T>> |
queue |
private boolean |
warningActive |
private int |
warningSize |
Constructor and Description |
---|
PublishQueue(PublisherRT<T> owner,
int warningSize) |
Modifier and Type | Method and Description |
---|---|
void |
add(T vo,
java.util.List<PointValueTime> pvts) |
void |
add(T vo,
PointValueTime pvt) |
java.util.List<PublishQueueEntry<T>> |
get(int max) |
int |
getSize() |
PublishQueueEntry<T> |
next() |
void |
remove(PublishQueueEntry<T> e) |
private void |
sizeCheck() |
protected final java.util.LinkedList<PublishQueueEntry<T extends PublishedPointVO>> queue
private final PublisherRT<T extends PublishedPointVO> owner
private final int warningSize
private boolean warningActive
public PublishQueue(PublisherRT<T> owner, int warningSize)
public void add(T vo, PointValueTime pvt)
public void add(T vo, java.util.List<PointValueTime> pvts)
public PublishQueueEntry<T> next()
public java.util.List<PublishQueueEntry<T>> get(int max)
public void remove(PublishQueueEntry<T> e)
public int getSize()
private void sizeCheck()