com.bloomberg.bmq

Class QueueOptions.Builder

java.lang.Object

com.bloomberg.bmq.QueueOptions.Builder

Enclosing class:

QueueOptions

public static class QueueOptions.Builder
extends Object

A helper class to create immutable QueueOptions with custom settings.

Method Summary

Modifier and Type	Method and Description
QueueOptions	build() Returns queue options based on this object properties.
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	setConsumerPriority(int consumerPriority) Sets priority of a consumer with respect to delivery of messages.
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	setMaxUnconfirmedMessages(long maxUnconfirmedMessages) Sets maximum number of outstanding messages that can be sent by the broker without being confirmed.
QueueOptions.Builder	setSuspendsOnBadHostHealth(boolean suspendsOnBadHostHealth) Sets whether queue should suspend when the host machine is unhealthy.

Methods inherited from class java.lang.Object

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

Method Detail

build

public QueueOptions build()

Returns queue options based on this object properties.

Returns:

QueueOptions immutable queue option object

setMaxUnconfirmedMessages

public QueueOptions.Builder setMaxUnconfirmedMessages(long maxUnconfirmedMessages)

Sets maximum number of outstanding messages that can be sent by the broker without being confirmed.

Parameters:

maxUnconfirmedMessages - maximum number of outstanding messages

Returns:

Builder this object

setMaxUnconfirmedBytes

public QueueOptions.Builder setMaxUnconfirmedBytes(long maxUnconfirmedBytes)

Sets maximum accumulated bytes of all outstanding messages that can be sent by the broker without being confirmed.

Parameters:

maxUnconfirmedBytes - maximum accumulated bytes of all outstanding messages without being confirmed

Returns:

Builder this object

setConsumerPriority

public QueueOptions.Builder setConsumerPriority(int consumerPriority)

Sets priority of a consumer with respect to delivery of messages.

Parameters:

consumerPriority - priority of a consumer

Returns:

Builder this object

setSuspendsOnBadHostHealth

public QueueOptions.Builder setSuspendsOnBadHostHealth(boolean suspendsOnBadHostHealth)

Sets whether queue should suspend when the host machine is unhealthy.

Parameters:

suspendsOnBadHostHealth - specifies whether queue suspends operation when host is unhealthy

Returns:

Builder this object

merge

public 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.

Parameters:

options - specifies options which is merged into the builder

Returns:

Builder this object