public void put(ReplDBMSEvent event) throws InterruptedException, ReplicatorException {
  queue.put(event);
  transactionCount++;
  if (logger.isDebugEnabled()) {
    if (transactionCount % 10000 == 0)     logger.debug("Queue store: xacts=" + transactionCount + " size="+ queue.size());
  }
}

public void put ( ReplDBMSEvent event ) throws InterruptedException , ReplicatorException { queue . put ( event ) ; transactionCount ++ ; if ( logger . isDebugEnabled ( ) ) { if ( transactionCount % 10000 == 0 ) logger . debug ( "Queue store: xacts=" + transactionCount + " size=" + queue . size ( ) ) ; } }
puts an event in the queue , blocking if it is full .
