diff options
author | Jakub Dudycz <jakub.dudycz@nokia.com> | 2018-01-25 18:12:01 +0100 |
---|---|---|
committer | Patrick Brady <pb071s@att.com> | 2018-01-26 17:14:05 +0000 |
commit | abe171a152e193787b21404503542241654ea891 (patch) | |
tree | 55d1a2662fbd9c447a24f0f3860c63cb89a98807 | |
parent | 5cd7ee0c6e5e1e52577c399fd2a3da4da589f59b (diff) |
CoreRegistry fixes
Change-Id: Ib2a54d01b038ea760b8d6078334067009b528e4f
Issue-ID: APPC-527
Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com>
-rw-r--r-- | appc-client/client-lib/src/main/java/org/onap/appc/client/impl/core/CoreRegistry.java | 29 |
1 files changed, 15 insertions, 14 deletions
diff --git a/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/core/CoreRegistry.java b/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/core/CoreRegistry.java index e0a0c5b34..d12a44018 100644 --- a/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/core/CoreRegistry.java +++ b/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/core/CoreRegistry.java @@ -27,16 +27,15 @@ package org.onap.appc.client.impl.core; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; -/** client lib Registry +/** + * client lib Registry */ -class CoreRegistry<T>{ - private Map<String, T> registry = - new ConcurrentHashMap<String, T>(); +class CoreRegistry<T> { - final private EmptyRegistryCallback emptyRegistryCallback; + private final EmptyRegistryCallback emptyRegistryCallback; + private Map<String, T> registry = new ConcurrentHashMap<>(); - - CoreRegistry(EmptyRegistryCallback emptyRegistryCallback){ + CoreRegistry(EmptyRegistryCallback emptyRegistryCallback) { this.emptyRegistryCallback = emptyRegistryCallback; } @@ -44,27 +43,29 @@ class CoreRegistry<T>{ registry.put(key, obj); } - <T> T unregister(String key) { - T item = (T) registry.remove(key); - if(registry.isEmpty()) { + T unregister(String key) { + T item = registry.remove(key); + if (registry.isEmpty()) { emptyRegistryCallback.emptyCallback(); } return item; } - <T> T get(String key){ - return (T) registry.get(key); + T get(String key) { + return registry.get(key); } synchronized boolean isExist(String key) { return registry.containsKey(key); } - boolean isEmpty(){ + boolean isEmpty() { return registry.isEmpty(); } - public interface EmptyRegistryCallback{ + @FunctionalInterface + public interface EmptyRegistryCallback { + void emptyCallback(); } } |