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

Add waitFor to check that once the async processing kicks in the pool 

clears the bad connection and a new one is returned from the pool.
This commit is contained in:
Timothy Bish 2016-05-09 15:15:30 -04:00
parent 7bdcca1bda
commit 100c5e0b59
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-jms-pool/src/test/java/org/apache/activemq/jms/pool/PooledConnectionSecurityExceptionTest.java
View File

@ -106,8 +106,8 @@ public class PooledConnectionSecurityExceptionTest {
} }
@Test @Test
public void testFailureGetsNewConnectionOnRetry() throws JMSException { public void testFailureGetsNewConnectionOnRetry() throws Exception {
Connection connection1 = pooledConnFact.createConnection("invalid", "credentials"); final Connection connection1 = pooledConnFact.createConnection("invalid", "credentials");
try { try {
connection1.start(); connection1.start();
@ -116,6 +116,15 @@ public class PooledConnectionSecurityExceptionTest {
LOG.info("Caught expected security error"); LOG.info("Caught expected security error");
} }
// The pool should process the async error
assertTrue("Should get new connection", Wait.waitFor(new Wait.Condition() {
@Override
public boolean isSatisified() throws Exception {
return connection1 != pooledConnFact.createConnection("invalid", "credentials");
}
}));
Connection connection2 = pooledConnFact.createConnection("invalid", "credentials"); Connection connection2 = pooledConnFact.createConnection("invalid", "credentials");
try { try {
connection2.start(); connection2.start();