public static interface BufferedBatchPublisher.Builder
BufferedBatchPublisher
.Modifier and Type | Method and Description |
---|---|
BufferedBatchPublisher.Builder |
autoFlush(boolean autoFlush)
Whether events to should be automatically flushed on shutdown.
|
BufferedBatchPublisher.Builder |
averagePerEventPayloadSize(int averagePerEventPayloadSize)
Sets the average event payload size, used to initialise string buffers.
|
BatchPublisher |
build()
Constructs a new
BatchPublisher . |
BufferedBatchPublisher.Builder |
capacity(int capacity)
Sets the maximum queue capacity.
|
BufferedBatchPublisher.Builder |
maxBatchEvents(int maxBatchedEvents)
Sets the maximum number of events in a given batch.
|
BufferedBatchPublisher.Builder |
writeInterval(Duration writeInterval)
The interval duration between each write.
|
BufferedBatchPublisher.Builder capacity(int capacity)
capacity
- queue capacityBufferedBatchPublisher.Builder maxBatchEvents(int maxBatchedEvents)
maxBatchedEvents
- maximum number of batched eventsBufferedBatchPublisher.Builder averagePerEventPayloadSize(int averagePerEventPayloadSize)
averagePerEventPayloadSize
- average event payload sizeBufferedBatchPublisher.Builder writeInterval(Duration writeInterval)
writeInterval
- write intervalBufferedBatchPublisher.Builder autoFlush(boolean autoFlush)
autoFlush
- whether to auto flushBatchPublisher build()
BatchPublisher
.BatchPublisher
Copyright 2010-2022 ForgeRock AS.