Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>

Type Parameters:

A - key type

B - value type

Enclosing interface:

RedisStreamReactiveOperations<A,B>

public static interface RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>

XCLAIM key group consumer min-idle-time id [id ...] [IDLE ms] [TIME ms-unix-time] [RETRYCOUNT count] [FORCE] [JUSTID]

Since:

1.4

Author:

Jeremy Kuhn

Method Summary

Modifier and Type	Method	Description
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	build(A key, A group, A consumer, long minIdleTime, String messageId)
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	build(A key, A group, A consumer, long minIdleTime, Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)
RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	force()
RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	idle(long ms)
RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	justid()
RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	retrycount(long count)
RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>	time(long msUnixTime)

Method Details

idle

RedisStreamReactiveOperations.StreamXclaimBuilder<A,B> idle(long ms)

Parameters:

ms -

Returns:

time

RedisStreamReactiveOperations.StreamXclaimBuilder<A,B> time(long msUnixTime)

Parameters:

msUnixTime -

Returns:

retrycount

RedisStreamReactiveOperations.StreamXclaimBuilder<A,B> retrycount(long count)

Parameters:

count -

Returns:

force

RedisStreamReactiveOperations.StreamXclaimBuilder<A,B> force()

Returns:

justid

RedisStreamReactiveOperations.StreamXclaimBuilder<A,B> justid()

Returns:

build

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> build(A key,
 A group,
 A consumer,
 long minIdleTime,
 String messageId)

Parameters:

key -

group -

consumer -

minIdleTime -

messageId -

Returns:

build

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> build(A key,
 A group,
 A consumer,
 long minIdleTime,
 Consumer<RedisStreamReactiveOperations.StreamMessageIds> messageIds)

Parameters:

key -

group -

consumer -

minIdleTime -

messageIds -

Returns: