BufferedBatchPublisher.Builder |
BufferedBatchPublisher.Builder.autoFlush(boolean autoFlush) |
Whether events to should be automatically flushed on shutdown.
|
BufferedBatchPublisher.Builder |
BufferedBatchPublisher.Builder.averagePerEventPayloadSize(int averagePerEventPayloadSize) |
Sets the average event payload size, used to initialise string buffers.
|
BufferedBatchPublisher.Builder |
BufferedBatchPublisher.Builder.capacity(int capacity) |
Sets the maximum queue capacity.
|
BufferedBatchPublisher.Builder |
BufferedBatchPublisher.Builder.maxBatchEvents(int maxBatchedEvents) |
Sets the maximum number of events in a given batch.
|
BufferedBatchPublisher.Builder |
BatchPublisherFactory.newBufferedPublisher(BatchConsumer consumer) |
Provides a new instance of a buffered batch publisher.
|
BufferedBatchPublisher.Builder |
BatchPublisherFactoryImpl.newBufferedPublisher(BatchConsumer consumer) |
|
static BufferedBatchPublisher.Builder |
BufferedBatchPublisher.newBuilder(BatchConsumer batchConsumer) |
Provides a new builder.
|
BufferedBatchPublisher.Builder |
BufferedBatchPublisher.Builder.writeInterval(Duration writeInterval) |
The interval duration between each write.
|