won.utils.batch

Class BatchingConsumer.Config

java.lang.Object

won.utils.batch.BatchingConsumer.Config

Enclosing class:

BatchingConsumer<K,I>

public static class BatchingConsumer.Config
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Optional<java.lang.Boolean>	consumeFirst
java.util.Optional<java.time.Duration>	maxBatchAge
java.util.Optional<java.lang.Integer>	maxBatchSize
java.util.Optional<java.time.Duration>	maxItemInterval
java.util.Optional<java.time.Duration>	minChunkInterval

Constructor Summary

Constructors

Constructor and Description
Config(java.util.Optional<java.time.Duration> maxBatchAge, java.util.Optional<java.time.Duration> minChunkInterval, java.util.Optional<java.time.Duration> maxItemInterval, java.util.Optional<java.lang.Boolean> consumeFirst, java.util.Optional<java.lang.Integer> maxBatchSize)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

maxBatchAge

public final java.util.Optional<java.time.Duration> maxBatchAge

maxItemInterval

public final java.util.Optional<java.time.Duration> maxItemInterval

consumeFirst

public final java.util.Optional<java.lang.Boolean> consumeFirst

minChunkInterval

public final java.util.Optional<java.time.Duration> minChunkInterval

maxBatchSize

public final java.util.Optional<java.lang.Integer> maxBatchSize

Constructor Detail

Config

public Config(java.util.Optional<java.time.Duration> maxBatchAge,
              java.util.Optional<java.time.Duration> minChunkInterval,
              java.util.Optional<java.time.Duration> maxItemInterval,
              java.util.Optional<java.lang.Boolean> consumeFirst,
              java.util.Optional<java.lang.Integer> maxBatchSize)