Fixes matching for a lowercase subcommand

Signed-off-by: Michael Kubovic <[email protected]>
vert-x3 · Nov 24, 2023 · c7c66d7 · c7c66d7
1 parent e0210be
commit c7c66d7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java b/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java
@@ -141,7 +141,7 @@ public Future<Response> send(Request request) {
         // can run anywhere
         if (REDUCERS.containsKey(cmd)) {
           sendToAllSlots(promise, req, cmd, args, forceMasterEndpoint, REDUCERS.get(cmd));
-        } else if(cmd.equals(SCRIPT) && Arrays.equals(args.get(0), "LOAD".getBytes())) {
+        } else if(cmd.equals(SCRIPT) && "LOAD".equalsIgnoreCase(new String(args.get(0)))) {
           sendToAllSlots(promise, req, cmd, args, forceMasterEndpoint, responses -> {
             // all nodes should compute the same sha
             assert responses.stream().map(Response::toString).collect(Collectors.toSet()).size() == 1;

diff --git a/src/test/java/io/vertx/redis/client/test/RedisClusterTest.java b/src/test/java/io/vertx/redis/client/test/RedisClusterTest.java
@@ -1244,7 +1244,7 @@ public void testScriptLoadRunsOnEveryMaster(TestContext should) {
       cluster.exceptionHandler(should::fail);
       Future<@Nullable Response> setFuture1 = cluster.send(cmd(SET).arg(key1).arg(argv1));
       Future<@Nullable Response> setFuture2 = cluster.send(cmd(SET).arg(key2).arg(argv2));
-      Future<@Nullable Response> scriptLoadFuture = cluster.send(cmd(SCRIPT).arg("LOAD").arg(script));
+      Future<@Nullable Response> scriptLoadFuture = cluster.send(cmd(SCRIPT).arg("load").arg(script));
 
       return Future.all(setFuture1, setFuture2, scriptLoadFuture)
         .compose(compositeRet -> {