You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/06/19 23:06:17 UTC
[06/23] git commit: fix testMessageDisorder() to assert after calling
run()
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/security
Commit: 405dabbc8e67f72a8c04e95c0b562dc2826c01a1
Parents: f1bf9cd
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 16:55:43 2014 -0400
Committer: P. Taylor Goetz <pt...@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