QueueHandler

HTTPSource

queue

BatchIterator DynamicBufferedBatcher FixedBufferedBatcher