Skip to content

Commit

Permalink
Fix doc
Browse files Browse the repository at this point in the history
Signed-off-by: Andrew Carbonetto <[email protected]>
  • Loading branch information
acarbonetto committed Jun 19, 2024
1 parent 844555b commit 8dd68a8
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ CompletableFuture<String> xgroupCreate(
* @example
* <pre>{@code
* // Creates the consumer "myconsumer" in consumer group "mygroup"
* assert client.xgroupDestroy("mystream", "mygroup", "myconsumer").get();
* assert client.xgroupCreateConsumer("mystream", "mygroup", "myconsumer").get();
* }</pre>
*/
CompletableFuture<Boolean> xgroupCreateConsumer(String key, String group, String consumer);
Expand All @@ -401,7 +401,7 @@ CompletableFuture<String> xgroupCreate(
* @example
* <pre>{@code
* // Deletes the consumer "myconsumer" in consumer group "mygroup"
* Long pendingMsgCount = client.xgroupDestroy("mystream", "mygroup", "myconsumer").get();
* Long pendingMsgCount = client.xgroupDelConsumer("mystream", "mygroup", "myconsumer").get();
* System.out.println("Consumer 'myconsumer' had " +
* + pendingMsgCount + " pending messages unclaimed.");
* }</pre>
Expand Down

0 comments on commit 8dd68a8

Please sign in to comment.