Repository: incubator-ignite Updated Branches: refs/heads/ignite-gg-9942 c8428a453 -> d47b66a21
# 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-gg-9942 Commit: f097a5b1e9568bc1f08b31e2b472e8bb15059eec Parents: b05b06f Author: vozerov-gridgain <voze...@gridgain.com> Authored: Wed Apr 1 15:14:43 2015 +0300 Committer: vozerov-gridgain <voze...@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,
