public static class QueueSharderPolicies.Builder extends Object
Modifier and Type | Method and Description |
---|---|
QueueSharderPolicies |
build() |
QueueSharderPolicies.Builder |
maxQueues(int maxQueues)
Change the maximum number of queues to create.
|
QueueSharderPolicies.Builder |
newQueueThreshold(int newQueueThreshold)
Change the queue threshold.
|
QueueSharderPolicies.Builder |
threadFactory(ThreadFactory threadFactory)
Change the thread factory that's used to create the sharder's thread
|
QueueSharderPolicies.Builder |
thresholdCheckMs(int thresholdCheckMs)
Change the threshold check.
|
public QueueSharderPolicies.Builder newQueueThreshold(int newQueueThreshold)
QueueSharderPolicies.DEFAULT_QUEUE_THRESHOLD
newQueueThreshold
- new valuepublic QueueSharderPolicies.Builder thresholdCheckMs(int thresholdCheckMs)
QueueSharderPolicies.DEFAULT_THRESHOLD_CHECK_MS
thresholdCheckMs
- period in millisecondspublic QueueSharderPolicies.Builder maxQueues(int maxQueues)
QueueSharderPolicies.DEFAULT_MAX_QUEUES
maxQueues
- the new maxpublic QueueSharderPolicies.Builder threadFactory(ThreadFactory threadFactory)
threadFactory
- new factorypublic QueueSharderPolicies build()
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.