Cleanup
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7940541a Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7940541a Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7940541a Branch: refs/heads/ignite-2977 Commit: 7940541a4639f35c0174b3a2160e0f7a98e95818 Parents: 6712c7f Author: Pavel Tupitsyn <[email protected]> Authored: Tue Apr 12 17:32:44 2016 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Tue Apr 12 17:32:44 2016 +0300 ---------------------------------------------------------------------- .../cache/query/PlatformContinuousQueryImpl.java | 4 ++-- .../Impl/Common/PlatformJavaObjectFactoryProxy.cs | 11 +++++++++-- 2 files changed, 11 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7940541a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java index 471b1db..db77d0e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java @@ -103,9 +103,9 @@ public class PlatformContinuousQueryImpl implements PlatformContinuousQuery { BinaryObjectImpl bo = (BinaryObjectImpl)filter; if (bo.typeId() == GridBinaryMarshaller.PLATFORM_JAVA_OBJECT_FACTORY_PROXY) { - PlatformJavaObjectFactoryProxy f = bo.deserialize(); + PlatformJavaObjectFactoryProxy prx = bo.deserialize(); - return (CacheEntryEventFilter)f.factory(ctx).create(); + return (CacheEntryEventFilter)prx.factory(ctx).create(); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/7940541a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PlatformJavaObjectFactoryProxy.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PlatformJavaObjectFactoryProxy.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PlatformJavaObjectFactoryProxy.cs index ef21609..c0ae298 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PlatformJavaObjectFactoryProxy.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/PlatformJavaObjectFactoryProxy.cs @@ -18,6 +18,7 @@ namespace Apache.Ignite.Core.Impl.Common { using System; + using System.Collections.Generic; using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Impl.Binary; @@ -44,17 +45,23 @@ namespace Apache.Ignite.Core.Impl.Common /** Optional payload. */ private readonly object _payload; + /** Properties to set */ + private IDictionary<string, object> _properties; + /// <summary> - /// Initializes a new instance of the <see cref="PlatformJavaObjectFactoryProxy"/> class. + /// Initializes a new instance of the <see cref="PlatformJavaObjectFactoryProxy" /> class. /// </summary> /// <param name="type">The type.</param> /// <param name="factoryClassName">Name of the factory class.</param> /// <param name="payload">The payload.</param> - protected PlatformJavaObjectFactoryProxy(FactoryType type, string factoryClassName, object payload) + /// <param name="properties">The properties.</param> + protected PlatformJavaObjectFactoryProxy(FactoryType type, string factoryClassName, object payload, + IDictionary<string, object> properties) { _factoryType = type; _factoryClassName = factoryClassName; _payload = payload; + _properties = properties; } /// <summary>
