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()