Skip to content

Commit cf54106

Browse files
imba-tjdmp911de
authored andcommitted
Fix reference documentation for Stream ops usage.
Closes #2825
1 parent 1c74527 commit cf54106

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc

+3-3
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ con.xAdd(record);
3232
// append message through RedisTemplate
3333
RedisTemplate template = …
3434
StringRecord record = StreamRecords.string(…).withStreamKey("my-stream");
35-
template.streamOps().add(record);
35+
template.opsForStream().add(record);
3636
----
3737

3838
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
5858
// Read message through RedisTemplate
5959
RedisTemplate template = …
6060
61-
List<MapRecord<K, HK, HV>> messages = template.streamOps().read(StreamReadOptions.empty().count(2),
61+
List<MapRecord<K, HK, HV>> messages = template.opsForStream().read(StreamReadOptions.empty().count(2),
6262
StreamOffset.latest("my-stream"));
6363
64-
List<MapRecord<K, HK, HV>> messages = template.streamOps().read(Consumer.from("my-group", "my-consumer"),
64+
List<MapRecord<K, HK, HV>> messages = template.opsForStream().read(Consumer.from("my-group", "my-consumer"),
6565
StreamReadOptions.empty().count(2),
6666
StreamOffset.create("my-stream", ReadOffset.lastConsumed()))
6767
----

0 commit comments

Comments
 (0)