diff --git a/src/main/java/com/rabbitmq/stream/StreamCreator.java b/src/main/java/com/rabbitmq/stream/StreamCreator.java index c37c04fc2d..659a53e728 100644 --- a/src/main/java/com/rabbitmq/stream/StreamCreator.java +++ b/src/main/java/com/rabbitmq/stream/StreamCreator.java @@ -146,23 +146,7 @@ enum LeaderLocator { * *

Default value for RabbitMQ 3.10+. */ - BALANCED("balanced"), - - /** - * The stream leader will be a random node of the cluster. - * - *

Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}. - */ - RANDOM("random"), - - /** - * The stream leader will be on the node with the least number of stream leaders. - * - *

Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}. - * - *

Default value for RabbitMQ 3.9. - */ - LEAST_LEADERS("least-leaders"); + BALANCED("balanced"); String value; diff --git a/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java b/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java index 86e3693ad7..c3d216046e 100644 --- a/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java +++ b/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java @@ -32,7 +32,7 @@ class StreamStreamCreator implements StreamCreator { private final StreamEnvironment environment; private final Client.StreamParametersBuilder streamParametersBuilder = - new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.LEAST_LEADERS); + new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.BALANCED); private String name; private DefaultSuperStreamConfiguration superStreamConfiguration;