Repository: activemq Updated Branches: refs/heads/master 67c28b1c6 -> eaf5c1215
Add test to assert that preconditions are met before moving on to the rest of the checks. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/eaf5c121 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/eaf5c121 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/eaf5c121 Branch: refs/heads/master Commit: eaf5c12151552e01c7de31bdcc8b96d8cbd3a1c6 Parents: 67c28b1 Author: Timothy Bish <[email protected]> Authored: Mon Jun 8 14:11:04 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Mon Jun 8 14:11:24 2015 -0400 ---------------------------------------------------------------------- .../transport/vm/VMTransportThreadSafeTest.java | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/eaf5c121/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java index 8534f89..c5c4706 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java @@ -523,18 +523,32 @@ public class VMTransportThreadSafeTest { @Override public void run() { try { - Thread.sleep(100); + Thread.sleep(200); } catch (InterruptedException e) { } ((GatedVMTestTransportListener) remote.getTransportListener()).gate.countDown(); } }); + + assertTrue(Wait.waitFor(new Wait.Condition() { + @Override + public boolean isSatisified() throws Exception { + return remoteReceived.size() == 1; + } + })); + gateman.start(); remote.stop(); local.stop(); - assertEquals(1, remoteReceived.size()); + assertTrue(Wait.waitFor(new Wait.Condition() { + @Override + public boolean isSatisified() throws Exception { + return remoteReceived.size() == 1; + } + })); + assertMessageAreOrdered(remoteReceived); }
