From 59f63df7016f77288fd5434e9e09557cd551eefd Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Fri, 28 Mar 2014 17:14:25 +0000 Subject: 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 --- .../org/apache/qpid/server/store/jdbc/JDBCMessageStore.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'qpid/java/broker-plugins/jdbc-store/src') 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 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 -- cgit v1.2.1