Skip to content

Commit

Permalink
[grid] Create redisson client
Browse files Browse the repository at this point in the history
  • Loading branch information
pujagani committed Jun 10, 2021
1 parent 9e9caf4 commit 1463f03
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 0 deletions.
1 change: 1 addition & 0 deletions java/server/src/org/openqa/selenium/redis/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -10,5 +10,6 @@ java_library(
],
deps = [
artifact("io.lettuce:lettuce-core"),
artifact("org.redisson:redisson")
],
)
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,9 @@
import io.lettuce.core.RedisClient;
import io.lettuce.core.RedisURI;
import io.lettuce.core.api.StatefulRedisConnection;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;

import java.io.Closeable;
import java.net.URI;
Expand All @@ -29,11 +32,16 @@

public class GridRedisClient implements Closeable {
private final RedisClient client;
private final RedissonClient redissonClient;
private final StatefulRedisConnection<String, String> connection;

public GridRedisClient(URI serverUri) {
client = RedisClient.create(RedisURI.create(serverUri));
connection = client.connect();

Config redissonConfig = new Config();
redissonConfig.useSingleServer().setAddress(serverUri.toString());
redissonClient = Redisson.create(redissonConfig);
}

public StatefulRedisConnection<String, String> getConnection() {
Expand Down

0 comments on commit 1463f03

Please sign in to comment.