sp-2 removed disco custom event test
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/be12b2d7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/be12b2d7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/be12b2d7 Branch: refs/heads/ignite-143 Commit: be12b2d781c0de6957fe53e9a2d74afb33560e82 Parents: d1ebb02 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Thu Mar 5 21:40:33 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Thu Mar 5 21:40:33 2015 +0300 ---------------------------------------------------------------------- .../internal/GridDiscoveryEventSelfTest.java | 43 -------------------- 1 file changed, 43 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be12b2d7/modules/core/src/test/java/org/apache/ignite/internal/GridDiscoveryEventSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridDiscoveryEventSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridDiscoveryEventSelfTest.java index f17e0a9..c094a5d 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridDiscoveryEventSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridDiscoveryEventSelfTest.java @@ -418,47 +418,4 @@ public class GridDiscoveryEventSelfTest extends GridCommonAbstractTest { stopAllGrids(); } } - - /** - * @throws Exception If failed. - */ - public void testCustomEvents() throws Exception { - try { - Ignite g0 = startGrid(0); - final Ignite g1 = startGrid(1); - Ignite g2 = startGrid(2); - - final CountDownLatch cnt = new CountDownLatch(3); - - IgnitePredicate<DiscoveryCustomEvent> lsnr = new IgnitePredicate<DiscoveryCustomEvent>() { - @Override public boolean apply(DiscoveryCustomEvent evt) { - assert cnt.getCount() > 0; - - cnt.countDown(); - - return true; - } - }; - - g0.events().localListen(lsnr, DiscoveryCustomEvent.EVT_DISCOVERY_CUSTOM_EVT); - g1.events().localListen(lsnr, DiscoveryCustomEvent.EVT_DISCOVERY_CUSTOM_EVT); - g2.events().localListen(lsnr, DiscoveryCustomEvent.EVT_DISCOVERY_CUSTOM_EVT); - - ((IgniteKernal)g1).context().discovery().sendCustomEvent("a"); - - cnt.await(); - - g0.events().localQuery(new IgnitePredicate<DiscoveryCustomEvent>() { - @Override public boolean apply(DiscoveryCustomEvent evt) { - assert "a".equals(evt.data()); - assert ((IgniteEx)g1).localNode().id().equals(evt.eventNode().id()); - - return true; - } - }, DiscoveryCustomEvent.EVT_DISCOVERY_CUSTOM_EVT); - } - finally { - stopAllGrids(); - } - } }
