From 7e3f7bd86137b0d9bd1d4cb3c09ba19bb7674723 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Fri, 6 Mar 2020 11:34:13 +0100 Subject: [PATCH] DATAMONGO-2481 - Polishing. Add since tag. Original pull request: #838. --- .../data/mongodb/core/messaging/ChangeStreamRequest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/ChangeStreamRequest.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/ChangeStreamRequest.java index c4ed0687c..bc104fe32 100644 --- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/ChangeStreamRequest.java +++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/ChangeStreamRequest.java @@ -190,6 +190,7 @@ public class ChangeStreamRequest * @param collectionName can be {@literal null}. * @param maxAwaitTime can be {@literal null}. * @param options must not be {@literal null}. + * @since 3.0 */ public ChangeStreamRequestOptions(@Nullable String databaseName, @Nullable String collectionName, @Nullable Duration maxAwaitTime, ChangeStreamOptions options) { @@ -260,7 +261,7 @@ public class ChangeStreamRequest private @Nullable String collectionName; private @Nullable Duration maxAwaitTime; private @Nullable MessageListener, ? super T> listener; - private ChangeStreamOptionsBuilder delegate = ChangeStreamOptions.builder(); + private final ChangeStreamOptionsBuilder delegate = ChangeStreamOptions.builder(); private ChangeStreamRequestBuilder() {} @@ -357,7 +358,7 @@ public class ChangeStreamRequest * @see ChangeStreamOptions#getCollation() * @see ChangeStreamOptionsBuilder#collation(Collation) */ - public ChangeStreamRequestBuilder collation(Collation collation) { + public ChangeStreamRequestBuilder collation(Collation collation) { Assert.notNull(collation, "Collation must not be null!");