From be676d84b9f9186a61f594257634e2134cc990e8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B0=AD=E4=B9=9D=E9=BC=8E?= <109224573@qq.com> Date: Tue, 9 Jan 2024 22:19:48 +0800 Subject: [PATCH] doc: streamOps -> opsForStream --- src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc b/src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc index b6fe510c79..97febc2cee 100644 --- a/src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc +++ b/src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc @@ -32,7 +32,7 @@ con.xAdd(record); // append message through RedisTemplate RedisTemplate template = … StringRecord record = StreamRecords.string(…).withStreamKey("my-stream"); -template.streamOps().add(record); +template.opsForStream().add(record); ---- Stream records carry a `Map`, key-value tuples, as their payload. Appending a record to a stream returns the `RecordId` that can be used as further reference. @@ -58,10 +58,10 @@ While stream consumption is typically associated with asynchronous processing, i // Read message through RedisTemplate RedisTemplate template = … -List> messages = template.streamOps().read(StreamReadOptions.empty().count(2), +List> messages = template.opsForStream().read(StreamReadOptions.empty().count(2), StreamOffset.latest("my-stream")); -List> messages = template.streamOps().read(Consumer.from("my-group", "my-consumer"), +List> messages = template.opsForStream().read(Consumer.from("my-group", "my-consumer"), StreamReadOptions.empty().count(2), StreamOffset.create("my-stream", ReadOffset.lastConsumed())) ----