summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Rudyy <orudyy@apache.org>2014-08-01 18:04:38 +0000
committerAlex Rudyy <orudyy@apache.org>2014-08-01 18:04:38 +0000
commit290b63ca0be3e72432208c01887ac928ff7b8fe5 (patch)
tree5fccd0f297902cd1b11aa6e6cd8c9392a54fa483
parent5bbff8c0c74e94c51a653327970883a38540f0e5 (diff)
downloadqpid-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
-rw-r--r--qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java3
-rw-r--r--qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java3
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)
{