ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject incubator-ignite git commit: # GG-9950: Implemented.
Date Wed, 01 Apr 2015 12:14:33 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-sprint-3 b05b06f91 -> f097a5b1e


# GG-9950: Implemented.


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

Branch: refs/heads/ignite-sprint-3
Commit: f097a5b1e9568bc1f08b31e2b472e8bb15059eec
Parents: b05b06f
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Wed Apr 1 15:14:43 2015 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Wed Apr 1 15:14:43 2015 +0300

----------------------------------------------------------------------
 .../continuous/CacheContinuousQueryManager.java | 28 ++++++++++++++++++++
 1 file changed, 28 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f097a5b1/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
index ed3bbea..70c5c9d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -274,6 +274,34 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter
{
      * @return Continuous routine ID.
      * @throws IgniteCheckedException In case of error.
      */
+    public UUID executeInternalQueryForNonInternalKeys(CacheEntryUpdatedListener<?, ?>
locLsnr,
+        CacheEntryEventSerializableFilter rmtFilter,
+        boolean loc,
+        boolean notifyExisting)
+        throws IgniteCheckedException
+    {
+        return executeQuery0(
+            locLsnr,
+            rmtFilter,
+            ContinuousQuery.DFLT_PAGE_SIZE,
+            ContinuousQuery.DFLT_TIME_INTERVAL,
+            ContinuousQuery.DFLT_AUTO_UNSUBSCRIBE,
+            false,
+            notifyExisting,
+            true,
+            false,
+            true,
+            loc ? cctx.grid().cluster().forLocal() : null);
+    }
+
+    /**
+     * @param locLsnr Local listener.
+     * @param rmtFilter Remote filter.
+     * @param loc Local flag.
+     * @param notifyExisting Notify existing flag.
+     * @return Continuous routine ID.
+     * @throws IgniteCheckedException In case of error.
+     */
     public UUID executeInternalQuery(CacheEntryUpdatedListener<?, ?> locLsnr,
         CacheEntryEventSerializableFilter rmtFilter,
         boolean loc,


Mime
View raw message