Package io.lettuce.core
Class XAutoClaimArgs.Builder
- java.lang.Object
-
- io.lettuce.core.XAutoClaimArgs.Builder
-
- Enclosing class:
- XAutoClaimArgs<K>
public static class XAutoClaimArgs.Builder extends Object
Builder entry points forXAutoClaimArgs
.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <K> XAutoClaimArgs<K>
justid(Consumer<K> consumer, long minIdleTime, String startId)
Creates newXAutoClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter.static <K> XAutoClaimArgs<K>
justid(Consumer<K> consumer, Duration minIdleTime, String startId)
Creates newXAutoClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter.static <K> XAutoClaimArgs<K>
xautoclaim(Consumer<K> consumer, long minIdleTime, String startId)
Creates newXAutoClaimArgs
.static <K> XAutoClaimArgs<K>
xautoclaim(Consumer<K> consumer, Duration minIdleTime, String startId)
Creates newXAutoClaimArgs
.
-
-
-
Method Detail
-
justid
public static <K> XAutoClaimArgs<K> justid(Consumer<K> consumer, long minIdleTime, String startId)
Creates newXAutoClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter. The message body is not returned when callingXAUTOCLAIM
.- Type Parameters:
K
-- Parameters:
consumer
-minIdleTime
-startId
-- Returns:
- new
XAutoClaimArgs
withminIdleTime
andstartId
configured.
-
justid
public static <K> XAutoClaimArgs<K> justid(Consumer<K> consumer, Duration minIdleTime, String startId)
Creates newXAutoClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter. The message body is not returned when callingXAUTOCLAIM
.- Type Parameters:
K
-- Parameters:
consumer
-minIdleTime
-startId
-- Returns:
- new
XAutoClaimArgs
withminIdleTime
andstartId
configured.
-
xautoclaim
public static <K> XAutoClaimArgs<K> xautoclaim(Consumer<K> consumer, long minIdleTime, String startId)
Creates newXAutoClaimArgs
.- Type Parameters:
K
-- Parameters:
consumer
-minIdleTime
-startId
-- Returns:
- new
XAutoClaimArgs
withminIdleTime
andstartId
configured.
-
xautoclaim
public static <K> XAutoClaimArgs<K> xautoclaim(Consumer<K> consumer, Duration minIdleTime, String startId)
Creates newXAutoClaimArgs
.- Type Parameters:
K
-- Parameters:
consumer
-minIdleTime
-startId
-- Returns:
- new
XAutoClaimArgs
withminIdleTime
andstartId
configured.
-
-