storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ptgo...@apache.org
Subject [5/7] git commit: fix testMessageDisorder() to assert after calling run()
Date Thu, 12 Jun 2014 21:03:17 GMT
fix testMessageDisorder() to assert after calling run()


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/405dabbc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/405dabbc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/405dabbc

Branch: refs/heads/master
Commit: 405dabbc8e67f72a8c04e95c0b562dc2826c01a1
Parents: f1bf9cd
Author: P. Taylor Goetz <ptgoetz@gmail.com>
Authored: Thu Jun 12 16:55:43 2014 -0400
Committer: P. Taylor Goetz <ptgoetz@gmail.com>
Committed: Thu Jun 12 16:55:43 2014 -0400

----------------------------------------------------------------------
 .../test/jvm/backtype/storm/utils/DisruptorQueueTest.java      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/405dabbc/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
index f21b10f..747d95c 100644
--- a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
+++ b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
@@ -55,10 +55,10 @@ public class DisruptorQueueTest extends TestCase {
                 }
             }
         });
-        
-        Assert.assertEquals("We expect to receive first published message first, but received
" + result[0].toString(), 
-                "1", result[0]);
+
         run(producer, consumer);
+        Assert.assertEquals("We expect to receive first published message first, but received
" + result[0],
+                "1", result[0]);
     }
     
     @Test 


Mime
View raw message