Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>

Type Parameters:

A - key type

Enclosing interface:

RedisStreamReactiveOperations<A,B>

public static interface RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>

XPENDING key group [IDLE min-idle-time] start end count [consumer]

Since:

1.4

Author:

Jeremy Kuhn

Method Summary

Modifier and Type	Method	Description
Flux<RedisStreamReactiveOperations.StreamPendingMessage>	build(A key, A group, String start, String end, long count)
RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>	consumer(A consumer)
RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>	idle(long minIdleTime)

Method Details

idle

RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A> idle(long minIdleTime)

Parameters:

minIdleTime -

Returns:

consumer

RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A> consumer(A consumer)

Parameters:

consumer -

Returns:

build

Flux<RedisStreamReactiveOperations.StreamPendingMessage> build(A key,
 A group,
 String start,
 String end,
 long count)

Parameters:

key -

group -

start -

end -

count -

Returns: