Repository: ignite Updated Branches: refs/heads/ignite-1537 31f0ddf5e -> f1ccdce4e
ignite-1.5 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f1ccdce4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f1ccdce4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f1ccdce4 Branch: refs/heads/ignite-1537 Commit: f1ccdce4e256f0b67cfc828e806147ba3c2affb2 Parents: 31f0ddf Author: sboikov <[email protected]> Authored: Thu Dec 24 12:24:28 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Dec 24 12:24:28 2015 +0300 ---------------------------------------------------------------------- .../stream/mqtt/IgniteMqttStreamerTest.java | 28 +++++--------------- 1 file changed, 7 insertions(+), 21 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f1ccdce4/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java ---------------------------------------------------------------------- diff --git a/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java b/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java index 6c7f67a..92a530d 100644 --- a/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java +++ b/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java @@ -37,14 +37,12 @@ import org.apache.ignite.IgniteCache; import org.apache.ignite.IgniteDataStreamer; import org.apache.ignite.cache.CachePeekMode; import org.apache.ignite.events.CacheEvent; -import org.apache.ignite.internal.util.lang.GridAbsPredicate; import org.apache.ignite.internal.util.lang.GridMapEntry; import org.apache.ignite.internal.util.typedef.F; import org.apache.ignite.lang.IgniteBiPredicate; import org.apache.ignite.lang.IgniteInClosure; import org.apache.ignite.stream.StreamMultipleTupleExtractor; import org.apache.ignite.stream.StreamSingleTupleExtractor; -import org.apache.ignite.testframework.GridTestUtils; import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; import com.github.rholder.retry.StopStrategies; @@ -197,7 +195,9 @@ public class IgniteMqttStreamerTest extends GridCommonAbstractTest { * @throws Exception If failed. */ public void testConnectionStatusWithBrokerDisconnection() throws Exception { - // configure streamer + fail("https://issues.apache.org/jira/browse/IGNITE-2255";); + + // Configure streamer. streamer.setSingleTupleExtractor(singleTupleExtractor()); streamer.setTopic(SINGLE_TOPIC_NAME); streamer.setBlockUntilConnected(true); @@ -205,34 +205,20 @@ public class IgniteMqttStreamerTest extends GridCommonAbstractTest { streamer.start(); - // action time: repeat 5 times; make sure the connection state is kept correctly every time + // Action time: repeat 5 times; make sure the connection state is kept correctly every time. for (int i = 0; i < 5; i++) { log.info("Iteration: " + i); - GridTestUtils.waitForCondition(new GridAbsPredicate() { - @Override public boolean apply() { - return streamer.isConnected(); - } - }, 2000); - assertTrue(streamer.isConnected()); broker.stop(); - GridTestUtils.waitForCondition(new GridAbsPredicate() { - @Override public boolean apply() { - return !streamer.isConnected(); - } - }, 2000); - assertFalse(streamer.isConnected()); - if (i < 4) { - broker.start(true); - broker.waitUntilStarted(); + broker.start(true); + broker.waitUntilStarted(); - Thread.sleep(500); - } + Thread.sleep(500); } }
