com.bloomberg.bmq

Class SessionOptions.Builder

java.lang.Object

com.bloomberg.bmq.SessionOptions.Builder

Enclosing class:

SessionOptions

public static class SessionOptions.Builder
extends Object

Helper class to create a SesssionOptions object with custom settings.

Method Summary

Modifier and Type	Method and Description
SessionOptions	build() Creates a SesssionOptions object based on this Builder properties.
SessionOptions.Builder	setBrokerUri(URI value) Sets URI to connect with the broker.
SessionOptions.Builder	setCloseQueueTimeout(Duration value) Sets timeout value for close queue operation
SessionOptions.Builder	setConfigureQueueTimeout(Duration value) Sets timeout value for configure queue operation
SessionOptions.Builder	setHostHealthMonitor(HostHealthMonitor value) Sets host health monitor object.
SessionOptions.Builder	setInboundBufferWaterMark(SessionOptions.InboundEventBufferWaterMark value) Sets low and high inbound buffer watermark values
SessionOptions.Builder	setOpenQueueTimeout(Duration value) Sets timeout value for open queue operation
SessionOptions.Builder	setStartTimeout(Duration value) Sets session start timeout
SessionOptions.Builder	setStatsDumpInterval(Duration value) Sets the stats dump interval to the specified 'value'.
SessionOptions.Builder	setStopTimeout(Duration value) Sets session stop timeout
SessionOptions.Builder	setWriteBufferWaterMark(SessionOptions.WriteBufferWaterMark value) Sets low and high channel watermark values

Methods inherited from class java.lang.Object

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

Method Detail

build

public SessionOptions build()

Creates a SesssionOptions object based on this Builder properties.

Returns:

SessionOptions immutable session options with custom settings

setBrokerUri

public SessionOptions.Builder setBrokerUri(URI value)

Sets URI to connect with the broker.

Parameters:

value - URI to set

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of invalid URI value

setStartTimeout

public SessionOptions.Builder setStartTimeout(Duration value)

Sets session start timeout

Parameters:

value - start timeout value

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of timeout value is zero or negative

setStopTimeout

public SessionOptions.Builder setStopTimeout(Duration value)

Sets session stop timeout

Parameters:

value - stop timeout value

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of timeout value is zero or negative

setWriteBufferWaterMark

public SessionOptions.Builder setWriteBufferWaterMark(SessionOptions.WriteBufferWaterMark value)

Sets low and high channel watermark values

Parameters:

value - holder object for watermark values

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of any of watermark values are zero or negative

setInboundBufferWaterMark

public SessionOptions.Builder setInboundBufferWaterMark(SessionOptions.InboundEventBufferWaterMark value)

Sets low and high inbound buffer watermark values

Parameters:

value - holder object for watermark values

Returns:

Builder this object

setStatsDumpInterval

public SessionOptions.Builder setStatsDumpInterval(Duration value)

Sets the stats dump interval to the specified 'value'. 0 - disable recurring dump of stats (final stats are always dumped at end of session).

Parameters:

value - stats dump interval value

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of interval value is negative

setOpenQueueTimeout

public SessionOptions.Builder setOpenQueueTimeout(Duration value)

Sets timeout value for open queue operation

Parameters:

value - timeout value

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of timeout value is zero or negative

setConfigureQueueTimeout

public SessionOptions.Builder setConfigureQueueTimeout(Duration value)

Sets timeout value for configure queue operation

Parameters:

value - timeout value

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of timeout value is zero or negative

setCloseQueueTimeout

public SessionOptions.Builder setCloseQueueTimeout(Duration value)

Sets timeout value for close queue operation

Parameters:

value - timeout value

Returns:

Builder this object

Throws:

IllegalArgumentException - in case of timeout value is zero or negative

setHostHealthMonitor

public SessionOptions.Builder setHostHealthMonitor(HostHealthMonitor value)

Sets host health monitor object.

Parameters:

value - host health monitor object

Returns:

Builder this object

Throws:

NullPointerException - if the specified value is null