From 5ffaa79f4e602234af2920447f81bc3358847868 Mon Sep 17 00:00:00 2001 From: Christoph Strobl Date: Fri, 28 Apr 2023 10:53:42 +0200 Subject: [PATCH] Fix code snippet in change streams reference documentation. Closes: #4376 --- src/main/asciidoc/reference/change-streams.adoc | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/asciidoc/reference/change-streams.adoc b/src/main/asciidoc/reference/change-streams.adoc index 02843a959..aff9db2d2 100644 --- a/src/main/asciidoc/reference/change-streams.adoc +++ b/src/main/asciidoc/reference/change-streams.adoc @@ -25,16 +25,16 @@ The following example shows how to use Change Streams with `MessageListener` ins [source,java] ---- MessageListenerContainer container = new DefaultMessageListenerContainer(template); -container.start(); <1> +container.start(); <1> -MessageListener, User> listener = System.out::println; <2> -ChangeStreamRequestOptions options = new ChangeStreamRequestOptions("user", ChangeStreamOptions.empty()); <3> +MessageListener, User> listener = System.out::println; <2> +ChangeStreamRequestOptions options = new ChangeStreamRequestOptions("db", "user", ChangeStreamOptions.empty()); <3> -Subscription subscription = container.register(new ChangeStreamRequest<>(listener, options), User.class); <4> +Subscription subscription = container.register(new ChangeStreamRequest<>(listener, options), User.class); <4> // ... -container.stop(); <5> +container.stop(); <5> ---- <1> Starting the container initializes the resources and starts `Task` instances for already registered `SubscriptionRequest` instances. Requests added after startup are ran immediately. <2> Define the listener called when a `Message` is received. The `Message#getBody()` is converted to the requested domain type. Use `Document` to receive raw results without conversion.