ExecutionServiceTimeout(interval: Long, timeUnit: TimeUnit)
Settings for the Execution Service timeout. Once a deduper has published all data to the blocking queues of all consumers, consumers will have a dynamic timeout set (defaults to 60 seconds) for all consumers to finish persisting data