Package org.redisson.api.stream

Interface StreamMultiReadArgs

public interface StreamMultiReadArgs

Arguments object for RStream.read() methods.

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
StreamMultiReadArgs	count(int count)	Defines stream data size limit.
static StreamMultiReadArgs	greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2)	Defines last stream ids received from all Streams including current one.
static StreamMultiReadArgs	greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2, String stream3, StreamMessageId id3)	Defines last stream ids received from all Streams including current one.
static StreamMultiReadArgs	greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2, String stream3, StreamMessageId id3, String stream4, StreamMessageId id4)	Defines last stream ids received from all Streams including current one.
static StreamMultiReadArgs	greaterThan(StreamMessageId id1, String stream2, StreamMessageId id2, String stream3, StreamMessageId id3, String stream4, StreamMessageId id4, String stream5, StreamMessageId id5)	Defines last stream ids received from all Streams including current one.
static StreamMultiReadArgs	greaterThan(StreamMessageId id1, Map<String,StreamMessageId> offsets)	Defines last stream ids received from all Streams including current one.
StreamMultiReadArgs	timeout(Duration timeout)	Defines time interval to wait for stream data availability.

Method Detail

count

StreamMultiReadArgs count(int count)

Defines stream data size limit.

Parameters:

count - - stream data size limit

Returns:

arguments object

timeout

StreamMultiReadArgs timeout(Duration timeout)

Defines time interval to wait for stream data availability.

Parameters:

timeout - - timeout duration

Returns:

arguments object

greaterThan

static StreamMultiReadArgs greaterThan(StreamMessageId id1,
                                       String stream2,
                                       StreamMessageId id2)

Defines last stream ids received from all Streams including current one.

Read stream data from all defined streams with ids greater than defined ids.

Parameters:

id1 - - last stream id of current stream

stream2 - - name of 2nd stream

id2 - - last stream id of 2nd stream

Returns:

arguments object

greaterThan

static StreamMultiReadArgs greaterThan(StreamMessageId id1,
                                       String stream2,
                                       StreamMessageId id2,
                                       String stream3,
                                       StreamMessageId id3)

Defines last stream ids received from all Streams including current one.

Read stream data from all defined streams with ids greater than defined ids.

Parameters:

id1 - - last stream id of current stream

stream2 - - name of 2nd stream

id2 - - last stream id of 2nd stream

stream3 - - name of 3rd stream

id3 - - last stream id of 3rd stream

Returns:

arguments object

greaterThan

static StreamMultiReadArgs greaterThan(StreamMessageId id1,
                                       String stream2,
                                       StreamMessageId id2,
                                       String stream3,
                                       StreamMessageId id3,
                                       String stream4,
                                       StreamMessageId id4)

Defines last stream ids received from all Streams including current one.

Read stream data from all defined streams with ids greater than defined ids.

Parameters:

id1 - - last stream id of current stream

stream2 - - name of 2nd stream

id2 - - last stream id of 2nd stream

stream3 - - name of 3rd stream

id3 - - last stream id of 3rd stream

stream4 - - name of 4th stream

id4 - - last stream id of 4th stream

Returns:

arguments object

greaterThan

static StreamMultiReadArgs greaterThan(StreamMessageId id1,
                                       String stream2,
                                       StreamMessageId id2,
                                       String stream3,
                                       StreamMessageId id3,
                                       String stream4,
                                       StreamMessageId id4,
                                       String stream5,
                                       StreamMessageId id5)

Defines last stream ids received from all Streams including current one.

Read stream data from all defined streams with ids greater than defined ids.

Parameters:

id1 - - last stream id of current stream

stream2 - - name of 2nd stream

id2 - - last stream id of 2nd stream

stream3 - - name of 3rd stream

id3 - - last stream id of 3rd stream

stream4 - - name of 4th stream

id4 - - last stream id of 4th stream

stream5 - - name of 4th stream

id5 - - last stream id of 4th stream

Returns:

arguments object

greaterThan

static StreamMultiReadArgs greaterThan(StreamMessageId id1,
                                       Map<String,StreamMessageId> offsets)

Defines last stream ids received from all Streams including current one.

Read stream data from all defined streams with ids greater than defined ids.

Parameters:

id1 - - last stream id of current stream

offsets - - last stream id mapped by stream name

Returns:

arguments object