| Constructor and Description |
|---|
XAddParams() |
| Modifier and Type | Method and Description |
|---|---|
void |
addParams(CommandArguments args) |
XAddParams |
approximateTrimming() |
boolean |
equals(java.lang.Object o) |
XAddParams |
exactTrimming() |
int |
hashCode() |
XAddParams |
id(byte[] id) |
XAddParams |
id(long time) |
XAddParams |
id(long time,
long sequence) |
XAddParams |
id(StreamEntryID id) |
XAddParams |
id(java.lang.String id) |
XAddParams |
idmp(byte[] producerId,
byte[] idempotentId)
Enable idempotent producer mode with explicit idempotent ID.
|
XAddParams |
idmp(java.lang.String producerId,
java.lang.String idempotentId)
Enable idempotent producer mode with explicit idempotent ID.
|
XAddParams |
idmpAuto(byte[] producerId)
Enable idempotent producer mode with automatic idempotent ID generation.
|
XAddParams |
idmpAuto(java.lang.String producerId)
Enable idempotent producer mode with automatic idempotent ID generation.
|
XAddParams |
limit(long limit) |
XAddParams |
maxLen(long maxLen) |
XAddParams |
minId(java.lang.String minId) |
XAddParams |
noMkStream() |
XAddParams |
trimmingMode(StreamDeletionPolicy trimMode)
When trimming, defines desired behaviour for handling consumer group references.
|
static XAddParams |
xAddParams() |
public static XAddParams xAddParams()
public XAddParams noMkStream()
public XAddParams id(byte[] id)
public XAddParams id(java.lang.String id)
public XAddParams id(StreamEntryID id)
public XAddParams id(long time, long sequence)
public XAddParams id(long time)
public XAddParams maxLen(long maxLen)
public XAddParams minId(java.lang.String minId)
public XAddParams approximateTrimming()
public XAddParams exactTrimming()
public XAddParams limit(long limit)
public XAddParams trimmingMode(StreamDeletionPolicy trimMode)
StreamDeletionPolicy for details.public XAddParams idmpAuto(byte[] producerId)
producerId - unique producer identifier (binary)public XAddParams idmpAuto(java.lang.String producerId)
producerId - unique producer identifier (string)public XAddParams idmp(byte[] producerId, byte[] idempotentId)
producerId - unique producer identifier (binary)idempotentId - unique idempotent identifier for this message (binary)public XAddParams idmp(java.lang.String producerId, java.lang.String idempotentId)
producerId - unique producer identifier (string)idempotentId - unique idempotent identifier for this message (string)public void addParams(CommandArguments args)
public boolean equals(java.lang.Object o)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.ObjectCopyright © 2026. All rights reserved.