Fix some sonars in policy-models

[policy/models.git] / models-interactions / model-actors / actorServiceProvider / src / main / java / org / onap / policy / controlloop / actorserviceprovider / pipeline / ListenerManager.java

diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManager.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManager.java
index d34a3fb..999aea7 100644 (file)
--- a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManager.java
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManager.java
@@ -21,7 +21,8 @@
 package org.onap.policy.controlloop.actorserviceprovider.pipeline;
 
 import java.util.ArrayList;
-import java.util.IdentityHashMap;
+import java.util.HashMap;
+import java.util.Map;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import org.onap.policy.controlloop.actorserviceprovider.Util;
@@ -40,7 +41,7 @@ public class ListenerManager {
     /**
      * Listeners to be executed when {@link #stop()} is invoked.
      */
-    private final IdentityHashMap<Runnable, Void> listeners = new IdentityHashMap<>(5);
+    private final Map<Runnable, Void> listeners = new HashMap<>(5);
 
     /**
      * Indicates that operations within the pipeline should stop executing.
@@ -100,8 +101,7 @@ public class ListenerManager {
      * @param listener listener to be executed
      */
     protected void runListener(Runnable listener) {
-        // TODO do this asynchronously?
-        Util.logException(listener, "pipeline listener {} threw an exception", listener);
+        Util.runFunction(listener, "pipeline listener {} threw an exception", listener);
     }
 
     /**