You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/04/01 22:27:26 UTC
[23/38] incubator-ignite git commit: # GG-9950: Implemented.
# 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-645
Commit: f097a5b1e9568bc1f08b31e2b472e8bb15059eec
Parents: b05b06f
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Apr 1 15:14:43 2015 +0300
Committer: vozerov-gridgain <vo...@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,