Skip to content

Commit

Permalink
typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Aliaksei Bialiauski authored and Aliaksei Bialiauski committed Mar 28, 2023
1 parent f7a5911 commit 9fef89e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -149,8 +149,7 @@ Again, [XML](https://en.wikipedia.org/wiki/XML#:~:text=Extensible%20Markup%20Lan
</consumer>
```

Consuming messages:
Firstly, you need to be subscribed on a particular topic and only then iterate over data in the topic:
Consuming [messages](#messages-api):
```java
try (
final Consumer<String, String> consumer =
Expand All @@ -168,6 +167,7 @@ try (
)
)
) {
// you need to be subscribed on a topic to iterate over data in the topic
consumer.subscribe(new ListOf<>("orders-saga-init")));
List<Dataized<String>> result = consumer.iterate("orders-saga-init", Duration.ofSeconds(5L));
}
Expand Down

0 comments on commit 9fef89e

Please sign in to comment.