From 0d1c88947845bb18a2191ad4e120860219a47963 Mon Sep 17 00:00:00 2001 From: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com> Date: Wed, 7 Dec 2022 17:49:12 +0600 Subject: [PATCH] Method renamed to broadcast() (#3227) --- src/main/java/redis/clients/jedis/UnifiedJedis.java | 2 +- .../jedis/commands/jedis/ClusterValuesCommandsTest.java | 6 +++--- .../clients/jedis/modules/search/SearchWithParamsTest.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) 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()); }