Converted TimeBatcher to constantly poll for data.  This is to get around an issue where a maxqueue size was used, so all producers are stuck waiting until the queue gets drained.