queueReader
is a worker that reads raw batches (satisfying the
-queue.Batch
interface, in this case via proxyqueue.batch
)
-from the queue, wraps them in a publisher.Batch
interface
-(ttlBatch
) to support pipeline operations like retry/error
-handling, and hands them off to eventConsumer
which
-distributes them to output workers.
-