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)	Deprecated, for removal: This API element is subject to removal in a future version.
Management.StreamSpecification	initialMemberCount(int initialMemberCount)	Set the number of initial members the stream should have.
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

@Deprecated(forRemoval=true)
Management.StreamSpecification initialClusterSize(int initialClusterSize)

Deprecated, for removal: This API element is subject to removal in a future version.

Deprecated, use initialMemberCount(int) instead.

Parameters:

initialClusterSize - initial number of nodes

Returns:

the stream specification

See Also:

• Initial Replication Factor

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

queue

Management.QueueSpecification queue()

Go back to the queue specification.

Returns:

queue specification