ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [1/2] incubator-ignite git commit: # GG-9950: DR fix.
Date Tue, 31 Mar 2015 12:46:01 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-gg-9950 [created] 721058ae8


# GG-9950: DR fix.


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

Branch: refs/heads/ignite-gg-9950
Commit: fc2c945b48f51c885baa39f9cacba00a1ae12de0
Parents: dfe90fb
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Tue Mar 31 15:44:43 2015 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Tue Mar 31 15:44:43 2015 +0300

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


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fc2c945b/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 eff845d..495c345 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 executeInternalQueryNonInternal(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