diff options
| author | Keith Wall <kwall@apache.org> | 2012-03-30 08:55:05 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2012-03-30 08:55:05 +0000 |
| commit | 8e76403adf9b23285c3e0c2c05d0927d9ad9283e (patch) | |
| tree | 50b3585f7752f3014dbb98785ac70f4cc38e3129 /java/systests | |
| parent | a2f346cbdaf708489184bdb654af4c64d9cbed8f (diff) | |
| download | qpid-python-8e76403adf9b23285c3e0c2c05d0927d9ad9283e.tar.gz | |
QPID-3916: Change message store interface to extend DurableConfigurationStore and change VirtualHost contructor
Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1307317 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/systests')
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java | 18 |
1 files changed, 5 insertions, 13 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java b/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java index 8ffc09930e..c3b006f371 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java +++ b/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java @@ -38,7 +38,7 @@ import java.nio.ByteBuffer; import java.util.HashMap; import java.util.Iterator; -public class SlowMessageStore implements MessageStore, DurableConfigurationStore +public class SlowMessageStore implements MessageStore { private static final Logger _logger = Logger.getLogger(SlowMessageStore.class); private static final String DELAYS = "delays"; @@ -160,11 +160,11 @@ public class SlowMessageStore implements MessageStore, DurableConfigurationStore public void configureMessageStore(String name, - MessageStoreRecoveryHandler recoveryHandler, - Configuration config, - LogSubject logSubject) throws Exception + MessageStoreRecoveryHandler messageRecoveryHandler, + TransactionLogRecoveryHandler tlogRecoveryHandler, + Configuration config, LogSubject logSubject) throws Exception { - _realStore.configureMessageStore(name, recoveryHandler, config, logSubject); + _realStore.configureMessageStore(name, messageRecoveryHandler, tlogRecoveryHandler, config, logSubject); } public void close() throws Exception @@ -227,14 +227,6 @@ public class SlowMessageStore implements MessageStore, DurableConfigurationStore doPostDelay("removeQueue"); } - public void configureTransactionLog(String name, - TransactionLogRecoveryHandler recoveryHandler, - Configuration storeConfiguration, LogSubject logSubject) - throws Exception - { - _realStore.configureTransactionLog(name, recoveryHandler, storeConfiguration, logSubject); - } - public Transaction newTransaction() { doPreDelay("beginTran"); |
