Package com.rabbitmq.client.amqp

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	initialClusterSize(int initialClusterSize)	Set the number of nodes the initial stream cluster should span.
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

initialClusterSize

Management.StreamSpecification initialClusterSize(int initialClusterSize)

Set the number of nodes the initial stream cluster should span.

Parameters:

initialClusterSize - initial number of nodes

Returns:

the stream specification

See Also:

• Initial Replication Factor

queue

Management.QueueSpecification queue()

Go back to the queue specification.

Returns:

queue specification