ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: IGNITE-2004 Fixed review notes.
Date Thu, 14 Apr 2016 15:42:45 GMT
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 <ntikhonov@gridgain.com>
Authored: Thu Apr 14 18:42:38 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
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) {


Mime
View raw message