Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-5621 

Fixing LinkStealingTest by adding a wait because removeConnection
may not have been called yet when checking if the removeException
exists the first time
This commit is contained in:
Christopher L. Shannon (cshannon) 2016-05-10 11:41:30 +00:00
parent 604f707d4d
commit d3ea5c4f9f
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
activemq-broker/src/test/java/org/apache/activemq/broker/LinkStealingTest.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq.broker;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import java.util.concurrent.atomic.AtomicReference;
@ -26,6 +26,8 @@ import javax.jms.InvalidClientIDException;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ConnectionInfo;
import org.apache.activemq.util.Wait;
import org.apache.activemq.util.Wait.Condition;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
@ -110,7 +112,14 @@ public class LinkStealingTest {
fail("Unexcpected exception causes test failure");
}
assertNotNull(removeException.get());
//Need to wait because removeConnection might not be called yet
assertTrue(Wait.waitFor(new Condition() {
@Override
public boolean isSatisified() throws Exception {
return removeException.get() != null;
}
}, 5000, 100));
LOG.info("removeException: {}", removeException.get().getMessage());
}
}