Method renamed to broadcast() (#3227)

redis · Dec 7, 2022 · 0d1c889 · 0d1c889
1 parent 6092720
commit 0d1c889
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/main/java/redis/clients/jedis/UnifiedJedis.java b/src/main/java/redis/clients/jedis/UnifiedJedis.java
@@ -4534,7 +4534,7 @@ public Map<String, Object> 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
@@ -115,15 +115,15 @@ public void onUnsubscribe(String channel, int subscribedChannels) {
 
   @Test
   public void broadcastRawPing() {
-    Map<?, Supplier<String>> replies = cluster.broadcasted().broadcastCommand(
+    Map<?, Supplier<String>> 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()));
   }
 
   @Test
   public void broadcastPing() {
-    Map<?, Supplier<String>> replies = cluster.broadcasted().ping();
+    Map<?, Supplier<String>> 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
@@ -1109,7 +1109,7 @@ public void list() {
 
   @Test
   public void broadcast() {
-    Map<?, Supplier<String>> reply = client.broadcasted().ftCreate(index, TextField.of("t"));
+    Map<?, Supplier<String>> reply = client.broadcast().ftCreate(index, TextField.of("t"));
     assertEquals(1, reply.size());
     assertOK(reply.values().stream().findFirst().get().get());
   }