public THLParallelReadQueue(int taskId,int maxSize,int maxControlEvents,long startingSeqno,int syncInterval,ReplDBMSHeader lastHeader,AtomicIntervalGuard<?> intervalGuard){
  this.taskId=taskId;
  this.readSeqno=startingSeqno;
  this.syncInterval=syncInterval;
  this.intervalGuard=intervalGuard;
  this.eventQueue=new LinkedBlockingQueue<ReplEvent>(maxSize);
  this.watchPredicates=new LinkedList<WatchPredicate<ReplDBMSHeader>>();
  this.controlQueue=new LinkedList<ReplControlEvent>();
  if (lastHeader == null) {
    this.lastHeader=new ReplDBMSHeaderData(startingSeqno - 1,(short)0,true,"dummy",-1,"dummy","dummy",new Timestamp(System.currentTimeMillis()),0);
  }
 else {
    this.lastHeader=lastHeader;
  }
}

public THLParallelReadQueue ( int taskId , int maxSize , int maxControlEvents , long startingSeqno , int syncInterval , ReplDBMSHeader lastHeader , AtomicIntervalGuard < ? > intervalGuard ) { this . taskId = taskId ; this . readSeqno = startingSeqno ; this . syncInterval = syncInterval ; this . intervalGuard = intervalGuard ; this . eventQueue = new LinkedBlockingQueue < ReplEvent > ( maxSize ) ; this . watchPredicates = new LinkedList < WatchPredicate < ReplDBMSHeader > > ( ) ; this . controlQueue = new LinkedList < ReplControlEvent > ( ) ; if ( lastHeader == null ) { this . lastHeader = new ReplDBMSHeaderData ( startingSeqno - 1 , ( short ) 0 , true , "dummy" , - 1 , "dummy" , "dummy" , new Timestamp ( System . currentTimeMillis ( ) ) , 0 ) ; } else { this . lastHeader = lastHeader ; } }
instantiates a new read queue .
