io.lettuce.core

Class XAddArgs.Builder

java.lang.Object

io.lettuce.core.XAddArgs.Builder

Enclosing class:

XAddArgs

public static class XAddArgs.Builder
extends Object

Builder entry points for XAddArgs.

Method Summary

Modifier and Type	Method and Description
static XAddArgs	idmp(byte[] producerId, byte[] idempotentId) Creates new XAddArgs with IDMP (idempotent producer with explicit ID).
static XAddArgs	idmp(String producerId, String idempotentId) Creates new XAddArgs with IDMP (idempotent producer with explicit ID).
static XAddArgs	idmpAuto(byte[] producerId) Creates new XAddArgs with IDMPAUTO (idempotent producer with auto-generated ID).
static XAddArgs	idmpAuto(String producerId) Creates new XAddArgs with IDMPAUTO (idempotent producer with auto-generated ID).
static XAddArgs	maxlen(long count) Creates new XAddArgs and setting MAXLEN.
static XAddArgs	minId(String minid) Creates new XAddArgs and setting MINID.
static XAddArgs	nomkstream() Creates new XAddArgs and setting NOMKSTREAM.

Methods inherited from class java.lang.Object

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

Method Detail

maxlen

public static XAddArgs maxlen(long count)

Creates new XAddArgs and setting MAXLEN.

Returns:

new XAddArgs with MAXLEN set.

See Also:

XAddArgs.maxlen(long)

nomkstream

public static XAddArgs nomkstream()

Creates new XAddArgs and setting NOMKSTREAM.

Returns:

new XAddArgs with NOMKSTREAM set.

Since:

6.1

See Also:

XAddArgs.nomkstream()

minId

public static XAddArgs minId(String minid)

Creates new XAddArgs and setting MINID.

Parameters:

minid - the oldest ID in the stream will be exactly the minimum between its original oldest ID and the specified threshold.

Returns:

new XAddArgs with MINID set.

Since:

6.1

See Also:

XAddArgs.minId(String)

idmp

public static XAddArgs idmp(byte[] producerId,
                            byte[] idempotentId)

Creates new XAddArgs with IDMP (idempotent producer with explicit ID).

Parameters:

producerId - the producer ID (must be unique per producer).

idempotentId - the idempotent ID (must be unique per message).

Returns:

new XAddArgs with IDMP set.

See Also:

XAddArgs.idmp(byte[], byte[])

idmp

public static XAddArgs idmp(String producerId,
                            String idempotentId)

Creates new XAddArgs with IDMP (idempotent producer with explicit ID).

Parameters:

producerId - the producer ID (must be unique per producer).

idempotentId - the idempotent ID (must be unique per message).

Returns:

new XAddArgs with IDMP set.

See Also:

XAddArgs.idmp(String, String)

idmpAuto

public static XAddArgs idmpAuto(byte[] producerId)

Creates new XAddArgs with IDMPAUTO (idempotent producer with auto-generated ID).

Parameters:

producerId - the producer ID (must be unique per producer).

Returns:

new XAddArgs with IDMPAUTO set.

See Also:

XAddArgs.idmpAuto(byte[])

idmpAuto

public static XAddArgs idmpAuto(String producerId)

Creates new XAddArgs with IDMPAUTO (idempotent producer with auto-generated ID).

Parameters:

producerId - the producer ID (must be unique per producer).

Returns:

new XAddArgs with IDMPAUTO set.

See Also:

XAddArgs.idmpAuto(String)