#IGNITE-53: wip

apache · Jan 20, 2015 · c500eda · c500eda
1 parent add3600
commit c500eda
Showing 1 changed file with 24 additions and 6 deletions.
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
@@ -946,15 +946,33 @@ public void removeAll(Collection<? extends K> keys) {
     }
 
     /** {@inheritDoc} */
-    @Override public void registerCacheEntryListener(CacheEntryListenerConfiguration cacheEntryLsnrConfiguration) {
+    @Override public void registerCacheEntryListener(CacheEntryListenerConfiguration<K, V> lsnrCfg) {
-        // TODO IGNITE-1.
+        GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
-        throw new UnsupportedOperationException();
+
+        try {
+            ctx.continuousQueries().registerCacheEntryListener(lsnrCfg, true);
+        }
+        catch (IgniteCheckedException e) {
+            throw cacheException(e);
+        }
+        finally {
+            gate.leave(prev);
+        }
     }
 
     /** {@inheritDoc} */
-    @Override public void deregisterCacheEntryListener(CacheEntryListenerConfiguration cacheEntryLsnrConfiguration) {
+    @Override public void deregisterCacheEntryListener(CacheEntryListenerConfiguration lsnrCfg) {
-        // TODO IGNITE-1.
+        GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
-        throw new UnsupportedOperationException();
+
+        try {
+            ctx.continuousQueries().deregisterCacheEntryListener(lsnrCfg);
+        }
+        catch (IgniteCheckedException e) {
+            throw cacheException(e);
+        }
+        finally {
+            gate.leave(prev);
+        }
     }
 
     /** {@inheritDoc} */