diff --git a/src/main/java/redis/clients/jedis/UnifiedJedis.java b/src/main/java/redis/clients/jedis/UnifiedJedis.java index 3df0334414..431681f36d 100644 --- a/src/main/java/redis/clients/jedis/UnifiedJedis.java +++ b/src/main/java/redis/clients/jedis/UnifiedJedis.java @@ -4534,7 +4534,7 @@ public Map graphConfigGet(String configName) { } // RedisGraph commands - public JedisBroadcast broadcasted() { + public JedisBroadcast broadcast() { return new JedisBroadcast(this); } diff --git a/src/test/java/redis/clients/jedis/commands/jedis/ClusterValuesCommandsTest.java b/src/test/java/redis/clients/jedis/commands/jedis/ClusterValuesCommandsTest.java index 9ea719dc51..1f7be1b8bb 100644 --- a/src/test/java/redis/clients/jedis/commands/jedis/ClusterValuesCommandsTest.java +++ b/src/test/java/redis/clients/jedis/commands/jedis/ClusterValuesCommandsTest.java @@ -115,7 +115,7 @@ public void onUnsubscribe(String channel, int subscribedChannels) { @Test public void broadcastRawPing() { - Map> replies = cluster.broadcasted().broadcastCommand( + Map> replies = cluster.broadcast().broadcastCommand( new CommandObject<>(new CommandArguments(Protocol.Command.PING), BuilderFactory.STRING)); assertEquals(3, replies.size()); replies.values().forEach(reply -> assertEquals("PONG", reply.get())); @@ -123,7 +123,7 @@ public void broadcastRawPing() { @Test public void broadcastPing() { - Map> replies = cluster.broadcasted().ping(); + Map> replies = cluster.broadcast().ping(); assertEquals(3, replies.size()); replies.values().forEach(reply -> assertEquals("PONG", reply.get())); } @@ -133,7 +133,7 @@ public void broadcastFlushAll() { assertNull(cluster.get("foo")); assertEquals("OK", cluster.set("foo", "bar")); assertEquals("bar", cluster.get("foo")); - cluster.broadcasted().flushAll(); + cluster.broadcast().flushAll(); assertNull(cluster.get("foo")); } } diff --git a/src/test/java/redis/clients/jedis/modules/search/SearchWithParamsTest.java b/src/test/java/redis/clients/jedis/modules/search/SearchWithParamsTest.java index a6a356cf99..76d4201bc5 100644 --- a/src/test/java/redis/clients/jedis/modules/search/SearchWithParamsTest.java +++ b/src/test/java/redis/clients/jedis/modules/search/SearchWithParamsTest.java @@ -1109,7 +1109,7 @@ public void list() { @Test public void broadcast() { - Map> reply = client.broadcasted().ftCreate(index, TextField.of("t")); + Map> reply = client.broadcast().ftCreate(index, TextField.of("t")); assertEquals(1, reply.size()); assertOK(reply.values().stream().findFirst().get().get()); }