Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>

Type Parameters:

A - key type

B - value type

Enclosing interface:

RedisStreamReactiveOperations<A,B>

public static interface RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>

XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] id [id ...]

Since:

1.4

Author:

Jeremy Kuhn

Method Summary

Modifier and Type	Method	Description
RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>	block(long milliseconds)
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	build(A group, A consumer, A key, String messageId)
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	build(A group, A consumer, Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)
RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>	count(long count)
RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>	noack()

Method Details

count

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

Parameters:

count -

Returns:

block

RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B> block(long milliseconds)

Parameters:

milliseconds -

Returns:

noack

RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B> noack()

Returns:

build

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

Parameters:

group -

consumer -

key -

messageId -

Returns:

build

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> build(A group,
 A consumer,
 Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)

Parameters:

group -

consumer -

streams -

Returns: