From 290b63ca0be3e72432208c01887ac928ff7b8fe5 Mon Sep 17 00:00:00 2001 From: Alex Rudyy Date: Fri, 1 Aug 2014 18:04:38 +0000 Subject: 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 --- .../apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java | 3 ++- .../org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) (limited to 'qpid/java') 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 providerAttributes = new HashMap<>(); - Set providerAttributeNames = connectionProviderFactory.getProviderAttributeNames(); + Set providerAttributeNames = new HashSet(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 providerAttributes = new HashMap<>(); - Set providerAttributeNames = connectionProviderFactory.getProviderAttributeNames(); + Set providerAttributeNames = new HashSet(connectionProviderFactory.getProviderAttributeNames()); providerAttributeNames.retainAll(parent.getContextKeys(false)); for(String attr : providerAttributeNames) { -- cgit v1.2.1