diff options
| author | Keith Wall <kwall@apache.org> | 2014-03-28 17:14:25 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-03-28 17:14:25 +0000 |
| commit | 59f63df7016f77288fd5434e9e09557cd551eefd (patch) | |
| tree | a93b7059b600a5590f86552dd164ddfff296bb8a /qpid/java/broker-plugins/jdbc-store | |
| parent | e7b1fb49e4d5521c952f3ebed73384611c3ceb48 (diff) | |
| download | qpid-python-59f63df7016f77288fd5434e9e09557cd551eefd.tar.gz | |
NO-JIRA: Make the MessageStore and DurableConfigurationStore stateless. This changes
removes the StateManager and delegates the operational logging (open/close)
messages to the vhost.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-bdb-ha2@1582835 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/jdbc-store')
| -rw-r--r-- | qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/JDBCMessageStore.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/JDBCMessageStore.java b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/JDBCMessageStore.java index 55c8d3ef79..4ca9cb2395 100644 --- a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/JDBCMessageStore.java +++ b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/JDBCMessageStore.java @@ -289,12 +289,12 @@ public class JDBCMessageStore extends AbstractJDBCMessageStore implements Messag protected void implementationSpecificConfiguration(String name, Map<String, Object> storeSettings) throws ClassNotFoundException, SQLException { - String connectionURL = String.valueOf(storeSettings.get(CONNECTION_URL)); + _connectionURL = String.valueOf(storeSettings.get(CONNECTION_URL)); Object poolAttribute = storeSettings.get(CONNECTION_POOL); JDBCDetails details = null; - String[] components = connectionURL.split(":",3); + String[] components = _connectionURL.split(":",3); if(components.length >= 2) { String vendor = components[1]; @@ -303,7 +303,7 @@ public class JDBCMessageStore extends AbstractJDBCMessageStore implements Messag if(details == null) { - getLogger().info("Do not recognize vendor from connection URL: " + connectionURL); + getLogger().info("Do not recognize vendor from connection URL: " + _connectionURL); // TODO - is there a better default than derby details = DERBY_DETAILS; @@ -319,7 +319,7 @@ public class JDBCMessageStore extends AbstractJDBCMessageStore implements Messag connectionProviderFactory = new DefaultConnectionProviderFactory(); } - _connectionProvider = connectionProviderFactory.getConnectionProvider(connectionURL, storeSettings); + _connectionProvider = connectionProviderFactory.getConnectionProvider(_connectionURL, storeSettings); _blobType = MapValueConverter.getStringAttribute(JDBC_BLOB_TYPE, storeSettings, details.getBlobType()); _varBinaryType = MapValueConverter.getStringAttribute(JDBC_VARBINARY_TYPE, storeSettings, details.getVarBinaryType()); _useBytesMethodsForBlob = MapValueConverter.getBooleanAttribute(JDBC_BYTES_FOR_BLOB, storeSettings, details.isUseBytesMethodsForBlob()); @@ -334,7 +334,7 @@ public class JDBCMessageStore extends AbstractJDBCMessageStore implements Messag @Override public String getStoreLocation() { - return ""; + return _connectionURL; } @Override |