Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
sazzad16 committed Dec 25, 2023
1 parent 388712c commit c3aa116
Showing 1 changed file with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -60,14 +60,15 @@ public void cleanUp() {
}

@Test
public void pipelineSwitch() {
public void pipelineWithSwitch() {
MultiClusterPooledConnectionProvider provider = new MultiClusterPooledConnectionProvider(
new MultiClusterClientConfig.Builder(getClusterConfigs(clientConfig, hostPort_1, hostPort_2)).build());

try (UnifiedJedis client = new UnifiedJedis(provider)) {
AbstractPipeline pipe = client.pipelined();
pipe.set("pstr", "foobar");
pipe.hset("phash", "foo", "bar");
//provider.incrementActiveMultiClusterIndex();
pipe.sync();
}

Expand All @@ -76,14 +77,15 @@ public void pipelineSwitch() {
}

@Test
public void transactionSwitch() {
public void transactionWithSwitch() {
MultiClusterPooledConnectionProvider provider = new MultiClusterPooledConnectionProvider(
new MultiClusterClientConfig.Builder(getClusterConfigs(clientConfig, hostPort_1, hostPort_2)).build());

try (UnifiedJedis client = new UnifiedJedis(provider)) {
AbstractTransaction tx = client.multi();
tx.set("tstr", "foobar");
tx.hset("thash", "foo", "bar");
//provider.incrementActiveMultiClusterIndex();
assertEquals(Arrays.asList("OK", Long.valueOf(1L)), tx.exec());
}

Expand Down Expand Up @@ -150,7 +152,7 @@ public void pipelineFailover() {
}

@Test
public void failoverAuthError() {
public void failoverFromAuthError() {
int slidingWindowMinCalls = 10;
int slidingWindowSize = 10;

Expand Down

0 comments on commit c3aa116

Please sign in to comment.