Skip to content

Commit af3b9bd

Browse files
committed
Rename MultiClusterTransaction to MultiDbTransaction
1 parent 8d1a768 commit af3b9bd

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,9 @@
1414
* Active-Active cluster(s) by using simple configuration
1515
*/
1616
@Experimental
17-
public class CircuitBreakerFailoverConnectionProvider extends CircuitBreakerFailoverBase {
17+
public class MultiDbConnectionSupplier extends CircuitBreakerFailoverBase {
1818

19-
public CircuitBreakerFailoverConnectionProvider(MultiDbConnectionProvider provider) {
19+
public MultiDbConnectionSupplier(MultiDbConnectionProvider provider) {
2020
super(provider);
2121
}
2222

src/main/java/redis/clients/jedis/mcf/MultiDbPipeline.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,14 @@
1616
@Experimental
1717
public class MultiDbPipeline extends PipelineBase implements Closeable {
1818

19-
private final CircuitBreakerFailoverConnectionProvider failoverProvider;
19+
private final MultiDbConnectionSupplier failoverProvider;
2020
private final Queue<KeyValue<CommandArguments, Response<?>>> commands = new LinkedList<>();
2121

2222
@Deprecated
2323
public MultiDbPipeline(MultiDbConnectionProvider pooledProvider) {
2424
super(new CommandObjects());
2525

26-
this.failoverProvider = new CircuitBreakerFailoverConnectionProvider(pooledProvider);
26+
this.failoverProvider = new MultiDbConnectionSupplier(pooledProvider);
2727

2828
try (Connection connection = failoverProvider.getConnection()) {
2929
RedisProtocol proto = connection.getRedisProtocol();
@@ -33,7 +33,7 @@ public MultiDbPipeline(MultiDbConnectionProvider pooledProvider) {
3333

3434
public MultiDbPipeline(MultiDbConnectionProvider pooledProvider, CommandObjects commandObjects) {
3535
super(commandObjects);
36-
this.failoverProvider = new CircuitBreakerFailoverConnectionProvider(pooledProvider);
36+
this.failoverProvider = new MultiDbConnectionSupplier(pooledProvider);
3737
}
3838

3939
@Override

src/main/java/redis/clients/jedis/mcf/MultiDbTransaction.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public class MultiDbTransaction extends TransactionBase {
2626

2727
private static final String GRAPH_COMMANDS_NOT_SUPPORTED_MESSAGE = "Graph commands are not supported.";
2828

29-
private final CircuitBreakerFailoverConnectionProvider failoverProvider;
29+
private final MultiDbConnectionSupplier failoverProvider;
3030
private final AtomicInteger extraCommandCount = new AtomicInteger();
3131
private final Queue<KeyValue<CommandArguments, Response<?>>> commands = new LinkedList<>();
3232

@@ -51,7 +51,7 @@ public MultiDbTransaction(MultiDbConnectionProvider provider) {
5151
*/
5252
@Deprecated
5353
public MultiDbTransaction(MultiDbConnectionProvider provider, boolean doMulti) {
54-
this.failoverProvider = new CircuitBreakerFailoverConnectionProvider(provider);
54+
this.failoverProvider = new MultiDbConnectionSupplier(provider);
5555

5656
try (Connection connection = failoverProvider.getConnection()) {
5757
RedisProtocol proto = connection.getRedisProtocol();
@@ -71,7 +71,7 @@ public MultiDbTransaction(MultiDbConnectionProvider provider, boolean doMulti) {
7171
public MultiDbTransaction(MultiDbConnectionProvider provider, boolean doMulti,
7272
CommandObjects commandObjects) {
7373
super(commandObjects);
74-
this.failoverProvider = new CircuitBreakerFailoverConnectionProvider(provider);
74+
this.failoverProvider = new MultiDbConnectionSupplier(provider);
7575

7676
if (doMulti) multi();
7777
}

0 commit comments

Comments
 (0)