Modifier and Type | Method and Description |
---|---|
static QueueOptions.Builder |
QueueOptions.builder()
Returns a helper class object to create immutable
QueueOptions with custom settings. |
QueueOptions.Builder |
QueueOptions.Builder.merge(QueueOptions options)
"Merges" another 'QueueOptions' into this builder, by invoking setF(options.getF()) for
all fields 'F' for which 'options.hasF()' is true.
|
QueueOptions.Builder |
QueueOptions.Builder.setConsumerPriority(int consumerPriority)
Sets priority of a consumer with respect to delivery of messages.
|
QueueOptions.Builder |
QueueOptions.Builder.setMaxUnconfirmedBytes(long maxUnconfirmedBytes)
Sets maximum accumulated bytes of all outstanding messages that can be sent by the broker
without being confirmed.
|
QueueOptions.Builder |
QueueOptions.Builder.setMaxUnconfirmedMessages(long maxUnconfirmedMessages)
Sets maximum number of outstanding messages that can be sent by the broker without being
confirmed.
|
QueueOptions.Builder |
QueueOptions.Builder.setSuspendsOnBadHostHealth(boolean suspendsOnBadHostHealth)
Sets whether queue should suspend when the host machine is unhealthy.
|
Copyright © 2023 Bloomberg L.P.. All rights reserved.