wip
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/25b3c437 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/25b3c437 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/25b3c437 Branch: refs/heads/ignite-2977 Commit: 25b3c4377d56976c35cf01f79c3f6f8fbe42660e Parents: 58074fc Author: Pavel Tupitsyn <[email protected]> Authored: Wed Apr 13 15:21:24 2016 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Wed Apr 13 15:21:24 2016 +0300 ---------------------------------------------------------------------- .../platform/cache/query/PlatformContinuousQueryImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/25b3c437/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 db77d0e..e2b9f1e 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 @@ -27,11 +27,11 @@ import javax.cache.event.CacheEntryEvent; import javax.cache.event.CacheEntryEventFilter; import javax.cache.event.CacheEntryListenerException; import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.binary.BinaryObject; import org.apache.ignite.cache.query.ContinuousQuery; import org.apache.ignite.cache.query.Query; import org.apache.ignite.cache.query.QueryCursor; import org.apache.ignite.internal.GridKernalContext; -import org.apache.ignite.internal.binary.BinaryObjectImpl; import org.apache.ignite.internal.binary.GridBinaryMarshaller; import org.apache.ignite.internal.processors.cache.IgniteCacheProxy; import org.apache.ignite.internal.processors.cache.query.QueryCursorEx; @@ -99,10 +99,10 @@ public class PlatformContinuousQueryImpl implements PlatformContinuousQuery { * @return Java filter or null. */ private static CacheEntryEventFilter getJavaFilter(Object filter, GridKernalContext ctx) { - if (filter instanceof BinaryObjectImpl) { - BinaryObjectImpl bo = (BinaryObjectImpl)filter; + if (filter instanceof BinaryObject) { + BinaryObject bo = (BinaryObject)filter; - if (bo.typeId() == GridBinaryMarshaller.PLATFORM_JAVA_OBJECT_FACTORY_PROXY) { + if (bo.type() != null && bo.type().typeId() == GridBinaryMarshaller.PLATFORM_JAVA_OBJECT_FACTORY_PROXY) { PlatformJavaObjectFactoryProxy prx = bo.deserialize(); return (CacheEntryEventFilter)prx.factory(ctx).create();
