Interface Management.StreamSpecification

Enclosing interface:

Management

public static interface Management.StreamSpecification

Specification of a stream.

See Also:

• Streams

Method Summary

Modifier and Type	Method	Description
Management.StreamSpecification	initialMemberCount(int initialMemberCount)	Set the number of initial members the stream should have.
Management.StreamSpecification	initialOffset(long initialOffset)	Set the stream initial offset.
Management.StreamSpecification	maxAge(Duration maxAge)	Set the maximum age of a stream before it gets truncated.
Management.StreamSpecification	maxSegmentSizeBytes(ByteCapacity maxSegmentSize)	Set the maximum size for the stream segment files.
Management.QueueSpecification	queue()	Go back to the queue specification.

Method Details

maxAge

Management.StreamSpecification maxAge(Duration maxAge)

Set the maximum age of a stream before it gets truncated.

Parameters:

maxAge - maximum age

Returns:

the stream specification

See Also:

• Data Retention

maxSegmentSizeBytes

Management.StreamSpecification maxSegmentSizeBytes(ByteCapacity maxSegmentSize)

Set the maximum size for the stream segment files.

Parameters:

maxSegmentSize -

Returns:

the stream specification

See Also:

• Declaring a Stream

initialMemberCount

Management.StreamSpecification initialMemberCount(int initialMemberCount)

Set the number of initial members the stream should have.

Parameters:

initialMemberCount - initial number of nodes

Returns:

the stream specification

See Also:

• Initial Replication Factor

initialOffset

Management.StreamSpecification initialOffset(long initialOffset)

Set the stream initial offset.

Requires RabbitMQ 4.4.0 or more.

Parameters:

initialOffset - stream initial offset

Returns:

this stream specification

queue

Management.QueueSpecification queue()

Go back to the queue specification.

Returns:

queue specification