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

some more sanity to this renew test, https://issues.apache.org/jira/browse/AMQ-4122 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1449184 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2013-02-22 19:51:04 +00:00
parent 7a0b32b82b
commit 74bccd57c6
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
activemq-unit-tests/src/test/java/org/apache/activemq/store/jdbc/LeaseDatabaseLockerTest.java
View File

@ -24,6 +24,7 @@ import java.sql.Connection;
import java.sql.PreparedStatement;
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@ -32,6 +33,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.activemq.broker.AbstractLocker;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter;
import org.apache.activemq.util.Wait;
import org.apache.derby.jdbc.EmbeddedDataSource;
import org.junit.Before;
import org.junit.Test;
@ -62,11 +64,11 @@ public class LeaseDatabaseLockerTest {
public void testLockInterleave() throws Exception {
LeaseDatabaseLocker lockerA = new LeaseDatabaseLocker();
brokerService.setBrokerName("First");
lockerA.setLeaseHolderId("First");
lockerA.configure(jdbc);
final LeaseDatabaseLocker lockerB = new LeaseDatabaseLocker();
brokerService.setBrokerName("Second");
lockerB.setLeaseHolderId("Second");
lockerB.configure(jdbc);
final AtomicBoolean blocked = new AtomicBoolean(true);
@ -75,11 +77,15 @@ public class LeaseDatabaseLockerTest {
lockerA.start();
printLockTable(connection);
assertTrue("First has lock", lockerA.keepAlive());
final CountDownLatch lockerBStarting = new CountDownLatch(1);
ExecutorService executor = Executors.newCachedThreadPool();
executor.execute(new Runnable() {
@Override
public void run() {
try {
lockerBStarting.countDown();
lockerB.start();
blocked.set(false);
printLockTable(connection);
@ -90,6 +96,14 @@ public class LeaseDatabaseLockerTest {
}
});
Wait.waitFor(new Wait.Condition() {
@Override
public boolean isSatisified() throws Exception {
return lockerBStarting.await(1, TimeUnit.SECONDS);
}
});
TimeUnit.MILLISECONDS.sleep(lockerB.getLockAcquireSleepInterval());
assertTrue("B is blocked", blocked.get());
assertTrue("A is good", lockerA.keepAlive());