test: Using redis-stack 6.2.6 instead of latest

redis-field-engineering · Sep 1, 2023 · 922a606 · 922a606
1 parent 9a8fbd5
commit 922a606
Showing 1 changed file with 37 additions and 33 deletions.
diff --git a/src/test/java/com/redis/trino/RediSearchServer.java b/src/test/java/com/redis/trino/RediSearchServer.java
@@ -14,37 +14,41 @@
 
 public class RediSearchServer implements Closeable {
 
-	private static final DockerImageName DOCKER_IMAGE_NAME = RedisStackContainer.DEFAULT_IMAGE_NAME
-			.withTag(RedisStackContainer.DEFAULT_TAG);
-	private final RedisStackContainer container = new RedisStackContainer(DOCKER_IMAGE_NAME).withEnv("REDISEARCH_ARGS",
-			"MAXAGGREGATERESULTS -1");
-	private final AbstractRedisClient client;
-	private final StatefulRedisModulesConnection<String, String> connection;
-
-	public RediSearchServer() {
-		this.container.start();
-		this.client = ClientBuilder.create(RedisURI.create(container.getRedisURI())).cluster(container.isCluster())
-				.build();
-		this.connection = RedisModulesUtils.connection(client);
-	}
-
-	public String getRedisURI() {
-		return container.getRedisURI();
-	}
-
-	public AbstractRedisClient getClient() {
-		return client;
-	}
-
-	public StatefulRedisModulesConnection<String, String> getConnection() {
-		return connection;
-	}
-
-	@Override
-	public void close() {
-		connection.close();
-		client.shutdown();
-		client.getResources().shutdown();
-		container.close();
-	}
+    private static final String TAG = "6.2.6-v9";
+
+    private static final DockerImageName DOCKER_IMAGE_NAME = RedisStackContainer.DEFAULT_IMAGE_NAME.withTag(TAG);
+
+    private final RedisStackContainer container = new RedisStackContainer(DOCKER_IMAGE_NAME).withEnv("REDISEARCH_ARGS",
+            "MAXAGGREGATERESULTS -1");
+
+    private final AbstractRedisClient client;
+
+    private final StatefulRedisModulesConnection<String, String> connection;
+
+    public RediSearchServer() {
+        this.container.start();
+        this.client = ClientBuilder.create(RedisURI.create(container.getRedisURI())).cluster(container.isCluster()).build();
+        this.connection = RedisModulesUtils.connection(client);
+    }
+
+    public String getRedisURI() {
+        return container.getRedisURI();
+    }
+
+    public AbstractRedisClient getClient() {
+        return client;
+    }
+
+    public StatefulRedisModulesConnection<String, String> getConnection() {
+        return connection;
+    }
+
+    @Override
+    public void close() {
+        connection.close();
+        client.shutdown();
+        client.getResources().shutdown();
+        container.close();
+    }
+
 }