diff options
| author | Keith Wall <kwall@apache.org> | 2014-06-18 20:51:43 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-06-18 20:51:43 +0000 |
| commit | 326b9560c14d1c30eb71c1396858791f9187d11e (patch) | |
| tree | 34ba78548d48295e88b9e038f382bd8861f32500 /qpid/java/broker-plugins/jdbc-store/src/test | |
| parent | 2622dda9c7d3267efd985b5ae5928b99063d2fa7 (diff) | |
| download | qpid-python-326b9560c14d1c30eb71c1396858791f9187d11e.tar.gz | |
QPID-5800: [Java Broker] Refactor Derby/JDBC message store implementations to separate message and config store implementations.
* Message store implementations can now be used in isolation, which is useful when the user is using a JSON VirtualHostNode with
another persistent store implementation.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1603626 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/jdbc-store/src/test')
| -rw-r--r-- | qpid/java/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/java/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java b/qpid/java/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java index 1f03b7f75f..8261e93347 100644 --- a/qpid/java/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java +++ b/qpid/java/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java @@ -52,7 +52,7 @@ public class JDBCMessageStoreTest extends MessageStoreTestCase public void testOnDelete() throws Exception { - Set<String> expectedTables = JDBCMessageStore.MESSAGE_STORE_TABLE_NAMES; + Set<String> expectedTables = GenericJDBCMessageStore.MESSAGE_STORE_TABLE_NAMES; assertTablesExist(expectedTables, true); getStore().closeMessageStore(); assertTablesExist(expectedTables, true); @@ -65,7 +65,7 @@ public class JDBCMessageStoreTest extends MessageStoreTestCase { _connectionURL = "jdbc:derby:memory:/" + getTestName() + ";create=true"; Map<String, Object> messageStoreSettings = new HashMap<String, Object>(); - messageStoreSettings.put(JDBCMessageStore.CONNECTION_URL, _connectionURL); + messageStoreSettings.put(GenericJDBCMessageStore.CONNECTION_URL, _connectionURL); return messageStoreSettings; } @@ -73,7 +73,7 @@ public class JDBCMessageStoreTest extends MessageStoreTestCase @Override protected MessageStore createMessageStore() { - return (new JDBCMessageStore()).getMessageStore(); + return new GenericJDBCMessageStore(); } private void assertTablesExist(Set<String> expectedTables, boolean exists) throws SQLException |