BarrierTakeMany.Options

public static class BarrierTakeMany.Options

Optional attributes for BarrierTakeMany

Public Methods

BarrierTakeMany.Options
allowSmallBatch(Boolean allowSmallBatch)
BarrierTakeMany.Options
timeoutMs(Long timeoutMs)
BarrierTakeMany.Options
waitForIncomplete(Boolean waitForIncomplete)

Inherited Methods

Public Methods

public BarrierTakeMany.Options allowSmallBatch (Boolean allowSmallBatch)

Parameters
allowSmallBatch Allow to return less than num_elements items if barrier is already closed.

public BarrierTakeMany.Options timeoutMs (Long timeoutMs)

Parameters
timeoutMs If the queue is empty, this operation will block for up to timeout_ms milliseconds. Note: This option is not supported yet.

public BarrierTakeMany.Options waitForIncomplete (Boolean waitForIncomplete)