ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-1.5
Date Thu, 24 Dec 2015 09:24:35 GMT
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 <sboikov@gridgain.com>
Authored: Thu Dec 24 12:24:28 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
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);
         }
     }
 


Mime
View raw message