ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [09/50] [abbrv] incubator-ignite git commit: ignite-555 Renamed IgniteCacheEntryEventFilter -> CacheEntryEventSerializableFilter. Also added jdk8 examples testsuit.
Date Mon, 23 Mar 2015 15:38:17 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/44f667a4/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
index 244d0b2..bd5a6d8 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
@@ -332,7 +332,7 @@ public abstract class GridCacheContinuousQueryAbstractSelfTest extends
GridCommo
             }
         });
 
-        qry.setRemoteFilter(new IgniteCacheEntryEventFilter<Integer, Integer>() {
+        qry.setRemoteFilter(new CacheEntryEventSerializableFilter<Integer, Integer>()
{
             @Override public boolean evaluate(CacheEntryEvent<? extends Integer, ? extends
Integer> evt) {
                 throw new RuntimeException("Test error.");
             }
@@ -375,7 +375,7 @@ public abstract class GridCacheContinuousQueryAbstractSelfTest extends
GridCommo
             }
         });
 
-        qry.setRemoteFilter(new IgniteCacheEntryEventFilter<Integer,Integer>() {
+        qry.setRemoteFilter(new CacheEntryEventSerializableFilter<Integer,Integer>()
{
             @Override public boolean evaluate(CacheEntryEvent<? extends Integer,? extends
Integer> evt) {
                 return evt.getKey() > 2;
             }
@@ -971,7 +971,7 @@ public abstract class GridCacheContinuousQueryAbstractSelfTest extends
GridCommo
                 }
             });
 
-            qry.setRemoteFilter(new IgniteCacheEntryEventFilter<Integer, Integer>()
{
+            qry.setRemoteFilter(new CacheEntryEventSerializableFilter<Integer, Integer>()
{
                 @Override public boolean evaluate(CacheEntryEvent<? extends Integer, ?
extends Integer> evt) {
                     return evt.getValue() >= 50;
                 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/44f667a4/modules/core/src/test/java/org/apache/ignite/loadtests/continuous/GridContinuousOperationsLoadTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/continuous/GridContinuousOperationsLoadTest.java
b/modules/core/src/test/java/org/apache/ignite/loadtests/continuous/GridContinuousOperationsLoadTest.java
index e81f4dd..f5ba069 100644
--- a/modules/core/src/test/java/org/apache/ignite/loadtests/continuous/GridContinuousOperationsLoadTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/loadtests/continuous/GridContinuousOperationsLoadTest.java
@@ -114,7 +114,7 @@ public class GridContinuousOperationsLoadTest {
                         }
                     });
 
-                    qry.setRemoteFilter(new IgniteCacheEntryEventFilter<Object,Object>()
{
+                    qry.setRemoteFilter(new CacheEntryEventSerializableFilter<Object,Object>()
{
                         @Override public boolean evaluate(CacheEntryEvent<?,?> evt)
{
                             if (filterSleepMs > 0) {
                                 try {


Mime
View raw message