diff options
author | Alex Rudyy <orudyy@apache.org> | 2014-08-01 18:04:38 +0000 |
---|---|---|
committer | Alex Rudyy <orudyy@apache.org> | 2014-08-01 18:04:38 +0000 |
commit | 290b63ca0be3e72432208c01887ac928ff7b8fe5 (patch) | |
tree | 5fccd0f297902cd1b11aa6e6cd8c9392a54fa483 | |
parent | 5bbff8c0c74e94c51a653327970883a38540f0e5 (diff) | |
download | qpid-python-290b63ca0be3e72432208c01887ac928ff7b8fe5.tar.gz |
QPID-5954: [Java Broker] Fix UnsupportedOperationException thrown from GenericJDBCConfigurationStore and GenericJDBCConfigurationStore on trying to evaluate settings for Bone Connection Pool provider
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1615185 13f79535-47bb-0310-9956-ffa450edef68
2 files changed, 4 insertions, 2 deletions
diff --git a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java index 554caebf5f..13d5c54ee4 100644 --- a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java +++ b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java @@ -26,6 +26,7 @@ import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.util.HashMap; +import java.util.HashSet; import java.util.Map; import java.util.Set; import java.util.concurrent.atomic.AtomicBoolean; @@ -113,7 +114,7 @@ public class GenericJDBCConfigurationStore extends AbstractJDBCConfigurationStor try { Map<String, String> providerAttributes = new HashMap<>(); - Set<String> providerAttributeNames = connectionProviderFactory.getProviderAttributeNames(); + Set<String> providerAttributeNames = new HashSet<String>(connectionProviderFactory.getProviderAttributeNames()); providerAttributeNames.retainAll(parent.getContextKeys(false)); for(String attr : providerAttributeNames) { diff --git a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java index 338ef52078..59e165acc2 100644 --- a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java +++ b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java @@ -27,6 +27,7 @@ import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.util.HashMap; +import java.util.HashSet; import java.util.Map; import java.util.Set; @@ -92,7 +93,7 @@ public class GenericJDBCMessageStore extends GenericAbstractJDBCMessageStore try { Map<String, String> providerAttributes = new HashMap<>(); - Set<String> providerAttributeNames = connectionProviderFactory.getProviderAttributeNames(); + Set<String> providerAttributeNames = new HashSet<String>(connectionProviderFactory.getProviderAttributeNames()); providerAttributeNames.retainAll(parent.getContextKeys(false)); for(String attr : providerAttributeNames) { |