org.edg.info
Class QueueEntry

java.lang.Object
  extended byorg.edg.info.QueueEntry

public class QueueEntry
extends java.lang.Object

Represents a tuple in a memory queue. As well as the tuple also contains a flag which indicates whether the tuple has had a chance to be streamed or not


Constructor Summary
QueueEntry(Tuple tuple)
           
 
Method Summary
 Tuple getTuple()
           
 boolean hasBeenStreamed()
          Returns whether this tuple has had its chance to be streamed.
 void setStreamed()
          Set the flag to indicate that this tuple has had a chance to be streamed
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

QueueEntry

public QueueEntry(Tuple tuple)
Method Detail

getTuple

public Tuple getTuple()

hasBeenStreamed

public boolean hasBeenStreamed()
Returns whether this tuple has had its chance to be streamed. If it's been hanging around for more than MAX_AGE_MILLIS it is automatically assumed to have had a chance.


setStreamed

public void setStreamed()
Set the flag to indicate that this tuple has had a chance to be streamed