Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id EDDFD193EC for ; Wed, 13 Apr 2016 14:53:01 +0000 (UTC) Received: (qmail 30273 invoked by uid 500); 13 Apr 2016 14:53:01 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 30106 invoked by uid 500); 13 Apr 2016 14:53:01 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 29854 invoked by uid 99); 13 Apr 2016 14:53:01 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Apr 2016 14:53:01 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 2AF22E022F; Wed, 13 Apr 2016 14:53:01 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vozerov@apache.org To: commits@ignite.apache.org Date: Wed, 13 Apr 2016 14:53:13 -0000 Message-Id: <6a543d30c1c344588787ae5c8cf88de2@git.apache.org> In-Reply-To: <7ac3b1d14d574d07946db9bb21d6643d@git.apache.org> References: <7ac3b1d14d574d07946db9bb21d6643d@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [14/50] ignite git commit: wip wip Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3bdfcd05 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3bdfcd05 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3bdfcd05 Branch: refs/heads/ignite-2977 Commit: 3bdfcd052355dbf3f2636ddbdf5aba9a3bc290ed Parents: ed277e4 Author: Pavel Tupitsyn Authored: Tue Apr 12 18:22:07 2016 +0300 Committer: Pavel Tupitsyn Committed: Tue Apr 12 18:22:07 2016 +0300 ---------------------------------------------------------------------- .../Continuous/ContinuousQueryJavaFilterTest.cs | 29 ++++++++++++++++---- 1 file changed, 24 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3bdfcd05/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 7d9033d..9febfa90 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 @@ -19,7 +19,6 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous { using System.Collections.Generic; - using System.Diagnostics.CodeAnalysis; using System.Linq; using Apache.Ignite.Core.Cache.Event; using Apache.Ignite.Core.Cache.Query.Continuous; @@ -90,17 +89,37 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous } /// - /// Tests the java objects. + /// Tests the filter. /// [Test] public void TestFilter() { - var cache = _ignite.GetOrCreateCache("qry"); - - var pred = JavaObjectFactory.CreateCacheEntryEventFilter( + var filter = JavaObjectFactory.CreateCacheEntryEventFilter( "org.apache.ignite.platform.PlatformCacheEntryEventFilter", new Dictionary {{"startsWith", "valid"}}); + TestFilter(filter); + } + + /// + /// Tests the filter. + /// + [Test] + public void TestFactory() + { + var filter = JavaObjectFactory.CreateCacheEntryEventFilterFactory( + "org.apache.ignite.platform.PlatformCacheEntryEventFilterFactory", + new Dictionary {{"startsWith", "valid"}}); + + TestFilter(filter); + } + + /// + /// Tests the specified filter. + /// + private void TestFilter(ICacheEntryEventFilter pred) + { + var cache = _ignite.GetOrCreateCache("qry"); var qry = new ContinuousQuery(new QueryListener(), pred); using (cache.QueryContinuous(qry))