Repository: ignite Updated Branches: refs/heads/ignite-2004 970861673 -> dcb547a40
IGNITE-2004 Fixed review notes. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dcb547a4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dcb547a4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dcb547a4 Branch: refs/heads/ignite-2004 Commit: dcb547a40e7ee19db071d536b679c45a55a350e3 Parents: 9708616 Author: nikolay_tikhonov <[email protected]> Authored: Thu Apr 14 18:42:38 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Thu Apr 14 18:42:38 2016 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/GridEventConsumeHandler.java | 4 ++-- .../org/apache/ignite/internal/GridMessageListenHandler.java | 4 ++-- .../cache/query/continuous/CacheContinuousQueryHandler.java | 2 +- .../internal/processors/continuous/GridContinuousHandler.java | 4 ++-- .../internal/processors/continuous/GridContinuousProcessor.java | 2 +- 5 files changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/dcb547a4/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java index cc656f1..19bf1a7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java @@ -21,8 +21,8 @@ import java.io.Externalizable; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.util.Collection; import java.util.LinkedList; -import java.util.List; import java.util.Map; import java.util.Queue; import java.util.UUID; @@ -301,7 +301,7 @@ class GridEventConsumeHandler implements GridContinuousHandler { * @param nodeId Node ID. * @param objs Notification objects. */ - @Override public void notifyCallback(UUID nodeId, UUID routineId, List<?> objs, GridKernalContext ctx) { + @Override public void notifyCallback(UUID nodeId, UUID routineId, Collection<?> objs, GridKernalContext ctx) { assert nodeId != null; assert routineId != null; assert objs != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/dcb547a4/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java index 70b9da7..0ac6877 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java @@ -21,7 +21,7 @@ import java.io.Externalizable; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; -import java.util.List; +import java.util.Collection; import java.util.Map; import java.util.UUID; import org.apache.ignite.IgniteCheckedException; @@ -149,7 +149,7 @@ public class GridMessageListenHandler implements GridContinuousHandler { } /** {@inheritDoc} */ - @Override public void notifyCallback(UUID nodeId, UUID routineId, List<?> objs, GridKernalContext ctx) { + @Override public void notifyCallback(UUID nodeId, UUID routineId, Collection<?> objs, GridKernalContext ctx) { assert false; } http://git-wip-us.apache.org/repos/asf/ignite/blob/dcb547a4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index 294a3ed..53ff00a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -573,7 +573,7 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler @SuppressWarnings("unchecked") @Override public void notifyCallback(final UUID nodeId, final UUID routineId, - List<?> objs, + Collection<?> objs, final GridKernalContext ctx) { assert nodeId != null; assert routineId != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/dcb547a4/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java index 318f5ce..46e87af 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.continuous; import java.io.Externalizable; -import java.util.List; +import java.util.Collection; import java.util.Map; import java.util.UUID; import org.apache.ignite.IgniteCheckedException; @@ -80,7 +80,7 @@ public interface GridContinuousHandler extends Externalizable, Cloneable { * @param objs Notification objects. * @param ctx Kernal context. */ - public void notifyCallback(UUID nodeId, UUID routineId, List<?> objs, GridKernalContext ctx); + public void notifyCallback(UUID nodeId, UUID routineId, Collection<?> objs, GridKernalContext ctx); /** * Deploys and marshals inner objects (called only if peer deployment is enabled). http://git-wip-us.apache.org/repos/asf/ignite/blob/dcb547a4/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java index 277f829..8107b3e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java @@ -964,7 +964,7 @@ public class GridContinuousProcessor extends GridProcessorAdapter { LocalRoutineInfo routine = locInfos.get(routineId); if (routine != null) - routine.hnd.notifyCallback(nodeId, routineId, (List<?>)msg.data(), ctx); + routine.hnd.notifyCallback(nodeId, routineId, (Collection<?>)msg.data(), ctx); } finally { if (msg.futureId() != null) {
