ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [6/6] incubator-ignite git commit: IGNITE-143 - Continuous queries refactoring (manual merge)
Date Sat, 14 Feb 2015 01:21:07 GMT
IGNITE-143 - Continuous queries refactoring (manual merge)


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b42fdcd2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b42fdcd2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b42fdcd2

Branch: refs/heads/ignite-sql-old
Commit: b42fdcd247b3f3788a1b3b0431bdef09b0561630
Parents: e465477
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Fri Feb 13 17:20:46 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Fri Feb 13 17:20:46 2015 -0800

----------------------------------------------------------------------
 .../ignite/cache/query/ContinuousQuery.java     | 30 ++++++++++++++++----
 1 file changed, 24 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b42fdcd2/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
b/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
index 35303ab..d99e95a 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
@@ -150,9 +150,12 @@ public final class ContinuousQuery<K, V> extends Query<ContinuousQuery<K,V>>
{
      * time continuous query is executed.
      *
      * @param initFilter Initial query.
+     * @return {@code this} for chaining.
      */
-    public void setInitialPredicate(Query initFilter) {
+    public ContinuousQuery<K, V> setInitialPredicate(Query initFilter) {
         this.initFilter = initFilter;
+
+        return this;
     }
 
     /**
@@ -177,9 +180,12 @@ public final class ContinuousQuery<K, V> extends Query<ContinuousQuery<K,V>>
{
      * blocking the thread that called the callback. Otherwise, you can get deadlocks.
      *
      * @param locLsnr Local callback.
+     * @return {@code this} for chaining.
      */
-    public void setLocalListener(CacheEntryUpdatedListener<K, V> locLsnr) {
+    public ContinuousQuery<K, V> setLocalListener(CacheEntryUpdatedListener<K, V>
locLsnr) {
         this.locLsnr = locLsnr;
+
+        return this;
     }
 
     /**
@@ -199,9 +205,12 @@ public final class ContinuousQuery<K, V> extends Query<ContinuousQuery<K,V>>
{
      * without blocking the thread that called the filter. Otherwise, you can get deadlocks.
      *
      * @param rmtFilter Key-value filter.
+     * @return {@code this} for chaining.
      */
-    public void setRemoteFilter(CacheEntryEventFilter<K, V> rmtFilter) {
+    public ContinuousQuery<K, V> setRemoteFilter(CacheEntryEventFilter<K, V>
rmtFilter) {
         this.rmtFilter = rmtFilter;
+
+        return this;
     }
 
     /**
@@ -224,12 +233,15 @@ public final class ContinuousQuery<K, V> extends Query<ContinuousQuery<K,V>>
{
      * disabled).
      *
      * @param bufSize Buffer size.
+     * @return {@code this} for chaining.
      */
-    public void setBufferSize(int bufSize) {
+    public ContinuousQuery<K, V> setBufferSize(int bufSize) {
         if (bufSize <= 0)
             throw new IllegalArgumentException("Buffer size must be above zero.");
 
         this.bufSize = bufSize;
+
+        return this;
     }
 
     /**
@@ -252,12 +264,15 @@ public final class ContinuousQuery<K, V> extends Query<ContinuousQuery<K,V>>
{
      * time check is disabled and entries will be sent only when buffer is full.
      *
      * @param timeInterval Time interval.
+     * @return {@code this} for chaining.
      */
-    public void setTimeInterval(long timeInterval) {
+    public ContinuousQuery<K, V> setTimeInterval(long timeInterval) {
         if (timeInterval < 0)
             throw new IllegalArgumentException("Time interval can't be negative.");
 
         this.timeInterval = timeInterval;
+
+        return this;
     }
 
     /**
@@ -280,9 +295,12 @@ public final class ContinuousQuery<K, V> extends Query<ContinuousQuery<K,V>>
{
      * Default value for this flag is {@code true}.
      *
      * @param autoUnsubscribe Automatic unsubscription flag.
+     * @return {@code this} for chaining.
      */
-    public void setAutoUnsubscribe(boolean autoUnsubscribe) {
+    public ContinuousQuery<K, V> setAutoUnsubscribe(boolean autoUnsubscribe) {
         this.autoUnsubscribe = autoUnsubscribe;
+
+        return this;
     }
 
     /**


Mime
View raw message