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/63fc5e7b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/63fc5e7b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/63fc5e7b Branch: refs/heads/ignite-709_3 Commit: 63fc5e7b91ff9ad440d1c49606cd432593c67dd7 Parents: 784c088 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Fri May 15 13:48:49 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Fri May 15 13:48:49 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/continuous/GridEventConsumeSelfTest.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/63fc5e7b/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 d219a60..63ec6d6 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 @@ -115,10 +115,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest implements 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, "waitForStartAck").size()); assertEquals(0, U.<Map>field(proc, "stopFuts").size()); - assertEquals(0, U.<Map>field(proc, "waitForStopAck").size()); - assertEquals(0, U.<Map>field(proc, "pending").size()); } }
