fix: Added ssl args to RedisContext create method

redis · Nov 1, 2024 · 7bf804a · 7bf804a
1 parent e3810fa
commit 7bf804a
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 3 deletions.
diff --git a/plugins/riot/src/main/java/com/redis/riot/AbstractRedisCommand.java b/plugins/riot/src/main/java/com/redis/riot/AbstractRedisCommand.java
@@ -15,7 +15,7 @@ public abstract class AbstractRedisCommand extends AbstractJobCommand {
 
 	@Override
 	protected void execute() throws Exception {
-		redisContext = RedisContext.of(redisArgs.getUri(), redisArgs);
+		redisContext = RedisContext.of(redisArgs);
 		redisContext.afterPropertiesSet();
 		try {
 			super.execute();

diff --git a/plugins/riot/src/main/java/com/redis/riot/AbstractRedisExportCommand.java b/plugins/riot/src/main/java/com/redis/riot/AbstractRedisExportCommand.java
@@ -23,7 +23,7 @@ public abstract class AbstractRedisExportCommand extends AbstractExportCommand {
 
 	@Override
 	protected RedisContext sourceRedisContext() {
-		return RedisContext.of(redisArgs.getUri(), redisArgs);
+		return RedisContext.of(redisArgs);
 	}
 
 	protected ItemProcessor<KeyValue<String>, Map<String, Object>> mapProcessor() {

diff --git a/plugins/riot/src/main/java/com/redis/riot/AbstractRedisImportCommand.java b/plugins/riot/src/main/java/com/redis/riot/AbstractRedisImportCommand.java
@@ -9,7 +9,7 @@ public abstract class AbstractRedisImportCommand extends AbstractImportCommand {
 
 	@Override
 	protected RedisContext targetRedisContext() {
-		return RedisContext.of(redisArgs.getUri(), redisArgs);
+		return RedisContext.of(redisArgs);
 	}
 
 	public RedisArgs getRedisArgs() {

diff --git a/plugins/riot/src/main/java/com/redis/riot/RedisContext.java b/plugins/riot/src/main/java/com/redis/riot/RedisContext.java
@@ -173,4 +173,10 @@ public RedisContext clientResources(ClientResources clientResources) {
 		return this;
 	}
 
+	public static RedisContext of(RedisArgs args) {
+		RedisContext context = of(args.getUri(), args);
+		context.sslOptions(args.getSslArgs().sslOptions());
+		return context;
+	}
+
 }