Skip to content

Commit

Permalink
Fix oversights in Config
Browse files Browse the repository at this point in the history
  • Loading branch information
viliam-durina committed Nov 14, 2017
1 parent 5f582db commit b02e8ac
Show file tree
Hide file tree
Showing 3 changed files with 107 additions and 87 deletions.
Expand Up @@ -35,6 +35,7 @@
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;

Expand Down Expand Up @@ -91,9 +92,9 @@ public class ClientConfig {

private ConfigPatternMatcher configPatternMatcher = new MatchingPointConfigPatternMatcher();

private Map<String, NearCacheConfig> nearCacheConfigMap = new ConcurrentHashMap<String, NearCacheConfig>();
private final Map<String, NearCacheConfig> nearCacheConfigMap = new ConcurrentHashMap<String, NearCacheConfig>();

private Map<String, ClientReliableTopicConfig> reliableTopicConfigMap
private final Map<String, ClientReliableTopicConfig> reliableTopicConfigMap
= new ConcurrentHashMap<String, ClientReliableTopicConfig>();

private Map<String, Map<String, QueryCacheConfig>> queryCacheConfigs;
Expand All @@ -102,7 +103,7 @@ public class ClientConfig {

private NativeMemoryConfig nativeMemoryConfig = new NativeMemoryConfig();

private List<ProxyFactoryConfig> proxyFactoryConfigs = new LinkedList<ProxyFactoryConfig>();
private final List<ProxyFactoryConfig> proxyFactoryConfigs = new LinkedList<ProxyFactoryConfig>();

private ManagedContext managedContext;

Expand Down Expand Up @@ -321,7 +322,11 @@ public Map<String, NearCacheConfig> getNearCacheConfigMap() {
* @return configured {@link com.hazelcast.client.config.ClientConfig} for chaining
*/
public ClientConfig setNearCacheConfigMap(Map<String, NearCacheConfig> nearCacheConfigMap) {
this.nearCacheConfigMap = nearCacheConfigMap;
this.nearCacheConfigMap.clear();
this.nearCacheConfigMap.putAll(nearCacheConfigMap);
for (Entry<String, NearCacheConfig> entry : this.nearCacheConfigMap.entrySet()) {
entry.getValue().setName(entry.getKey());
}
return this;
}

Expand Down Expand Up @@ -635,7 +640,8 @@ public List<ProxyFactoryConfig> getProxyFactoryConfigs() {
* @return configured {@link com.hazelcast.client.config.ClientConfig} for chaining
*/
public ClientConfig setProxyFactoryConfigs(List<ProxyFactoryConfig> proxyFactoryConfigs) {
this.proxyFactoryConfigs = proxyFactoryConfigs;
this.proxyFactoryConfigs.clear();
this.proxyFactoryConfigs.addAll(proxyFactoryConfigs);
return this;
}

Expand Down
Expand Up @@ -401,7 +401,7 @@ public CacheConfig findCacheConfig(String simpleName) {
if (simpleName == null) {
return null;
}
CacheSimpleConfig cacheSimpleConfig = nodeEngine.getConfig().findCacheConfig(simpleName);
CacheSimpleConfig cacheSimpleConfig = nodeEngine.getConfig().findCacheConfigOrNull(simpleName);
if (cacheSimpleConfig == null) {
return null;
}
Expand Down

0 comments on commit b02e8ac

Please sign in to comment.