IGNITE-143 - Fixing tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d0c88b79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d0c88b79 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d0c88b79 Branch: refs/heads/ignite-143 Commit: d0c88b79f353bb1ac526b602123eccd4d4cc9103 Parents: 83cfcc1 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Thu Feb 12 17:02:14 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Thu Feb 12 17:02:14 2015 -0800 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d0c88b79/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 93fbbe7..05f7e0d 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 @@ -166,7 +166,7 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K lsnr.oldValueRequired() ? oldVal : null, lsnr.oldValueRequired() ? oldBytes : null); CacheContinuousQueryEvent<K, V> evt = new CacheContinuousQueryEvent<>( - cctx.kernalContext().cache().publicJCache(cctx.name()), evtType, e0); + cctx.kernalContext().cache().jcache(cctx.name()), evtType, e0); lsnr.onEntryUpdated(evt, primary, recordIgniteEvt); } @@ -213,7 +213,7 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K lsnr.oldValueRequired() ? oldVal : null, lsnr.oldValueRequired() ? oldBytes : null); CacheContinuousQueryEvent<K, V> evt = new CacheContinuousQueryEvent<>( - cctx.kernalContext().cache().publicJCache(cctx.name()), EXPIRED, e0); + cctx.kernalContext().cache().jcache(cctx.name()), EXPIRED, e0); lsnr.onEntryUpdated(evt, primary, recordIgniteEvt); } @@ -482,7 +482,7 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K throw new IgniteCheckedException("Listener must implement one of CacheEntryListener sub-interfaces."); CacheEntryUpdatedListener<K, V> locLsnr = (CacheEntryUpdatedListener<K, V>)new JCacheQueryLocalListener( - locLsnrImpl, cctx.kernalContext().cache().publicJCache(cctx.name())); + locLsnrImpl, cctx.kernalContext().cache().jcache(cctx.name())); CacheEntryEventFilter<K, V> rmtFilter = (CacheEntryEventFilter<K, V>)new JCacheQueryRemoteFilter<>( cfg.getCacheEntryEventFilterFactory() != null ? cfg.getCacheEntryEventFilterFactory().create() : null,
