com.solace.messaging.config

Interface DirectReceiverBackPressureConfiguration

All Known Subinterfaces:

DirectMessageReceiverBuilder

@ProviderType
public interface DirectReceiverBackPressureConfiguration

An interface for the configuration of back-pressure features for a message receiver.

Since:

1.0

Method Summary

Modifier and Type	Method and Description
DirectReceiverBackPressureConfiguration	onBackPressureDropLatest(int bufferCapacity) The Configuration for back-pressure with a specified number of pre-buffered received messages.
DirectReceiverBackPressureConfiguration	onBackPressureDropOldest(int bufferCapacity) The Configuration for back-pressure with a specified number of pre-buffered received messages.
DirectReceiverBackPressureConfiguration	onBackPressureElastic() The configuration for back-pressure with an elastic, unlimited capacity buffer.

Method Detail

onBackPressureDropLatest

DirectReceiverBackPressureConfiguration onBackPressureDropLatest(int bufferCapacity)

The Configuration for back-pressure with a specified number of pre-buffered received messages. This configuration drops any new items emitted by the producer (publisher) when the buffer is full.

Parameters:

bufferCapacity - the maximum number of messages in a buffer; a value '>' 0 is permitted

Returns:

an instance of itself

Since:

1.0

onBackPressureDropOldest

DirectReceiverBackPressureConfiguration onBackPressureDropOldest(int bufferCapacity)

The Configuration for back-pressure with a specified number of pre-buffered received messages. This configuration drops the oldest messages emitted by the producer (publisher) when the buffer is full.

Parameters:

bufferCapacity - the maximum number of messages in a buffer; a value '>' 0 is permitted

Returns:

an instance of itself

Since:

1.0

onBackPressureElastic

DirectReceiverBackPressureConfiguration onBackPressureElastic()

The configuration for back-pressure with an elastic, unlimited capacity buffer. This configuration is recommended for microservices that run in a managed environment which can detect crashes and restart those microservices. Usage of this strategy for applications can lead to out-of-memory situations.

Returns:

an instance of itself

Since:

1.0