wip
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0f51a31c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0f51a31c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0f51a31c Branch: refs/heads/ignite-2977 Commit: 0f51a31c80561075fbcebdd318d4550c3c525d8f Parents: 518fe46 Author: Pavel Tupitsyn <[email protected]> Authored: Wed Apr 13 14:16:43 2016 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Wed Apr 13 14:16:43 2016 +0300 ---------------------------------------------------------------------- .../ignite/platform/PlatformCacheEntryEventFilter.java | 9 +++++++++ .../Cache/Query/Continuous/ContinuousQueryJavaFilterTest.cs | 2 ++ 2 files changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0f51a31c/modules/core/src/test/java/org/apache/ignite/platform/PlatformCacheEntryEventFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/platform/PlatformCacheEntryEventFilter.java b/modules/core/src/test/java/org/apache/ignite/platform/PlatformCacheEntryEventFilter.java index 15efc84..22d7e6a 100644 --- a/modules/core/src/test/java/org/apache/ignite/platform/PlatformCacheEntryEventFilter.java +++ b/modules/core/src/test/java/org/apache/ignite/platform/PlatformCacheEntryEventFilter.java @@ -25,6 +25,7 @@ import org.apache.ignite.resources.IgniteInstanceResource; import javax.cache.event.CacheEntryEvent; import javax.cache.event.CacheEntryListenerException; import java.math.BigDecimal; +import java.util.UUID; /** * Test filter. @@ -74,6 +75,9 @@ public class PlatformCacheEntryEventFilter implements CacheEntryEventSerializabl private boolean boolField; /** Property to be set from platform. */ + private UUID guidField; + + /** Property to be set from platform. */ private BinaryObject objField; /** Property to be set from platform. */ @@ -113,6 +117,9 @@ public class PlatformCacheEntryEventFilter implements CacheEntryEventSerializabl private boolean[] boolArr; /** Property to be set from platform. */ + private UUID[] guidArr; + + /** Property to be set from platform. */ private Object[] objArr; /** Injected instance. */ @@ -138,6 +145,7 @@ public class PlatformCacheEntryEventFilter implements CacheEntryEventSerializabl assert doubleField == 10.123; assert "11.245".equals(decimalField.toString()); assert boolField; + assert guidField.equals(ignite.cluster().localNode().id()); // check arrays assert charArr[0] == 'a'; @@ -152,6 +160,7 @@ public class PlatformCacheEntryEventFilter implements CacheEntryEventSerializabl assert floatArr[0] == (float)9.99; assert doubleArr[0] == 10.123; assert boolArr[0]; + assert guidArr[0].equals(ignite.cluster().localNode().id()); // check binary object assert objField != null && objField.field("Int") == 1 && "2".equals(objField.field("String")); http://git-wip-us.apache.org/repos/asf/ignite/blob/0f51a31c/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryJavaFilterTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryJavaFilterTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryJavaFilterTest.cs index 1561908..f4aa0ac 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryJavaFilterTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryJavaFilterTest.cs @@ -115,6 +115,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous {"doubleField", 10.123}, {"decimalField", (decimal) 11.245}, {"boolField", true}, + {"guidField", _ignite.GetCluster().GetLocalNode().Id}, { "objField", new TestBinary { @@ -134,6 +135,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous {"floatArr", new[] {(float) 9.99}}, {"doubleArr", new[] {10.123}}, {"boolArr", new[] {true}}, + {"guidArr", new[] {_ignite.GetCluster().GetLocalNode().Id}}, { "objArr", new object[] {
