Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-4365 - ensure 500ms retry time is enforce for kahaDbJdbcLeaseQueueMasterSlaveTest

Browse Source
This commit is contained in:
gtully 2013-10-01 13:18:36 +01:00
parent 92ee5c6bab
commit 40ea66556e
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java
View File

@ -52,8 +52,8 @@ public class kahaDbJdbcLeaseQueueMasterSlaveTest extends QueueMasterSlaveTestSup
leaseDatabaseLocker.setCreateTablesOnStartup(true); leaseDatabaseLocker.setCreateTablesOnStartup(true);
leaseDatabaseLocker.setDataSource(getExistingDataSource()); leaseDatabaseLocker.setDataSource(getExistingDataSource());
leaseDatabaseLocker.setStatements(new Statements()); leaseDatabaseLocker.setStatements(new Statements());
configureLocker(kahaDBPersistenceAdapter);
kahaDBPersistenceAdapter.setLocker(leaseDatabaseLocker); kahaDBPersistenceAdapter.setLocker(leaseDatabaseLocker);
configureLocker(kahaDBPersistenceAdapter);
configureBroker(master); configureBroker(master);
master.start(); master.start();
} }
@ -82,9 +82,8 @@ public class kahaDbJdbcLeaseQueueMasterSlaveTest extends QueueMasterSlaveTestSup
LeaseDatabaseLocker leaseDatabaseLocker = new LeaseDatabaseLocker(); LeaseDatabaseLocker leaseDatabaseLocker = new LeaseDatabaseLocker();
leaseDatabaseLocker.setDataSource(getExistingDataSource()); leaseDatabaseLocker.setDataSource(getExistingDataSource());
leaseDatabaseLocker.setStatements(new Statements()); leaseDatabaseLocker.setStatements(new Statements());
configureLocker(kahaDBPersistenceAdapter);
kahaDBPersistenceAdapter.setLocker(leaseDatabaseLocker); kahaDBPersistenceAdapter.setLocker(leaseDatabaseLocker);
configureLocker(kahaDBPersistenceAdapter);
configureBroker(broker); configureBroker(broker);
broker.start(); broker.start();
slave.set(broker); slave.set(broker);