From 40ea66556ecf68beb47919a15b31a379d7c4271f Mon Sep 17 00:00:00 2001 From: gtully Date: Tue, 1 Oct 2013 13:18:36 +0100 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-4365 - ensure 500ms retry time is enforce for kahaDbJdbcLeaseQueueMasterSlaveTest --- .../broker/ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java index ba59eb74b1..52026301de 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java @@ -52,8 +52,8 @@ public class kahaDbJdbcLeaseQueueMasterSlaveTest extends QueueMasterSlaveTestSup leaseDatabaseLocker.setCreateTablesOnStartup(true); leaseDatabaseLocker.setDataSource(getExistingDataSource()); leaseDatabaseLocker.setStatements(new Statements()); - configureLocker(kahaDBPersistenceAdapter); kahaDBPersistenceAdapter.setLocker(leaseDatabaseLocker); + configureLocker(kahaDBPersistenceAdapter); configureBroker(master); master.start(); } @@ -82,9 +82,8 @@ public class kahaDbJdbcLeaseQueueMasterSlaveTest extends QueueMasterSlaveTestSup LeaseDatabaseLocker leaseDatabaseLocker = new LeaseDatabaseLocker(); leaseDatabaseLocker.setDataSource(getExistingDataSource()); leaseDatabaseLocker.setStatements(new Statements()); - configureLocker(kahaDBPersistenceAdapter); kahaDBPersistenceAdapter.setLocker(leaseDatabaseLocker); - + configureLocker(kahaDBPersistenceAdapter); configureBroker(broker); broker.start(); slave.set(broker);