File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/main/asciidoc/reference Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -54,14 +54,14 @@ The message listener container itself does not require external threading resour
5454ReactiveRedisConnectionFactory factory = …
5555ReactiveRedisMessageListenerContainer container = new ReactiveRedisMessageListenerContainer(factory);
5656
57- Flux<ChannelMessage<String, String>> stream = container.receive(ChannelTopic.of("my-chanel "));
57+ Flux<ChannelMessage<String, String>> stream = container.receive(ChannelTopic.of("my-channel "));
5858----
5959
6060[[redis:reactive:pubsub:subscribe:template]]
6161=== Subscribing via template API
6262
6363As mentioned above you can directly use `ReactiveRedisTemplate` to subscribe to channels / patterns. This approach
64- offers a straight forward, though limited solution as you loose the option to add subscriptions after the initial
64+ offers a straight forward, though limited solution as you lose the option to add subscriptions after the initial
6565ones. Nevertheless you still can control the message stream via the returned `Flux` using eg. `take(Duration)`. When
6666done reading, on error or cancellation all bound resources are freed again.
6767
You can’t perform that action at this time.
0 commit comments