Interface ConnectionSettings.Affinity<T>

Type Parameters:

T - type of the owning object

Enclosing interface:

ConnectionSettings<T>

public static interface ConnectionSettings.Affinity<T>

Connection affinity settings.

This is an experimental API, subject to change.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ConnectionSettings.Affinity.Operation	Affinity operation.

Method Summary

Modifier and Type	Method	Description
T	connection()	Return the connection builder.
ConnectionSettings.Affinity<T>	operation(ConnectionSettings.Affinity.Operation operation)	The type of operation to look affinity with.
ConnectionSettings.Affinity<T>	queue(String queue)	The queue to have affinity with.
ConnectionSettings.Affinity<T>	reuse(boolean reuse)	Whether an open connection with the same affinity should reused.
ConnectionSettings.Affinity<T>	strategy(ConnectionSettings.AffinityStrategy strategy)	Set the ConnectionSettings.AffinityStrategy.

Method Details

queue

ConnectionSettings.Affinity<T> queue(String queue)

The queue to have affinity with.

Parameters:

queue - queue

Returns:

affinity settings

operation

ConnectionSettings.Affinity<T> operation(ConnectionSettings.Affinity.Operation operation)

The type of operation to look affinity with.

ConnectionSettings.Affinity.Operation.PUBLISH will favor the node with the queue leader on it.

ConnectionSettings.Affinity.Operation.CONSUME will favor a node with a queue member (replica) on it.

Parameters:

operation - type of operation

Returns:

affinity settings

reuse

ConnectionSettings.Affinity<T> reuse(boolean reuse)

Whether an open connection with the same affinity should reused.

Default is false (open a new connection, do not reuse).

Parameters:

reuse - true to reuse, false to open a new connection

Returns:

affinity settings

strategy

ConnectionSettings.Affinity<T> strategy(ConnectionSettings.AffinityStrategy strategy)

Set the ConnectionSettings.AffinityStrategy.

Parameters:

strategy - affinity strategy

Returns:

affinity settings

connection

T connection()

Return the connection builder.

Returns:

connection builder