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 | da8070494a06d0b6c37127eb0a3439e394bddd31 (patch) | |
| tree | 85ca23ccf051f3157a5f4b3be1b7752dfe576c6d /qpid/java/bdbstore/src/test | |
| parent | 6e605c53e91d5b9b1bf46985c5cf8bd94a34de4d (diff) | |
| download | qpid-python-da8070494a06d0b6c37127eb0a3439e394bddd31.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@1307317 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/bdbstore/src/test')
2 files changed, 5 insertions, 3 deletions
diff --git a/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java b/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java index 74fba168a9..0ccfbe5a2a 100644 --- a/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java +++ b/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java @@ -37,6 +37,7 @@ import org.apache.qpid.server.store.MessageMetaDataType; import org.apache.qpid.server.store.MessageStore; import org.apache.qpid.server.store.StorableMessageMetaData; import org.apache.qpid.server.store.StoredMessage; +import org.apache.qpid.server.store.Transaction; import org.apache.qpid.server.store.TransactionLogResource; import org.apache.qpid.transport.DeliveryProperties; import org.apache.qpid.transport.Header; @@ -419,7 +420,7 @@ public class BDBMessageStoreTest extends org.apache.qpid.server.store.MessageSto } }; - MessageStore.Transaction txn = log.newTransaction(); + Transaction txn = log.newTransaction(); txn.enqueueMessage(mockQueue, new MockMessage(1L)); txn.enqueueMessage(mockQueue, new MockMessage(5L)); @@ -457,7 +458,7 @@ public class BDBMessageStoreTest extends org.apache.qpid.server.store.MessageSto } }; - MessageStore.Transaction txn = log.newTransaction(); + Transaction txn = log.newTransaction(); txn.enqueueMessage(mockQueue, new MockMessage(21L)); txn.abortTran(); @@ -498,7 +499,7 @@ public class BDBMessageStoreTest extends org.apache.qpid.server.store.MessageSto } }; - MessageStore.Transaction txn = log.newTransaction(); + Transaction txn = log.newTransaction(); txn.enqueueMessage(mockQueue, new MockMessage(30L)); txn.commitTran(); diff --git a/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java b/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java index b906ab2474..4e201d5473 100644 --- a/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java +++ b/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java @@ -20,6 +20,7 @@ */ package org.apache.qpid.server.store.berkeleydb; + import static org.apache.qpid.server.store.berkeleydb.BDBStoreUpgradeTestPreparer.NON_DURABLE_QUEUE_NAME; import static org.apache.qpid.server.store.berkeleydb.BDBStoreUpgradeTestPreparer.QUEUE_NAME; import static org.apache.qpid.server.store.berkeleydb.BDBStoreUpgradeTestPreparer.SELECTOR_SUB_NAME; |