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 <sevdoki...@gridgain.com> Authored: Fri May 15 14:00:48 2015 +0300 Committer: sevdokimov <sevdoki...@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());
