ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [35/47] incubator-ignite git commit: IGNITE-836 Fix GridEventConsumeSelfTest
Date Fri, 15 May 2015 14:02:37 GMT
IGNITE-836 Fix GridEventConsumeSelfTest


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/980dd472
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/980dd472
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/980dd472

Branch: refs/heads/ignite-709_3
Commit: 980dd47254f68becc69938f9420f23079fef584c
Parents: 63fc5e7
Author: sevdokimov <sevdokimov@gridgain.com>
Authored: Fri May 15 14:00:48 2015 +0300
Committer: sevdokimov <sevdokimov@gridgain.com>
Committed: Fri May 15 14:00:48 2015 +0300

----------------------------------------------------------------------
 .../processors/continuous/GridEventConsumeSelfTest.java  | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/980dd472/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
index 63ec6d6..9ff99c4 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
@@ -102,17 +102,18 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest
implements
         assertEquals(GRID_CNT, grid(0).cluster().nodes().size());
 
         for (int i = 0; i < GRID_CNT; i++) {
-            IgniteKernal grid = (IgniteKernal)grid(i);
+            IgniteEx grid = grid(i);
 
             GridContinuousProcessor proc = grid.context().continuous();
 
-            if (noAutoUnsubscribe) {
-                localRoutines(proc).clear();
-
+            try {
+                if (!noAutoUnsubscribe)
+                    assertEquals(0, U.<Map>field(proc, "rmtInfos").size());
+            }
+            finally {
                 U.<Map>field(proc, "rmtInfos").clear();
             }
 
-            assertEquals(0, localRoutines(proc).size());
             assertEquals(0, U.<Map>field(proc, "rmtInfos").size());
             assertEquals(0, U.<Map>field(proc, "startFuts").size());
             assertEquals(0, U.<Map>field(proc, "stopFuts").size());


Mime
View raw message