org.rvpf.forwarder

Class BatchControl.Builder

Object

BatchControl.Builder

Enclosing class:

BatchControl

public static final class BatchControl.Builder
extends Object

Batch control builder.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BATCH_LIMIT_PROPERTY Specifies the maximum number of messages in a transaction.
static String	BATCH_TIMEOUT_PROPERTY The maximum elapsed time to complete the batch when at least one message has been received in the current transaction.
static String	BATCH_WAIT_PROPERTY The maximum elapsed time to wait for an additional message when at least one has been received in the current transaction.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
BatchControl.Builder	applyProperties(KeyedGroups moduleProperties) Applies properties.
BatchControl	build() Builds a batch control.
BatchControl.Builder	setDefaultLimit(int defaultLimit) Sets the default limit.
BatchControl.Builder	setDefaultWait(Optional<ElapsedTime> defaultWait) Sets the default wait.
BatchControl.Builder	setLogger(Logger logger) Sets the logger.

Methods inherited from class Object

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

Field Detail

BATCH_LIMIT_PROPERTY

public static final String BATCH_LIMIT_PROPERTY

Specifies the maximum number of messages in a transaction.

See Also:

Constant Field Values

BATCH_TIMEOUT_PROPERTY

public static final String BATCH_TIMEOUT_PROPERTY

The maximum elapsed time to complete the batch when at least one message has been received in the current transaction.

See Also:

Constant Field Values

BATCH_WAIT_PROPERTY

public static final String BATCH_WAIT_PROPERTY

The maximum elapsed time to wait for an additional message when at least one has been received in the current transaction.

See Also:

Constant Field Values

Constructor Detail

Builder

public Builder()

Method Detail

applyProperties

@Nonnull
public BatchControl.Builder applyProperties(@Nonnull
                                                      KeyedGroups moduleProperties)

Applies properties.

Parameters:

moduleProperties - The module properties.

Returns:

This.

build

public BatchControl build()

Builds a batch control.

Returns:

The new batch control.

setDefaultLimit

@Nonnull
public BatchControl.Builder setDefaultLimit(int defaultLimit)

Sets the default limit.

Parameters:

defaultLimit - The default limit.

Returns:

This.

setDefaultWait

@Nonnull
public BatchControl.Builder setDefaultWait(@Nonnull
                                                     Optional<ElapsedTime> defaultWait)

Sets the default wait.

Parameters:

defaultWait - The default wait.

Returns:

This.

setLogger

@Nonnull
public BatchControl.Builder setLogger(@Nonnull
                                                Logger logger)

Sets the logger.

Parameters:

logger - The logger.

Returns:

This.