Uses of Interface
org.redisson.api.stream.StreamMultiReadGroupArgs

Packages that use StreamMultiReadGroupArgs

Package	Description
org.redisson
org.redisson.api
org.redisson.api.stream

Uses of StreamMultiReadGroupArgs in org.redisson

Methods in org.redisson with parameters of type StreamMultiReadGroupArgs

Modifier and Type	Method	Description
Map<String,Map<StreamMessageId,Map<K,V>>>	RedissonStream.readGroup(String groupName, String consumerName, StreamMultiReadGroupArgs args)
RFuture<Map<String,Map<StreamMessageId,Map<K,V>>>>	RedissonStream.readGroupAsync(String groupName, String consumerName, StreamMultiReadGroupArgs args)

Uses of StreamMultiReadGroupArgs in org.redisson.api

Methods in org.redisson.api with parameters of type StreamMultiReadGroupArgs

Modifier and Type	Method	Description
Map<String,Map<StreamMessageId,Map<K,V>>>	RStream.readGroup(String groupName, String consumerName, StreamMultiReadGroupArgs args)	Read stream data from consumer group and multiple streams including current.
reactor.core.publisher.Mono<Map<String,Map<StreamMessageId,Map<K,V>>>>	RStreamReactive.readGroup(String groupName, String consumerName, StreamMultiReadGroupArgs args)	Read stream data from consumer group and multiple streams including current.
io.reactivex.rxjava3.core.Single<Map<String,Map<StreamMessageId,Map<K,V>>>>	RStreamRx.readGroup(String groupName, String consumerName, StreamMultiReadGroupArgs args)	Read stream data from consumer group and multiple streams including current.
RFuture<Map<String,Map<StreamMessageId,Map<K,V>>>>	RStreamAsync.readGroupAsync(String groupName, String consumerName, StreamMultiReadGroupArgs args)	Read stream data from consumer group and multiple streams including current.

Uses of StreamMultiReadGroupArgs in org.redisson.api.stream

Methods in org.redisson.api.stream that return StreamMultiReadGroupArgs

Modifier and Type	Method	Description
StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.count(int count)	Defines stream data size limit.
static StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2)	Defines to return messages of all Streams with ids greater than defined message ids.
static StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2, String stream3, StreamMessageId id3)	Defines to return messages of all Streams with ids greater than defined message ids.
static StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2, String stream3, StreamMessageId id3, String stream4, StreamMessageId id4)	Defines to return messages of all Streams with ids greater than defined message ids.
static StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2, String stream3, StreamMessageId id3, String stream4, StreamMessageId id4, String stream5, StreamMessageId id5)	Defines to return messages of all Streams with ids greater than defined message ids.
static StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.greaterThan(StreamMessageId id, Map<String,StreamMessageId> offsets)	Defines to return messages of all Streams with ids greater than defined message ids.
StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.noAck()	Defines avoid of adding messages to Pending Entries List.
StreamMultiReadGroupArgs	StreamMultiReadGroupArgs.timeout(Duration timeout)	Defines time interval to wait for stream data availability.