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;
/**
* 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.
* @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);
}
/**