Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>

Type Parameters:

A - key type

B - value type

Enclosing interface:

RedisStreamReactiveOperations<A,B>

public static interface RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>

XAUTOCLAIM key group consumer min-idle-time start [COUNT count] [JUSTID]

Since:

1.4

Author:

Jeremy Kuhn

Method Summary

Modifier and Type	Method	Description
Mono<RedisStreamReactiveOperations.StreamClaimedMessages<A,B>>	build(A key, A group, A consumer, long minIdleTime, String start)
RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>	count(long count)
RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>	justid()

Method Details

justid

RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B> justid()

Returns:

count

RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B> count(long count)

Parameters:

count -

Returns:

build

Mono<RedisStreamReactiveOperations.StreamClaimedMessages<A,B>> build(A key,
 A group,
 A consumer,
 long minIdleTime,
 String start)

Parameters:

key -

group -

consumer -

minIdleTime -

start -

Returns: