This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 9ba50eaf586 IGNITE-17245 Fix AbstractContinuousQuery.setIncludeExpired
to return this for chaining (#10120)
9ba50eaf586 is described below
commit 9ba50eaf5864d1a8dd01ae6ecdb91cf7c0b9e1b9
Author: Stephen Darlington <[email protected]>
AuthorDate: Tue Jul 5 06:54:13 2022 +0100
IGNITE-17245 Fix AbstractContinuousQuery.setIncludeExpired to return this
for chaining (#10120)
---
.../java/org/apache/ignite/cache/query/AbstractContinuousQuery.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/cache/query/AbstractContinuousQuery.java
b/modules/core/src/main/java/org/apache/ignite/cache/query/AbstractContinuousQuery.java
index 2a615ee8873..a9391e4a98c 100644
---
a/modules/core/src/main/java/org/apache/ignite/cache/query/AbstractContinuousQuery.java
+++
b/modules/core/src/main/java/org/apache/ignite/cache/query/AbstractContinuousQuery.java
@@ -186,9 +186,12 @@ public abstract class AbstractContinuousQuery<K, V>
extends Query<Cache.Entry<K,
* This flag is {@code false} by default, so {@link EventType#EXPIRED}
events are disabled.
*
* @param includeExpired Whether to notify about {@link EventType#EXPIRED}
events.
+ * @return {@code this} for chaining.
*/
- public void setIncludeExpired(boolean includeExpired) {
+ public AbstractContinuousQuery<K, V> setIncludeExpired(boolean
includeExpired) {
this.includeExpired = includeExpired;
+
+ return this;
}
/**
