Skip to content

Commit 963e32f

Browse files
committed
Rename MultiClusterTransaction t o MultiDbTransaction
1 parent 5867088 commit 963e32f

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

src/main/java/redis/clients/jedis/MultiDbClient.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import redis.clients.jedis.executors.CommandExecutor;
88
import redis.clients.jedis.mcf.CircuitBreakerCommandExecutor;
99
import redis.clients.jedis.mcf.MultiDbPipeline;
10-
import redis.clients.jedis.mcf.MultiClusterTransaction;
10+
import redis.clients.jedis.mcf.MultiDbTransaction;
1111
import redis.clients.jedis.providers.ConnectionProvider;
1212
import redis.clients.jedis.mcf.MultiDbConnectionProvider;
1313

@@ -232,25 +232,25 @@ public MultiDbPipeline pipelined() {
232232
* The returned transaction supports the same resilience features as the main client, including
233233
* automatic failover during transaction execution.
234234
* </p>
235-
* @return a new MultiClusterTransaction instance
235+
* @return a new MultiDbTransaction instance
236236
*/
237237
@Override
238-
public MultiClusterTransaction multi() {
239-
return new MultiClusterTransaction((MultiDbConnectionProvider) provider, true, commandObjects);
238+
public MultiDbTransaction multi() {
239+
return new MultiDbTransaction((MultiDbConnectionProvider) provider, true, commandObjects);
240240
}
241241

242242
/**
243243
* @param doMulti {@code false} should be set to enable manual WATCH, UNWATCH and MULTI
244244
* @return transaction object
245245
*/
246246
@Override
247-
public MultiClusterTransaction transaction(boolean doMulti) {
247+
public MultiDbTransaction transaction(boolean doMulti) {
248248
if (provider == null) {
249249
throw new IllegalStateException(
250250
"It is not allowed to create Transaction from this " + getClass());
251251
}
252252

253-
return new MultiClusterTransaction(getMultiDbConnectionProvider(), doMulti, commandObjects);
253+
return new MultiDbTransaction(getMultiDbConnectionProvider(), doMulti, commandObjects);
254254
}
255255

256256
public Endpoint getActiveEndpoint() {

src/main/java/redis/clients/jedis/UnifiedJedis.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
import redis.clients.jedis.mcf.CircuitBreakerCommandExecutor;
3636
import redis.clients.jedis.mcf.MultiDbPipeline;
3737
import redis.clients.jedis.mcf.MultiDbConnectionProvider;
38-
import redis.clients.jedis.mcf.MultiClusterTransaction;
38+
import redis.clients.jedis.mcf.MultiDbTransaction;
3939
import redis.clients.jedis.params.*;
4040
import redis.clients.jedis.providers.*;
4141
import redis.clients.jedis.resps.*;
@@ -5121,7 +5121,7 @@ public AbstractTransaction transaction(boolean doMulti) {
51215121
if (provider == null) {
51225122
throw new IllegalStateException("It is not allowed to create Transaction from this " + getClass());
51235123
} else if (provider instanceof MultiDbConnectionProvider) {
5124-
return new MultiClusterTransaction((MultiDbConnectionProvider) provider, doMulti, commandObjects);
5124+
return new MultiDbTransaction((MultiDbConnectionProvider) provider, doMulti, commandObjects);
51255125
} else {
51265126
return new Transaction(provider.getConnection(), doMulti, true, commandObjects);
51275127
}

src/main/java/redis/clients/jedis/mcf/MultiClusterTransaction.java renamed to src/main/java/redis/clients/jedis/mcf/MultiDbTransaction.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
* This is high memory dependent solution as all the appending commands will be hold in memory.
2121
*/
2222
@Experimental
23-
public class MultiClusterTransaction extends TransactionBase {
23+
public class MultiDbTransaction extends TransactionBase {
2424

2525
private static final Builder<?> NO_OP_BUILDER = BuilderFactory.RAW_OBJECT;
2626

@@ -39,7 +39,7 @@ public class MultiClusterTransaction extends TransactionBase {
3939
* @param provider
4040
*/
4141
@Deprecated
42-
public MultiClusterTransaction(MultiDbConnectionProvider provider) {
42+
public MultiDbTransaction(MultiDbConnectionProvider provider) {
4343
this(provider, true);
4444
}
4545

@@ -50,7 +50,7 @@ public MultiClusterTransaction(MultiDbConnectionProvider provider) {
5050
* @param doMulti {@code false} should be set to enable manual WATCH, UNWATCH and MULTI
5151
*/
5252
@Deprecated
53-
public MultiClusterTransaction(MultiDbConnectionProvider provider, boolean doMulti) {
53+
public MultiDbTransaction(MultiDbConnectionProvider provider, boolean doMulti) {
5454
this.failoverProvider = new CircuitBreakerFailoverConnectionProvider(provider);
5555

5656
try (Connection connection = failoverProvider.getConnection()) {
@@ -68,7 +68,7 @@ public MultiClusterTransaction(MultiDbConnectionProvider provider, boolean doMul
6868
* @param doMulti {@code false} should be set to enable manual WATCH, UNWATCH and MULTI
6969
* @param commandObjects command objects
7070
*/
71-
public MultiClusterTransaction(MultiDbConnectionProvider provider, boolean doMulti,
71+
public MultiDbTransaction(MultiDbConnectionProvider provider, boolean doMulti,
7272
CommandObjects commandObjects) {
7373
super(commandObjects);
7474
this.failoverProvider = new CircuitBreakerFailoverConnectionProvider(provider);

0 commit comments

Comments
 (0)