Merge "Actor redesign."

48 files changed, 6518 insertions, 84 deletions

diff --git a/models-interactions/model-actors/actor.appc/src/main/java/org/onap/policy/controlloop/actor/appc/AppcActorServiceProvider.java b/models-interactions/model-actors/actor.appc/src/main/java/org/onap/policy/controlloop/actor/appc/AppcActorServiceProvider.java
index e2c997bca..0da1e2a27 100644
--- a/models-interactions/model-actors/actor.appc/src/main/java/org/onap/policy/controlloop/actor/appc/AppcActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.appc/src/main/java/org/onap/policy/controlloop/actor/appc/AppcActorServiceProvider.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * APPCActorServiceProvider
  * ================================================================================
- * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -33,13 +33,15 @@ import org.onap.policy.common.utils.coder.CoderException;
 import org.onap.policy.common.utils.coder.StandardCoder;
 import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 import org.onap.policy.controlloop.policy.Policy;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-public class AppcActorServiceProvider implements Actor {
+public class AppcActorServiceProvider extends ActorImpl {
+    private static final String NAME = "APPC";
+
     private static final Logger logger = LoggerFactory.getLogger(AppcActorServiceProvider.class);
 
     private static final StandardCoder coder = new StandardCoder();
@@ -62,9 +64,13 @@ public class AppcActorServiceProvider implements Actor {
     private static final ImmutableMap<String, List<String>> payloads = new ImmutableMap.Builder<String, List<String>>()
             .put(RECIPE_MODIFY, ImmutableList.of("generic-vnf.vnf-id")).build();
 
+    public AppcActorServiceProvider() {
+        super(NAME);
+    }
+
     @Override
     public String actor() {
-        return "APPC";
+        return NAME;
     }
 
     @Override
diff --git a/models-interactions/model-actors/actor.appclcm/src/main/java/org/onap/policy/controlloop/actor/appclcm/AppcLcmActorServiceProvider.java b/models-interactions/model-actors/actor.appclcm/src/main/java/org/onap/policy/controlloop/actor/appclcm/AppcLcmActorServiceProvider.java
index fb307587d..47898f7d8 100644
--- a/models-interactions/model-actors/actor.appclcm/src/main/java/org/onap/policy/controlloop/actor/appclcm/AppcLcmActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.appclcm/src/main/java/org/onap/policy/controlloop/actor/appclcm/AppcLcmActorServiceProvider.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * AppcLcmActorServiceProvider
  * ================================================================================
- * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved.
  * Modifications copyright (c) 2018 Nokia
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
@@ -38,13 +38,15 @@ import org.onap.policy.appclcm.AppcLcmOutput;
 import org.onap.policy.appclcm.AppcLcmResponseCode;
 import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 import org.onap.policy.controlloop.policy.Policy;
 import org.onap.policy.controlloop.policy.PolicyResult;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class AppcLcmActorServiceProvider implements Actor {
+public class AppcLcmActorServiceProvider extends ActorImpl {
+
+    private static final String NAME = "APPC";
 
     private static final Logger logger = LoggerFactory.getLogger(AppcLcmActorServiceProvider.class);
 
@@ -74,9 +76,13 @@ public class AppcLcmActorServiceProvider implements Actor {
             new ImmutableMap.Builder<String, List<String>>().put(RECIPE_RESTART, ImmutableList.of(APPC_VM_ID))
                     .put(RECIPE_MODIFY, ImmutableList.of(APPC_REQUEST_PARAMS, APPC_CONFIG_PARAMS)).build();
 
+    public AppcLcmActorServiceProvider() {
+        super(NAME);
+    }
+
     @Override
     public String actor() {
-        return "APPC";
+        return NAME;
     }
 
     @Override
diff --git a/models-interactions/model-actors/actor.cds/src/main/java/org/onap/policy/controlloop/actor/cds/CdsActorServiceProvider.java b/models-interactions/model-actors/actor.cds/src/main/java/org/onap/policy/controlloop/actor/cds/CdsActorServiceProvider.java
index df13ba306..05ff02e5c 100644
--- a/models-interactions/model-actors/actor.cds/src/main/java/org/onap/policy/controlloop/actor/cds/CdsActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.cds/src/main/java/org/onap/policy/controlloop/actor/cds/CdsActorServiceProvider.java
@@ -1,6 +1,7 @@
 /*-
  * ============LICENSE_START=======================================================
  * Copyright (C) 2019 Bell Canada. All rights reserved.
+ * Modifications Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -47,7 +48,7 @@ import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
 import org.onap.policy.controlloop.actor.cds.constants.CdsActorConstants;
 import org.onap.policy.controlloop.actor.cds.request.CdsActionRequest;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 import org.onap.policy.controlloop.policy.Policy;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -55,10 +56,14 @@ import org.slf4j.LoggerFactory;
 /**
  * CDS Actor service-provider implementation. This is a deploy dark feature for El-Alto release.
  */
-public class CdsActorServiceProvider implements Actor {
+public class CdsActorServiceProvider extends ActorImpl {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(CdsActorServiceProvider.class);
 
+    public CdsActorServiceProvider() {
+        super(CdsActorConstants.CDS_ACTOR);
+    }
+
     /**
      * {@inheritDoc}.
      */
diff --git a/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/BandwidthOnDemandOperator.java b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/BandwidthOnDemandOperator.java
new file mode 100644
index 000000000..0e721bf8c
--- /dev/null
+++ b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/BandwidthOnDemandOperator.java
@@ -0,0 +1,102 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actor.sdnc;
+
+import java.util.UUID;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+import org.onap.policy.sdnc.SdncHealRequest;
+import org.onap.policy.sdnc.SdncHealRequestHeaderInfo;
+import org.onap.policy.sdnc.SdncHealRequestInfo;
+import org.onap.policy.sdnc.SdncHealServiceInfo;
+import org.onap.policy.sdnc.SdncHealVfModuleInfo;
+import org.onap.policy.sdnc.SdncHealVfModuleParameter;
+import org.onap.policy.sdnc.SdncHealVfModuleParametersInfo;
+import org.onap.policy.sdnc.SdncHealVfModuleRequestInput;
+import org.onap.policy.sdnc.SdncHealVnfInfo;
+import org.onap.policy.sdnc.SdncRequest;
+
+public class BandwidthOnDemandOperator extends SdncOperator {
+    public static final String NAME = "BandwidthOnDemand";
+
+    /**
+     * Constructs the object.
+     *
+     * @param actorName name of the actor with which this operator is associated
+     */
+    public BandwidthOnDemandOperator(String actorName) {
+        super(actorName, NAME);
+    }
+
+    @Override
+    protected SdncRequest constructRequest(VirtualControlLoopEvent onset) {
+        String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
+        if (StringUtils.isBlank(serviceInstance)) {
+            throw new IllegalArgumentException("missing enrichment data, service-instance-id");
+        }
+
+        SdncHealVfModuleParameter bandwidth = new SdncHealVfModuleParameter();
+        bandwidth.setName("bandwidth");
+        bandwidth.setValue(onset.getAai().get("bandwidth"));
+
+        SdncHealVfModuleParameter timeStamp = new SdncHealVfModuleParameter();
+        timeStamp.setName("bandwidth-change-time");
+        timeStamp.setValue(onset.getAai().get("bandwidth-change-time"));
+
+        SdncHealVfModuleParametersInfo vfParametersInfo = new SdncHealVfModuleParametersInfo();
+        vfParametersInfo.addParameters(bandwidth);
+        vfParametersInfo.addParameters(timeStamp);
+
+        SdncHealVfModuleRequestInput vfRequestInfo = new SdncHealVfModuleRequestInput();
+        vfRequestInfo.setVfModuleParametersInfo(vfParametersInfo);
+
+        SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
+        serviceInfo.setServiceInstanceId(serviceInstance);
+
+        SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
+        requestInfo.setRequestAction("SdwanBandwidthChange");
+
+        SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
+        headerInfo.setSvcAction("update");
+        headerInfo.setSvcRequestId(UUID.randomUUID().toString());
+
+        SdncRequest request = new SdncRequest();
+        request.setNsInstanceId(serviceInstance);
+        request.setRequestId(onset.getRequestId());
+        request.setUrl("/GENERIC-RESOURCE-API:vf-module-topology-operation");
+
+        SdncHealVnfInfo vnfInfo = new SdncHealVnfInfo();
+        vnfInfo.setVnfId(onset.getAai().get("vnfId"));
+
+        SdncHealVfModuleInfo vfModuleInfo = new SdncHealVfModuleInfo();
+        vfModuleInfo.setVfModuleId("");
+
+        SdncHealRequest healRequest = new SdncHealRequest();
+        healRequest.setVnfInfo(vnfInfo);
+        healRequest.setVfModuleInfo(vfModuleInfo);
+        healRequest.setRequestHeaderInfo(headerInfo);
+        healRequest.setVfModuleRequestInput(vfRequestInfo);
+        healRequest.setRequestInfo(requestInfo);
+        healRequest.setServiceInfo(serviceInfo);
+        request.setHealRequest(healRequest);
+        return request;
+    }
+}
diff --git a/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/RerouteOperator.java b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/RerouteOperator.java
new file mode 100644
index 000000000..59af31f4f
--- /dev/null
+++ b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/RerouteOperator.java
@@ -0,0 +1,81 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actor.sdnc;
+
+import java.util.UUID;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+import org.onap.policy.sdnc.SdncHealNetworkInfo;
+import org.onap.policy.sdnc.SdncHealRequest;
+import org.onap.policy.sdnc.SdncHealRequestHeaderInfo;
+import org.onap.policy.sdnc.SdncHealRequestInfo;
+import org.onap.policy.sdnc.SdncHealServiceInfo;
+import org.onap.policy.sdnc.SdncRequest;
+
+public class RerouteOperator extends SdncOperator {
+    public static final String NAME = "Reroute";
+
+    /**
+     * Constructs the object.
+     *
+     * @param actorName name of the actor with which this operator is associated
+     */
+    public RerouteOperator(String actorName) {
+        super(actorName, NAME);
+    }
+
+    @Override
+    protected SdncRequest constructRequest(VirtualControlLoopEvent onset) {
+        String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
+        if (StringUtils.isBlank(serviceInstance)) {
+            throw new IllegalArgumentException("missing enrichment data, service-instance-id");
+        }
+        SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
+        serviceInfo.setServiceInstanceId(serviceInstance);
+
+        String networkId = onset.getAai().get("network-information.network-id");
+        if (StringUtils.isBlank(networkId)) {
+            throw new IllegalArgumentException("missing enrichment data, network-id");
+        }
+        SdncHealNetworkInfo networkInfo = new SdncHealNetworkInfo();
+        networkInfo.setNetworkId(networkId);
+
+        SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
+        requestInfo.setRequestAction("ReoptimizeSOTNInstance");
+
+        SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
+        headerInfo.setSvcAction("reoptimize");
+        headerInfo.setSvcRequestId(UUID.randomUUID().toString());
+
+        SdncRequest request = new SdncRequest();
+        request.setNsInstanceId(serviceInstance);
+        request.setRequestId(onset.getRequestId());
+        request.setUrl("/GENERIC-RESOURCE-API:network-topology-operation");
+
+        SdncHealRequest healRequest = new SdncHealRequest();
+        healRequest.setRequestHeaderInfo(headerInfo);
+        healRequest.setNetworkInfo(networkInfo);
+        healRequest.setRequestInfo(requestInfo);
+        healRequest.setServiceInfo(serviceInfo);
+        request.setHealRequest(healRequest);
+        return request;
+    }
+}
diff --git a/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncActorServiceProvider.java b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncActorServiceProvider.java
index 24d019f41..13276f929 100644
--- a/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncActorServiceProvider.java
@@ -4,7 +4,7 @@
  * ================================================================================
  * Copyright (C) 2018-2019 Huawei Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
- * Modifications Copyright (C) 2019 AT&T Intellectual Property.
+ * Modifications Copyright (C) 2019-2020 AT&T Intellectual Property.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -26,10 +26,14 @@ import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import java.util.Collections;
 import java.util.List;
+import java.util.Map;
 import java.util.UUID;
+import java.util.function.Function;
 import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.Util;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.HttpActorParams;
 import org.onap.policy.controlloop.policy.Policy;
 import org.onap.policy.sdnc.SdncHealNetworkInfo;
 import org.onap.policy.sdnc.SdncHealRequest;
@@ -45,10 +49,13 @@ import org.onap.policy.sdnc.SdncRequest;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
-public class SdncActorServiceProvider implements Actor {
+public class SdncActorServiceProvider extends ActorImpl {
     private static final Logger logger = LoggerFactory.getLogger(SdncActorServiceProvider.class);
 
+    public static final String NAME = "SDNC";
+
+    // TODO old code: remove lines down to **HERE**
+
     // Strings for Sdnc Actor
     private static final String SDNC_ACTOR = "SDNC";
 
@@ -62,8 +69,36 @@ public class SdncActorServiceProvider implements Actor {
     private static final String RECIPE_BW_ON_DEMAND = "BandwidthOnDemand";
 
     private static final ImmutableList<String> recipes = ImmutableList.of(RECIPE_REROUTE);
-    private static final ImmutableMap<String, List<String>> targets =
-            new ImmutableMap.Builder<String, List<String>>().put(RECIPE_REROUTE, ImmutableList.of(TARGET_VM)).build();
+    private static final ImmutableMap<String, List<String>> targets = new ImmutableMap.Builder<String, List<String>>()
+                    .put(RECIPE_REROUTE, ImmutableList.of(TARGET_VM)).build();
+
+    // **HERE**
+
+    /**
+     * Constructs the object.
+     */
+    public SdncActorServiceProvider() {
+        // @formatter:off
+        super(NAME,
+            new RerouteOperator(NAME),
+            new BandwidthOnDemandOperator(NAME));
+
+        // @formatter:on
+    }
+
+    @Override
+    protected Function<String, Map<String, Object>> makeOperatorParameters(Map<String, Object> actorParameters) {
+        String actorName = getName();
+
+        // @formatter:off
+        return Util.translate(actorName, actorParameters, HttpActorParams.class)
+                        .doValidation(actorName)
+                        .makeOperationParameters(actorName);
+        // @formatter:on
+    }
+
+
+    // TODO old code: remove lines down to **HERE**
 
     @Override
     public String actor() {
@@ -93,16 +128,15 @@ public class SdncActorServiceProvider implements Actor {
      * @param policy the policy
      * @return the constructed request
      */
-    public SdncRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation,
-            Policy policy) {
+    public SdncRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation, Policy policy) {
         switch (policy.getRecipe()) {
             case RECIPE_REROUTE:
                 return constructReOptimizeRequest(onset);
             case RECIPE_BW_ON_DEMAND:
-                logger.info("Construct request for receipe {}" , RECIPE_BW_ON_DEMAND);
+                logger.info("Construct request for receipe {}", RECIPE_BW_ON_DEMAND);
                 return constructBwOnDemandRequest(onset);
             default:
-                logger.info("Unsupported recipe {} " + policy.getRecipe());
+                logger.info("Unsupported recipe {}", policy.getRecipe());
                 return null;
         }
     }
@@ -199,4 +233,6 @@ public class SdncActorServiceProvider implements Actor {
         request.setHealRequest(healRequest);
         return request;
     }
+
+    // **HERE**
 }
diff --git a/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncOperator.java b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncOperator.java
new file mode 100644
index 000000000..c2e4c8f8b
--- /dev/null
+++ b/models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncOperator.java
@@ -0,0 +1,144 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actor.sdnc;
+
+import java.util.HashMap;
+import java.util.Map;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import lombok.AccessLevel;
+import lombok.Getter;
+import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
+import org.onap.policy.common.endpoints.http.client.HttpClient;
+import org.onap.policy.common.endpoints.http.client.HttpClientFactoryInstance;
+import org.onap.policy.common.endpoints.utils.NetLoggerUtil;
+import org.onap.policy.common.endpoints.utils.NetLoggerUtil.EventType;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.controlloop.ControlLoopOperation;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+import org.onap.policy.controlloop.actorserviceprovider.Util;
+import org.onap.policy.controlloop.actorserviceprovider.impl.OperatorPartial;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ControlLoopOperationParams;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.HttpParams;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ParameterValidationRuntimeException;
+import org.onap.policy.controlloop.policy.PolicyResult;
+import org.onap.policy.sdnc.SdncRequest;
+import org.onap.policy.sdnc.SdncResponse;
+import org.onap.policy.sdnc.util.Serialization;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Superclass for SDNC Operators.
+ */
+public abstract class SdncOperator extends OperatorPartial {
+    private static final Logger logger = LoggerFactory.getLogger(SdncOperator.class);
+
+    @Getter(AccessLevel.PROTECTED)
+    private HttpClient client;
+
+    /**
+     * URI path for this particular operation.
+     */
+    private String path;
+
+    /**
+     * Constructs the object.
+     *
+     * @param actorName name of the actor with which this operator is associated
+     * @param name operation name
+     */
+    public SdncOperator(String actorName, String name) {
+        super(actorName, name);
+    }
+
+    // TODO add a junit for this and for plug-in via ActorService
+    @Override
+    protected void doConfigure(Map<String, Object> parameters) {
+        HttpParams params = Util.translate(getFullName(), parameters, HttpParams.class);
+        ValidationResult result = params.validate(getFullName());
+        if (!result.isValid()) {
+            throw new ParameterValidationRuntimeException("invalid parameters", result);
+        }
+
+        client = HttpClientFactoryInstance.getClientFactory().get(params.getClientName());
+        path = params.getPath();
+    }
+
+    @Override
+    protected ControlLoopOperation doOperation(ControlLoopOperationParams params, int attempt,
+                    ControlLoopOperation operation) {
+
+        SdncRequest request = constructRequest(params.getContext().getEvent());
+        PolicyResult result = doRequest(request);
+
+        return setOutcome(params, operation, result);
+    }
+
+    /**
+     * Constructs the request.
+     *
+     * @param onset event for which the request should be constructed
+     * @return a new request
+     */
+    protected abstract SdncRequest constructRequest(VirtualControlLoopEvent onset);
+
+    /**
+     * Posts the request and retrieves the response.
+     *
+     * @param sdncRequest request to be posted
+     * @return the result of the request
+     */
+    private PolicyResult doRequest(SdncRequest sdncRequest) {
+        Map<String, Object> headers = new HashMap<>();
+
+        headers.put("Accept", "application/json");
+        String sdncUrl = client.getBaseUrl();
+
+        String sdncRequestJson = Serialization.gsonPretty.toJson(sdncRequest);
+
+        // TODO move this into a utility
+        NetLoggerUtil.log(EventType.OUT, CommInfrastructure.REST, sdncUrl, sdncRequestJson);
+        logger.info("[OUT|{}|{}|]{}{}", CommInfrastructure.REST, sdncUrl, NetLoggerUtil.SYSTEM_LS, sdncRequestJson);
+
+        Entity<SdncRequest> entity = Entity.entity(sdncRequest, MediaType.APPLICATION_JSON);
+
+        // TODO modify this to use asynchronous client operations
+        Response rawResponse = client.post(path, entity, headers);
+        String strResponse = HttpClient.getBody(rawResponse, String.class);
+
+        // TODO move this into a utility
+        NetLoggerUtil.log(EventType.IN, CommInfrastructure.REST, sdncUrl, strResponse);
+        logger.info("[IN|{}|{}|]{}{}", "Sdnc", sdncUrl, NetLoggerUtil.SYSTEM_LS, strResponse);
+        logger.info("Response to Sdnc Heal post:");
+        logger.info(strResponse);
+
+        SdncResponse response = Serialization.gsonPretty.fromJson(strResponse, SdncResponse.class);
+
+        if (response.getResponseOutput() == null || !"200".equals(response.getResponseOutput().getResponseCode())) {
+            logger.info("Sdnc Heal Restcall failed with http error code {}", rawResponse.getStatus());
+            return PolicyResult.FAILURE;
+        }
+
+        return PolicyResult.SUCCESS;
+    }
+}
diff --git a/models-interactions/model-actors/actor.sdnr/src/main/java/org/onap/policy/controlloop/actor/sdnr/SdnrActorServiceProvider.java b/models-interactions/model-actors/actor.sdnr/src/main/java/org/onap/policy/controlloop/actor/sdnr/SdnrActorServiceProvider.java
index 4367f54c5..0919779a5 100644
--- a/models-interactions/model-actors/actor.sdnr/src/main/java/org/onap/policy/controlloop/actor/sdnr/SdnrActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.sdnr/src/main/java/org/onap/policy/controlloop/actor/sdnr/SdnrActorServiceProvider.java
@@ -3,7 +3,7 @@
  * SdnrActorServiceProvider
  * ================================================================================
  * Copyright (C) 2018 Wipro Limited Intellectual Property. All rights reserved.
- * Modifications Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2019-2020 AT&T Intellectual Property. All rights reserved.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -23,14 +23,12 @@ package org.onap.policy.controlloop.actor.sdnr;
 
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
-
 import java.util.Collections;
 import java.util.List;
-
 import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.ControlLoopResponse;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 import org.onap.policy.controlloop.policy.Policy;
 import org.onap.policy.controlloop.policy.PolicyResult;
 import org.onap.policy.sdnr.PciCommonHeader;
@@ -39,11 +37,12 @@ import org.onap.policy.sdnr.PciRequestWrapper;
 import org.onap.policy.sdnr.PciResponse;
 import org.onap.policy.sdnr.PciResponseCode;
 import org.onap.policy.sdnr.PciResponseWrapper;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class SdnrActorServiceProvider implements Actor {
+public class SdnrActorServiceProvider extends ActorImpl {
+
+    private static final String NAME = "SDNR";
 
     public static class Pair<A, B> {
         public final A result;
@@ -81,9 +80,13 @@ public class SdnrActorServiceProvider implements Actor {
     private static final ImmutableMap<String, List<String>> payloads = new ImmutableMap.Builder<String, List<String>>()
             .put(RECIPE_MODIFY, ImmutableList.of(SDNR_REQUEST_PARAMS, SDNR_CONFIG_PARAMS)).build();
 
+    public SdnrActorServiceProvider() {
+        super(NAME);
+    }
+
     @Override
     public String actor() {
-        return "SDNR";
+        return NAME;
     }
 
     @Override
@@ -275,7 +278,7 @@ public class SdnrActorServiceProvider implements Actor {
         /* The ControlLoop response determined from the SDNR Response and input event. */
         ControlLoopResponse clRsp = new ControlLoopResponse();
         clRsp.setPayload(sdnrResponse.getPayload());
-        clRsp.setFrom("SDNR");
+        clRsp.setFrom(NAME);
         clRsp.setTarget("DCAE");
         clRsp.setClosedLoopControlName(event.getClosedLoopControlName());
         clRsp.setPolicyName(event.getPolicyName());
diff --git a/models-interactions/model-actors/actor.so/src/main/java/org/onap/policy/controlloop/actor/so/SoActorServiceProvider.java b/models-interactions/model-actors/actor.so/src/main/java/org/onap/policy/controlloop/actor/so/SoActorServiceProvider.java
index b85307547..a743f49c0 100644
--- a/models-interactions/model-actors/actor.so/src/main/java/org/onap/policy/controlloop/actor/so/SoActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.so/src/main/java/org/onap/policy/controlloop/actor/so/SoActorServiceProvider.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * SOActorServiceProvider
  * ================================================================================
- * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -35,7 +35,7 @@ import org.onap.aai.domain.yang.Tenant;
 import org.onap.policy.aai.AaiCqResponse;
 import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 import org.onap.policy.controlloop.policy.Policy;
 import org.onap.policy.so.SoCloudConfiguration;
 import org.onap.policy.so.SoManager;
@@ -51,7 +51,7 @@ import org.onap.policy.so.util.Serialization;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class SoActorServiceProvider implements Actor {
+public class SoActorServiceProvider extends ActorImpl {
     private static final Logger logger = LoggerFactory.getLogger(SoActorServiceProvider.class);
 
     private static final String TENANT_NOT_FOUND = "Tenant Item not found in AAI response {}";
@@ -89,6 +89,10 @@ public class SoActorServiceProvider implements Actor {
     private static String lastServiceItemServiceInstanceId;
     private static String lastVfModuleItemVfModuleInstanceId;
 
+    public SoActorServiceProvider() {
+        super(SO_ACTOR);
+    }
+
     @Override
     public String actor() {
         return SO_ACTOR;
diff --git a/models-interactions/model-actors/actor.vfc/src/main/java/org/onap/policy/controlloop/actor/vfc/VfcActorServiceProvider.java b/models-interactions/model-actors/actor.vfc/src/main/java/org/onap/policy/controlloop/actor/vfc/VfcActorServiceProvider.java
index 1ca379f71..8d560ef3c 100644
--- a/models-interactions/model-actors/actor.vfc/src/main/java/org/onap/policy/controlloop/actor/vfc/VfcActorServiceProvider.java
+++ b/models-interactions/model-actors/actor.vfc/src/main/java/org/onap/policy/controlloop/actor/vfc/VfcActorServiceProvider.java
@@ -1,7 +1,7 @@
 /*-
  * ============LICENSE_START=======================================================
  * Copyright (C) 2017-2018 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2018-2020 AT&T Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -22,21 +22,19 @@ package org.onap.policy.controlloop.actor.vfc;
 
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
-
 import java.util.Collections;
 import java.util.List;
-
 import org.onap.policy.aai.AaiCqResponse;
 import org.onap.policy.controlloop.ControlLoopOperation;
 import org.onap.policy.controlloop.VirtualControlLoopEvent;
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 import org.onap.policy.controlloop.policy.Policy;
 import org.onap.policy.vfc.VfcHealActionVmInfo;
 import org.onap.policy.vfc.VfcHealAdditionalParams;
 import org.onap.policy.vfc.VfcHealRequest;
 import org.onap.policy.vfc.VfcRequest;
 
-public class VfcActorServiceProvider implements Actor {
+public class VfcActorServiceProvider extends ActorImpl {
     private static final String GENERIC_VNF_ID = "generic-vnf.vnf-id";
 
     // Strings for VFC Actor
@@ -52,6 +50,10 @@ public class VfcActorServiceProvider implements Actor {
     private static final ImmutableMap<String, List<String>> targets =
             new ImmutableMap.Builder<String, List<String>>().put(RECIPE_RESTART, ImmutableList.of(TARGET_VM)).build();
 
+    public VfcActorServiceProvider() {
+        super(VFC_ACTOR);
+    }
+
     @Override
     public String actor() {
         return VFC_ACTOR;
diff --git a/models-interactions/model-actors/actorServiceProvider/pom.xml b/models-interactions/model-actors/actorServiceProvider/pom.xml
index ee3a924f8..54b13f0ed 100644
--- a/models-interactions/model-actors/actorServiceProvider/pom.xml
+++ b/models-interactions/model-actors/actorServiceProvider/pom.xml
@@ -18,22 +18,47 @@
   ============LICENSE_END=========================================================
   -->
 
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-  <modelVersion>4.0.0</modelVersion>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
 
-  <parent>
-   <groupId>org.onap.policy.models.policy-models-interactions.model-actors</groupId>
-    <artifactId>model-actors</artifactId>
-    <version>2.2.1-SNAPSHOT</version>
-  </parent>
+    <parent>
+        <groupId>org.onap.policy.models.policy-models-interactions.model-actors</groupId>
+        <artifactId>model-actors</artifactId>
+        <version>2.2.1-SNAPSHOT</version>
+    </parent>
 
-  <artifactId>actorServiceProvider</artifactId>
+    <artifactId>actorServiceProvider</artifactId>
 
-  <dependencies>
-    <dependency>
-      <groupId>junit</groupId>
-      <artifactId>junit</artifactId>
-      <scope>test</scope>
-    </dependency>
-  </dependencies>
+    <dependencies>
+        <dependency>
+            <groupId>org.onap.policy.models.policy-models-interactions.model-impl</groupId>
+            <artifactId>aai</artifactId>
+            <version>${project.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.onap.policy.models.policy-models-interactions.model-impl</groupId>
+            <artifactId>events</artifactId>
+            <version>${project.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.onap.policy.common</groupId>
+            <artifactId>policy-endpoints</artifactId>
+            <version>${policy.common.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.powermock</groupId>
+            <artifactId>powermock-api-mockito2</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
 </project>
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/ActorService.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/ActorService.java
index 809936146..13f09b1ad 100644
--- a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/ActorService.java
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/ActorService.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * ActorService
  * ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2018, 2020 AT&T Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -21,25 +21,56 @@
 
 package org.onap.policy.controlloop.actorserviceprovider;
 
-import com.google.common.collect.ImmutableList;
-
-import java.util.Iterator;
+import com.google.common.collect.ImmutableMap;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
 import java.util.ServiceLoader;
-
+import java.util.Set;
+import org.onap.policy.common.parameters.BeanValidationResult;
+import org.onap.policy.controlloop.actorserviceprovider.impl.StartConfigPartial;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ParameterValidationRuntimeException;
 import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class ActorService {
-
+/**
+ * Service that manages a set of actors. To use the service, first invoke
+ * {@link #configure(Map)} to configure all of the actors, and then invoke
+ * {@link #start()} to start all of the actors. When finished using the actor service,
+ * invoke {@link #stop()} or {@link #shutdown()}.
+ */
+public class ActorService extends StartConfigPartial<Map<String, Object>> {
     private static final Logger logger = LoggerFactory.getLogger(ActorService.class);
-    private static ActorService service;
 
-    // USed to load actors
-    private final ServiceLoader<Actor> loader;
+    private final Map<String, Actor> name2actor;
+
+    private static class LazyHolder {
+        static final ActorService INSTANCE = new ActorService();
+    }
+
+    /**
+     * Constructs the object and loads the list of actors.
+     */
+    protected ActorService() {
+        super("actors");
+
+        Map<String, Actor> map = new HashMap<>();
+
+        for (Actor newActor : loadActors()) {
+            map.compute(newActor.getName(), (name, existingActor) -> {
+                if (existingActor == null) {
+                    return newActor;
+                }
+
+                // TODO: should this throw an exception?
+                logger.warn("duplicate actor names for {}: {}, ignoring {}", name,
+                                existingActor.getClass().getSimpleName(), newActor.getClass().getSimpleName());
+                return existingActor;
+            });
+        }
 
-    private ActorService() {
-        loader = ServiceLoader.load(Actor.class);
+        name2actor = ImmutableMap.copyOf(map);
     }
 
     /**
@@ -47,27 +78,115 @@ public class ActorService {
      *
      * @return the instance
      */
-    public static synchronized ActorService getInstance() {
-        if (service == null) {
-            service = new ActorService();
+    public static ActorService getInstance() {
+        return LazyHolder.INSTANCE;
+    }
+
+    /**
+     * Gets a particular actor.
+     *
+     * @param name name of the actor of interest
+     * @return the desired actor
+     * @throws IllegalArgumentException if no actor by the given name exists
+     */
+    public Actor getActor(String name) {
+        Actor actor = name2actor.get(name);
+        if (actor == null) {
+            throw new IllegalArgumentException("unknown actor " + name);
         }
-        return service;
+
+        return actor;
     }
 
     /**
-     * Get the actors.
+     * Gets the actors.
      *
      * @return the actors
      */
-    public ImmutableList<Actor> actors() {
-        Iterator<Actor> iter = loader.iterator();
-        logger.debug("returning actors");
-        while (iter.hasNext()) {
-            if (logger.isDebugEnabled()) {
-                logger.debug("Got {}", iter.next().actor());
+    public Collection<Actor> getActors() {
+        return name2actor.values();
+    }
+
+    /**
+     * Gets the names of the actors.
+     *
+     * @return the actor names
+     */
+    public Set<String> getActorNames() {
+        return name2actor.keySet();
+    }
+
+    @Override
+    protected void doConfigure(Map<String, Object> parameters) {
+        logger.info("configuring actors");
+
+        BeanValidationResult valres = new BeanValidationResult("ActorService", parameters);
+
+        for (Actor actor : name2actor.values()) {
+            String actorName = actor.getName();
+            Map<String, Object> subparams = Util.translateToMap(actorName, parameters.get(actorName));
+
+            if (subparams != null) {
+
+                try {
+                    actor.configure(subparams);
+
+                } catch (ParameterValidationRuntimeException e) {
+                    logger.warn("failed to configure actor {}", actorName, e);
+                    valres.addResult(e.getResult());
+
+                } catch (RuntimeException e) {
+                    logger.warn("failed to configure actor {}", actorName, e);
+                }
+
+            } else if (actor.isConfigured()) {
+                logger.warn("missing configuration parameters for actor {}; using previous parameters", actorName);
+
+            } else {
+                logger.warn("missing configuration parameters for actor {}; actor cannot be started", actorName);
             }
         }
 
-        return ImmutableList.copyOf(loader.iterator());
+        if (!valres.isValid() && logger.isWarnEnabled()) {
+            logger.warn("actor services validation errors:\n{}", valres.getResult());
+        }
+    }
+
+    @Override
+    protected void doStart() {
+        logger.info("starting actors");
+
+        for (Actor actor : name2actor.values()) {
+            if (actor.isConfigured()) {
+                Util.logException(actor::start, "failed to start actor {}", actor.getName());
+
+            } else {
+                logger.warn("not starting unconfigured actor {}", actor.getName());
+            }
+        }
+    }
+
+    @Override
+    protected void doStop() {
+        logger.info("stopping actors");
+        name2actor.values()
+                        .forEach(actor -> Util.logException(actor::stop, "failed to stop actor {}", actor.getName()));
+    }
+
+    @Override
+    protected void doShutdown() {
+        logger.info("shutting down actors");
+
+        // @formatter:off
+        name2actor.values().forEach(
+            actor -> Util.logException(actor::shutdown, "failed to shutdown actor {}", actor.getName()));
+
+        // @formatter:on
+    }
+
+    // the following methods may be overridden by junit tests
+
+    protected Iterable<Actor> loadActors() {
+        return ServiceLoader.load(Actor.class);
     }
 }
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/DelayedIdentString.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/DelayedIdentString.java
new file mode 100644
index 000000000..b7a9a53ad
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/DelayedIdentString.java
@@ -0,0 +1,65 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider;
+
+import lombok.AllArgsConstructor;
+
+/**
+ * Object whose {@link #toString()} method invokes {@link Object#toString()} on another
+ * object, on-demand. This assumes that the other object's method returns an object
+ * identifier. This is typically used to include an object's identifier in a log message.
+ */
+@AllArgsConstructor
+public class DelayedIdentString {
+    /**
+     * String to return for null objects or null object identifiers.
+     */
+    public static final String NULL_STRING = "null";
+
+    private final Object object;
+
+    /**
+     * Gets the object's identifier, after stripping anything appearing before '@'.
+     */
+    @Override
+    public String toString() {
+        if (object == null) {
+            return NULL_STRING;
+        }
+
+        String ident = objectToString();
+        if (ident == null) {
+            return NULL_STRING;
+        }
+
+        int index = ident.indexOf('@');
+        return (index > 0 ? ident.substring(index) : ident);
+    }
+
+    /**
+     * Invokes the object's {@link Object#toString()} method.
+     *
+     * @return the output from the object's {@link Object#toString()} method
+     */
+    protected String objectToString() {
+        return object.toString();
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/Operator.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/Operator.java
new file mode 100644
index 000000000..e308ee42e
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/Operator.java
@@ -0,0 +1,58 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider;
+
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import org.onap.policy.common.capabilities.Configurable;
+import org.onap.policy.common.capabilities.Startable;
+import org.onap.policy.controlloop.ControlLoopOperation;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ControlLoopOperationParams;
+
+/**
+ * This is the service interface for defining an Actor operation used in Control Loop
+ * Operational Policies for performing actions on runtime entities.
+ */
+public interface Operator extends Startable, Configurable<Map<String, Object>> {
+
+    /**
+     * Gets the name of the associated actor.
+     *
+     * @return the name of the associated actor
+     */
+    String getActorName();
+
+    /**
+     * Gets the name of the operation.
+     *
+     * @return the operation name
+     */
+    String getName();
+
+    /**
+     * Called by enforcement PDP engine to start the operation. As part of the operation,
+     * it invokes the "start" and "complete" call-backs found within the parameters.
+     *
+     * @param params parameters needed to start the operation
+     * @return a future that can be used to cancel or await the result of the operation
+     */
+    CompletableFuture<ControlLoopOperation> startOperation(ControlLoopOperationParams params);
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/Util.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/Util.java
new file mode 100644
index 000000000..0aba1a7fa
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/Util.java
@@ -0,0 +1,114 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider;
+
+import java.util.Arrays;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import org.onap.policy.common.utils.coder.Coder;
+import org.onap.policy.common.utils.coder.CoderException;
+import org.onap.policy.common.utils.coder.StandardCoder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Actor utilities.
+ */
+public class Util {
+    private static final Logger logger = LoggerFactory.getLogger(Util.class);
+
+    private Util() {
+        // do nothing
+    }
+
+    /**
+     * Extracts an object's identity by invoking {@link Object#toString()} and returning
+     * the portion starting with "@". Extraction is done on-demand, when toString() is
+     * called on the result. This is typically used when logging.
+     *
+     * @param object object whose identity is to be extracted
+     * @return an object that will extract the source object's identity when this object's
+     *         toString() method is called
+     */
+    public static Object ident(Object object) {
+        return new DelayedIdentString(object);
+    }
+
+    /**
+     * Runs a function and logs a message if it throws an exception. Does <i>not</i>
+     * re-throw the exception.
+     *
+     * @param function function to be run
+     * @param exceptionMessage message to log if an exception is thrown
+     * @param exceptionArgs arguments to be passed to the logger
+     */
+    public static void logException(Runnable function, String exceptionMessage, Object... exceptionArgs) {
+        try {
+            function.run();
+
+        } catch (RuntimeException ex) {
+            // create a new array containing the original arguments plus the exception
+            Object[] allArgs = Arrays.copyOf(exceptionArgs, exceptionArgs.length + 1);
+            allArgs[exceptionArgs.length] = ex;
+
+            logger.warn(exceptionMessage, allArgs);
+        }
+    }
+
+    /**
+     * Translates parameters from one class to another, typically from a Map to a POJO or
+     * vice versa.
+     *
+     * @param identifier identifier of the actor/operation being translated; used to build
+     *        an exception message
+     * @param source source object to be translated
+     * @param clazz target class
+     * @return the translated object
+     */
+    public static <T> T translate(String identifier, Object source, Class<T> clazz) {
+        Coder coder = new StandardCoder();
+
+        try {
+            String json = coder.encode(source);
+            return coder.decode(json, clazz);
+
+        } catch (CoderException | RuntimeException e) {
+            throw new IllegalArgumentException("cannot translate parameters for " + identifier, e);
+        }
+    }
+
+    /**
+     * Translates parameters to a Map.
+     *
+     * @param identifier identifier of the actor/operation being translated; used to build
+     *        an exception message
+     * @param source source parameters
+     * @return the parameters, as a Map
+     */
+    @SuppressWarnings("unchecked")
+    public static Map<String, Object> translateToMap(String identifier, Object source) {
+        if (source == null) {
+            return null;
+        }
+
+        return translate(identifier, source, LinkedHashMap.class);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/controlloop/ControlLoopEventContext.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/controlloop/ControlLoopEventContext.java
new file mode 100644
index 000000000..68bbe7edc
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/controlloop/ControlLoopEventContext.java
@@ -0,0 +1,90 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.controlloop;
+
+import java.io.Serializable;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.Setter;
+import org.onap.policy.aai.AaiCqResponse;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+
+/**
+ * Context associated with a control loop event.
+ */
+@Getter
+@Setter
+public class ControlLoopEventContext implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @Setter(AccessLevel.NONE)
+    private final VirtualControlLoopEvent event;
+
+    private AaiCqResponse aaiCqResponse;
+
+    // TODO may remove this if it proves not to be needed
+    @Getter(AccessLevel.NONE)
+    @Setter(AccessLevel.NONE)
+    private Map<String, Serializable> properties = new ConcurrentHashMap<>();
+
+    /**
+     * Constructs the object.
+     *
+     * @param event event with which this is associated
+     */
+    public ControlLoopEventContext(VirtualControlLoopEvent event) {
+        this.event = event;
+    }
+
+    /**
+     * Determines if the context contains a property.
+     *
+     * @param name name of the property of interest
+     * @return {@code true} if the context contains the property, {@code false} otherwise
+     */
+    public boolean contains(String name) {
+        return properties.containsKey(name);
+    }
+
+    /**
+     * Gets a property, casting it to the desired type.
+     *
+     * @param <T> desired type
+     * @param name name of the property whose value is to be retrieved
+     * @return the property's value, or {@code null} if it does not yet have a value
+     */
+    @SuppressWarnings("unchecked")
+    public <T> T getProperty(String name) {
+        return (T) properties.get(name);
+    }
+
+    /**
+     * Sets a property's value.
+     *
+     * @param name property name
+     * @param value new property value
+     */
+    public void setProperty(String name, Serializable value) {
+        properties.put(name, value);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/ActorImpl.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/ActorImpl.java
new file mode 100644
index 000000000..9b9aa914e
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/ActorImpl.java
@@ -0,0 +1,239 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.impl;
+
+import com.google.common.collect.ImmutableMap;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.function.Function;
+import org.onap.policy.common.parameters.BeanValidationResult;
+import org.onap.policy.controlloop.actorserviceprovider.Operator;
+import org.onap.policy.controlloop.actorserviceprovider.Util;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ParameterValidationRuntimeException;
+import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Implementation of an actor.
+ */
+public class ActorImpl extends StartConfigPartial<Map<String, Object>> implements Actor {
+    private static final Logger logger = LoggerFactory.getLogger(ActorImpl.class);
+
+    /**
+     * Maps a name to an operator.
+     */
+    private Map<String, Operator> name2operator;
+
+    /**
+     * Constructs the object.
+     *
+     * @param name actor name
+     * @param operators the operations supported by this actor
+     */
+    public ActorImpl(String name, Operator... operators) {
+        super(name);
+        setOperators(Arrays.asList(operators));
+    }
+
+    /**
+     * Sets the operators supported by this actor, overriding any previous list.
+     *
+     * @param operators the operations supported by this actor
+     */
+    protected void setOperators(List<Operator> operators) {
+        if (isConfigured()) {
+            throw new IllegalStateException("attempt to set operators on a configured actor: " + getName());
+        }
+
+        Map<String, Operator> map = new HashMap<>();
+        for (Operator newOp : operators) {
+            map.compute(newOp.getName(), (opName, existingOp) -> {
+                if (existingOp == null) {
+                    return newOp;
+                }
+
+                // TODO: should this throw an exception?
+                logger.warn("duplicate names for actor operation {}.{}: {}, ignoring {}", getName(), opName,
+                                existingOp.getClass().getSimpleName(), newOp.getClass().getSimpleName());
+                return existingOp;
+            });
+        }
+
+        this.name2operator = ImmutableMap.copyOf(map);
+    }
+
+    @Override
+    public String getName() {
+        return getFullName();
+    }
+
+    @Override
+    public Operator getOperator(String name) {
+        Operator operator = name2operator.get(name);
+        if (operator == null) {
+            throw new IllegalArgumentException("unknown operation " + getName() + "." + name);
+        }
+
+        return operator;
+    }
+
+    @Override
+    public Collection<Operator> getOperators() {
+        return name2operator.values();
+    }
+
+    @Override
+    public Set<String> getOperationNames() {
+        return name2operator.keySet();
+    }
+
+    /**
+     * For each operation, it looks for a set of parameters by the same name and, if
+     * found, configures the operation with the parameters.
+     */
+    @Override
+    protected void doConfigure(Map<String, Object> parameters) {
+        final String actorName = getName();
+        logger.info("configuring operations for actor {}", actorName);
+
+        BeanValidationResult valres = new BeanValidationResult(actorName, parameters);
+
+        // function that creates operator-specific parameters, given the operation name
+        Function<String, Map<String, Object>> opParamsMaker = makeOperatorParameters(parameters);
+
+        for (Operator operator : name2operator.values()) {
+            String operName = operator.getName();
+            Map<String, Object> subparams = opParamsMaker.apply(operName);
+
+            if (subparams != null) {
+
+                try {
+                    operator.configure(subparams);
+
+                } catch (ParameterValidationRuntimeException e) {
+                    logger.warn("failed to configure operation {}.{}", actorName, operName, e);
+                    valres.addResult(e.getResult());
+
+                } catch (RuntimeException e) {
+                    logger.warn("failed to configure operation {}.{}", actorName, operName, e);
+                }
+
+            } else if (operator.isConfigured()) {
+                logger.warn("missing configuration parameters for operation {}.{}; using previous parameters",
+                                actorName, operName);
+
+            } else {
+                logger.warn("missing configuration parameters for operation {}.{}; operation cannot be started",
+                                actorName, operName);
+            }
+        }
+    }
+
+    /**
+     * Extracts the operator parameters from the actor parameters, for a given operator.
+     * This method assumes each operation has its own set of parameters.
+     *
+     * @param actorParameters actor parameters
+     * @return a function to extract the operator parameters from the actor parameters.
+     *         Note: this function may return {@code null} if there are no parameters for
+     *         the given operation name
+     */
+    protected Function<String, Map<String, Object>> makeOperatorParameters(Map<String, Object> actorParameters) {
+
+        return operName -> Util.translateToMap(getName() + "." + operName, actorParameters.get(operName));
+    }
+
+    /**
+     * Starts each operation.
+     */
+    @Override
+    protected void doStart() {
+        final String actorName = getName();
+        logger.info("starting operations for actor {}", actorName);
+
+        for (Operator oper : name2operator.values()) {
+            if (oper.isConfigured()) {
+                Util.logException(oper::start, "failed to start operation {}.{}", actorName, oper.getName());
+
+            } else {
+                logger.warn("not starting unconfigured operation {}.{}", actorName, oper.getName());
+            }
+        }
+    }
+
+    /**
+     * Stops each operation.
+     */
+    @Override
+    protected void doStop() {
+        final String actorName = getName();
+        logger.info("stopping operations for actor {}", actorName);
+
+        // @formatter:off
+        name2operator.values().forEach(
+            oper -> Util.logException(oper::stop, "failed to stop operation {}.{}", actorName, oper.getName()));
+        // @formatter:on
+    }
+
+    /**
+     * Shuts down each operation.
+     */
+    @Override
+    protected void doShutdown() {
+        final String actorName = getName();
+        logger.info("shutting down operations for actor {}", actorName);
+
+        // @formatter:off
+        name2operator.values().forEach(oper -> Util.logException(oper::shutdown,
+                        "failed to shutdown operation {}.{}", actorName, oper.getName()));
+        // @formatter:on
+    }
+
+    // TODO old code: remove lines down to **HERE**
+
+    @Override
+    public String actor() {
+        return null;
+    }
+
+    @Override
+    public List<String> recipes() {
+        return Collections.emptyList();
+    }
+
+    @Override
+    public List<String> recipeTargets(String recipe) {
+        return Collections.emptyList();
+    }
+
+    @Override
+    public List<String> recipePayloads(String recipe) {
+        return Collections.emptyList();
+    }
+
+    // **HERE**
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperatorPartial.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperatorPartial.java
new file mode 100644
index 000000000..80d8fbd04
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperatorPartial.java
@@ -0,0 +1,757 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.impl;
+
+import java.time.Instant;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionException;
+import java.util.concurrent.Executor;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.function.Function;
+import lombok.Getter;
+import org.onap.policy.controlloop.ControlLoopOperation;
+import org.onap.policy.controlloop.actorserviceprovider.Operator;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ControlLoopOperationParams;
+import org.onap.policy.controlloop.actorserviceprovider.pipeline.PipelineControllerFuture;
+import org.onap.policy.controlloop.policy.Policy;
+import org.onap.policy.controlloop.policy.PolicyResult;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Partial implementation of an operator. Subclasses can choose to simply implement
+ * {@link #doOperation(ControlLoopOperationParams)}, or they may choose to override
+ * {@link #doOperationAsFuture(ControlLoopOperationParams)}.
+ */
+public abstract class OperatorPartial extends StartConfigPartial<Map<String, Object>> implements Operator {
+
+    private static final Logger logger = LoggerFactory.getLogger(OperatorPartial.class);
+
+    private static final String OUTCOME_SUCCESS = PolicyResult.SUCCESS.toString();
+    private static final String OUTCOME_FAILURE = PolicyResult.FAILURE.toString();
+    private static final String OUTCOME_RETRIES = PolicyResult.FAILURE_RETRIES.toString();
+
+    @Getter
+    private final String actorName;
+
+    @Getter
+    private final String name;
+
+    /**
+     * Constructs the object.
+     *
+     * @param actorName name of the actor with which this operator is associated
+     * @param name operation name
+     */
+    public OperatorPartial(String actorName, String name) {
+        super(actorName + "." + name);
+        this.actorName = actorName;
+        this.name = name;
+    }
+
+    /**
+     * This method does nothing.
+     */
+    @Override
+    protected void doConfigure(Map<String, Object> parameters) {
+        // do nothing
+    }
+
+    /**
+     * This method does nothing.
+     */
+    @Override
+    protected void doStart() {
+        // do nothing
+    }
+
+    /**
+     * This method does nothing.
+     */
+    @Override
+    protected void doStop() {
+        // do nothing
+    }
+
+    /**
+     * This method does nothing.
+     */
+    @Override
+    protected void doShutdown() {
+        // do nothing
+    }
+
+    @Override
+    public final CompletableFuture<ControlLoopOperation> startOperation(ControlLoopOperationParams params) {
+        if (!isAlive()) {
+            throw new IllegalStateException("operation is not running: " + getFullName());
+        }
+
+        final Executor executor = params.getExecutor();
+
+        // allocate a controller for the entire operation
+        final PipelineControllerFuture<ControlLoopOperation> controller = new PipelineControllerFuture<>();
+
+        CompletableFuture<ControlLoopOperation> preproc = startPreprocessor(params);
+        if (preproc == null) {
+            // no preprocessor required - just start the operation
+            return startOperationAttempt(params, controller, 1);
+        }
+
+        // propagate "stop" to the preprocessor
+        controller.add(preproc);
+
+        /*
+         * Do preprocessor first and then, if successful, start the operation. Note:
+         * operations create their own outcome, ignoring the outcome from any previous
+         * steps.
+         */
+        preproc.whenCompleteAsync(controller.delayedRemove(preproc), executor)
+                        .thenComposeAsync(handleFailure(params, controller), executor)
+                        .thenComposeAsync(onSuccess(params, unused -> startOperationAttempt(params, controller, 1)),
+                                        executor);
+
+        return controller;
+    }
+
+    /**
+     * Starts an operation's preprocessor step(s). If the preprocessor fails, then it
+     * invokes the started and completed call-backs.
+     *
+     * @param params operation parameters
+     * @return a future that will return the preprocessor outcome, or {@code null} if this
+     *         operation needs no preprocessor
+     */
+    protected CompletableFuture<ControlLoopOperation> startPreprocessor(ControlLoopOperationParams params) {
+        logger.info("{}: start low-level operation preprocessor for {}", getFullName(), params.getRequestId());
+
+        final Executor executor = params.getExecutor();
+        final ControlLoopOperation operation = params.makeOutcome();
+
+        final Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> preproc =
+                        doPreprocessorAsFuture(params);
+        if (preproc == null) {
+            // no preprocessor required
+            return null;
+        }
+
+        // allocate a controller for the preprocessor steps
+        final PipelineControllerFuture<ControlLoopOperation> controller = new PipelineControllerFuture<>();
+
+        /*
+         * Don't mark it complete until we've built the whole pipeline. This will prevent
+         * the operation from starting until after it has been successfully built (i.e.,
+         * without generating any exceptions).
+         */
+        final CompletableFuture<ControlLoopOperation> firstFuture = new CompletableFuture<>();
+
+        // @formatter:off
+        firstFuture
+            .thenComposeAsync(controller.add(preproc), executor)
+            .exceptionally(fromException(params, operation))
+            .whenCompleteAsync(controller.delayedComplete(), executor);
+        // @formatter:on
+
+        // start the pipeline
+        firstFuture.complete(operation);
+
+        return controller;
+    }
+
+    /**
+     * Handles a failure in the preprocessor pipeline. If a failure occurred, then it
+     * invokes the call-backs and returns a failed outcome. Otherwise, it returns the
+     * outcome that it received.
+     *
+     * @param params operation parameters
+     * @param controller pipeline controller
+     * @return a function that checks the outcome status and continues, if successful, or
+     *         indicates a failure otherwise
+     */
+    private Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> handleFailure(
+                    ControlLoopOperationParams params, PipelineControllerFuture<ControlLoopOperation> controller) {
+
+        return outcome -> {
+
+            if (outcome != null && isSuccess(outcome)) {
+                logger.trace("{}: preprocessor succeeded for {}", getFullName(), params.getRequestId());
+                return CompletableFuture.completedFuture(outcome);
+            }
+
+            logger.warn("preprocessor failed, discontinuing operation {} for {}", getFullName(), params.getRequestId());
+
+            final Executor executor = params.getExecutor();
+            final CallbackManager callbacks = new CallbackManager();
+
+            // propagate "stop" to the callbacks
+            controller.add(callbacks);
+
+            final ControlLoopOperation outcome2 = params.makeOutcome();
+
+            // TODO need a FAILURE_MISSING_DATA (e.g., A&AI)
+
+            outcome2.setOutcome(PolicyResult.FAILURE_GUARD.toString());
+            outcome2.setMessage(outcome != null ? outcome.getMessage() : null);
+
+            CompletableFuture.completedFuture(outcome2).thenApplyAsync(callbackStarted(params, callbacks), executor)
+                            .thenApplyAsync(callbackCompleted(params, callbacks), executor)
+                            .whenCompleteAsync(controller.delayedRemove(callbacks), executor)
+                            .whenCompleteAsync(controller.delayedComplete(), executor);
+
+            return controller;
+        };
+    }
+
+    /**
+     * Invokes the operation's preprocessor step(s) as a "future". This method simply
+     * returns {@code null}.
+     * <p/>
+     * This method assumes the following:
+     * <ul>
+     * <li>the operator is alive</li>
+     * <li>exceptions generated within the pipeline will be handled by the invoker</li>
+     * </ul>
+     *
+     * @param params operation parameters
+     * @return a function that will start the preprocessor and returns its outcome, or
+     *         {@code null} if this operation needs no preprocessor
+     */
+    protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doPreprocessorAsFuture(
+                    ControlLoopOperationParams params) {
+        return null;
+    }
+
+    /**
+     * Starts the operation attempt, with no preprocessor. When all retries complete, it
+     * will complete the controller.
+     *
+     * @param params operation parameters
+     * @param controller controller for all operation attempts
+     * @param attempt attempt number, typically starting with 1
+     * @return a future that will return the final result of all attempts
+     */
+    private CompletableFuture<ControlLoopOperation> startOperationAttempt(ControlLoopOperationParams params,
+                    PipelineControllerFuture<ControlLoopOperation> controller, int attempt) {
+
+        final Executor executor = params.getExecutor();
+
+        CompletableFuture<ControlLoopOperation> future = startAttemptWithoutRetries(params, attempt);
+
+        // propagate "stop" to the operation attempt
+        controller.add(future);
+
+        // detach when complete
+        future.whenCompleteAsync(controller.delayedRemove(future), executor)
+                        .thenComposeAsync(retryOnFailure(params, controller, attempt), params.getExecutor())
+                        .whenCompleteAsync(controller.delayedComplete(), executor);
+
+        return controller;
+    }
+
+    /**
+     * Starts the operation attempt, without doing any retries.
+     *
+     * @param params operation parameters
+     * @param attempt attempt number, typically starting with 1
+     * @return a future that will return the result of a single operation attempt
+     */
+    private CompletableFuture<ControlLoopOperation> startAttemptWithoutRetries(ControlLoopOperationParams params,
+                    int attempt) {
+
+        logger.info("{}: start operation attempt {} for {}", getFullName(), attempt, params.getRequestId());
+
+        final Executor executor = params.getExecutor();
+        final ControlLoopOperation outcome = params.makeOutcome();
+        final CallbackManager callbacks = new CallbackManager();
+
+        // this operation attempt gets its own controller
+        final PipelineControllerFuture<ControlLoopOperation> controller = new PipelineControllerFuture<>();
+
+        // propagate "stop" to the callbacks
+        controller.add(callbacks);
+
+        /*
+         * Don't mark it complete until we've built the whole pipeline. This will prevent
+         * the operation from starting until after it has been successfully built (i.e.,
+         * without generating any exceptions).
+         */
+        final CompletableFuture<ControlLoopOperation> firstFuture = new CompletableFuture<>();
+
+        // @formatter:off
+        CompletableFuture<ControlLoopOperation> future2 =
+            firstFuture.thenComposeAsync(verifyRunning(controller, params), executor)
+                        .thenApplyAsync(callbackStarted(params, callbacks), executor)
+                        .thenComposeAsync(controller.add(doOperationAsFuture(params, attempt)), executor);
+        // @formatter:on
+
+        // handle timeouts, if specified
+        long timeoutMillis = getTimeOutMillis(params.getPolicy());
+        if (timeoutMillis > 0) {
+            logger.info("{}: set timeout to {}ms for {}", getFullName(), timeoutMillis, params.getRequestId());
+            future2 = future2.orTimeout(timeoutMillis, TimeUnit.MILLISECONDS);
+        }
+
+        /*
+         * Note: we re-invoke callbackStarted() just to be sure the callback is invoked
+         * before callbackCompleted() is invoked.
+         *
+         * Note: no need to remove "callbacks" from the pipeline, as we're going to stop
+         * the pipeline as the last step anyway.
+         */
+
+        // @formatter:off
+        future2.exceptionally(fromException(params, outcome))
+                    .thenApplyAsync(setRetryFlag(params, attempt), executor)
+                    .thenApplyAsync(callbackStarted(params, callbacks), executor)
+                    .thenApplyAsync(callbackCompleted(params, callbacks), executor)
+                    .whenCompleteAsync(controller.delayedComplete(), executor);
+        // @formatter:on
+
+        // start the pipeline
+        firstFuture.complete(outcome);
+
+        return controller;
+    }
+
+    /**
+     * Determines if the outcome was successful.
+     *
+     * @param outcome outcome to examine
+     * @return {@code true} if the outcome was successful
+     */
+    protected boolean isSuccess(ControlLoopOperation outcome) {
+        return OUTCOME_SUCCESS.equals(outcome.getOutcome());
+    }
+
+    /**
+     * Determines if the outcome was a failure for this operator.
+     *
+     * @param outcome outcome to examine, or {@code null}
+     * @return {@code true} if the outcome is not {@code null} and was a failure
+     *         <i>and</i> was associated with this operator, {@code false} otherwise
+     */
+    protected boolean isActorFailed(ControlLoopOperation outcome) {
+        return OUTCOME_FAILURE.equals(getActorOutcome(outcome));
+    }
+
+    /**
+     * Invokes the operation as a "future". This method simply invokes
+     * {@link #doOperation(ControlLoopOperationParams)} turning it into a "future".
+     * <p/>
+     * This method assumes the following:
+     * <ul>
+     * <li>the operator is alive</li>
+     * <li>verifyRunning() has been invoked</li>
+     * <li>callbackStarted() has been invoked</li>
+     * <li>the invoker will perform appropriate timeout checks</li>
+     * <li>exceptions generated within the pipeline will be handled by the invoker</li>
+     * </ul>
+     *
+     * @param params operation parameters
+     * @param attempt attempt number, typically starting with 1
+     * @return a function that will start the operation and return its result when
+     *         complete
+     */
+    protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doOperationAsFuture(
+                    ControlLoopOperationParams params, int attempt) {
+
+        /*
+         * TODO As doOperation() may perform blocking I/O, this should be launched in its
+         * own thread to prevent the ForkJoinPool from being tied up. Should probably
+         * provide a method to make that easy.
+         */
+
+        return operation -> CompletableFuture.supplyAsync(() -> doOperation(params, attempt, operation),
+                        params.getExecutor());
+    }
+
+    /**
+     * Low-level method that performs the operation. This can make the same assumptions
+     * that are made by {@link #doOperationAsFuture(ControlLoopOperationParams)}. This
+     * method throws an {@link UnsupportedOperationException}.
+     *
+     * @param params operation parameters
+     * @param attempt attempt number, typically starting with 1
+     * @param operation the operation being performed
+     * @return the outcome of the operation
+     */
+    protected ControlLoopOperation doOperation(ControlLoopOperationParams params, int attempt,
+                    ControlLoopOperation operation) {
+
+        throw new UnsupportedOperationException("start operation " + getFullName());
+    }
+
+    /**
+     * Sets the outcome status to FAILURE_RETRIES, if the current operation outcome is
+     * FAILURE, assuming the policy specifies retries and the retry count has been
+     * exhausted.
+     *
+     * @param params operation parameters
+     * @param attempt latest attempt number, starting with 1
+     * @return a function to get the next future to execute
+     */
+    private Function<ControlLoopOperation, ControlLoopOperation> setRetryFlag(ControlLoopOperationParams params,
+                    int attempt) {
+
+        return operation -> {
+            if (operation != null && !isActorFailed(operation)) {
+                /*
+                 * wrong type or wrong operation - just leave it as is. No need to log
+                 * anything here, as retryOnFailure() will log a message
+                 */
+                return operation;
+            }
+
+            // get a non-null operation
+            ControlLoopOperation oper2;
+            if (operation != null) {
+                oper2 = operation;
+            } else {
+                oper2 = params.makeOutcome();
+                oper2.setOutcome(OUTCOME_FAILURE);
+            }
+
+            if (params.getPolicy().getRetry() != null && params.getPolicy().getRetry() > 0
+                            && attempt > params.getPolicy().getRetry()) {
+                /*
+                 * retries were specified and we've already tried them all - change to
+                 * FAILURE_RETRIES
+                 */
+                logger.info("operation {} retries exhausted for {}", getFullName(), params.getRequestId());
+                oper2.setOutcome(OUTCOME_RETRIES);
+            }
+
+            return oper2;
+        };
+    }
+
+    /**
+     * Restarts the operation if it was a FAILURE. Assumes that
+     * {@link #setRetryFlag(ControlLoopOperationParams, int)} was previously invoked, and
+     * thus that the "operation" is not {@code null}.
+     *
+     * @param params operation parameters
+     * @param controller controller for all of the retries
+     * @param attempt latest attempt number, starting with 1
+     * @return a function to get the next future to execute
+     */
+    private Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> retryOnFailure(
+                    ControlLoopOperationParams params, PipelineControllerFuture<ControlLoopOperation> controller,
+                    int attempt) {
+
+        return operation -> {
+            if (!isActorFailed(operation)) {
+                // wrong type or wrong operation - just leave it as is
+                logger.trace("not retrying operation {} for {}", getFullName(), params.getRequestId());
+                return CompletableFuture.completedFuture(operation);
+            }
+
+            if (params.getPolicy().getRetry() == null || params.getPolicy().getRetry() <= 0) {
+                // no retries - already marked as FAILURE, so just return it
+                logger.info("operation {} no retries for {}", getFullName(), params.getRequestId());
+                return CompletableFuture.completedFuture(operation);
+            }
+
+
+            /*
+             * Retry the operation.
+             */
+            logger.info("retry operation {} for {}", getFullName(), params.getRequestId());
+
+            return startOperationAttempt(params, controller, attempt + 1);
+        };
+    }
+
+    /**
+     * Gets the outcome of an operation for this operation.
+     *
+     * @param operation operation whose outcome is to be extracted
+     * @return the outcome of the given operation, if it's for this operator, {@code null}
+     *         otherwise
+     */
+    protected String getActorOutcome(ControlLoopOperation operation) {
+        if (operation == null) {
+            return null;
+        }
+
+        if (!getActorName().equals(operation.getActor())) {
+            return null;
+        }
+
+        if (!getName().equals(operation.getOperation())) {
+            return null;
+        }
+
+        return operation.getOutcome();
+    }
+
+    /**
+     * Gets a function that will start the next step, if the current operation was
+     * successful, or just return the current operation, otherwise.
+     *
+     * @param params operation parameters
+     * @param nextStep function that will invoke the next step, passing it the operation
+     * @return a function that will start the next step
+     */
+    protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> onSuccess(
+                    ControlLoopOperationParams params,
+                    Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> nextStep) {
+
+        return operation -> {
+
+            if (operation == null) {
+                logger.trace("{}: null outcome - discarding next task for {}", getFullName(), params.getRequestId());
+                ControlLoopOperation outcome = params.makeOutcome();
+                outcome.setOutcome(OUTCOME_FAILURE);
+                return CompletableFuture.completedFuture(outcome);
+
+            } else if (isSuccess(operation)) {
+                logger.trace("{}: success - starting next task for {}", getFullName(), params.getRequestId());
+                return nextStep.apply(operation);
+
+            } else {
+                logger.trace("{}: failure - discarding next task for {}", getFullName(), params.getRequestId());
+                return CompletableFuture.completedFuture(operation);
+            }
+        };
+    }
+
+    /**
+     * Converts an exception into an operation outcome, returning a copy of the outcome to
+     * prevent background jobs from changing it.
+     *
+     * @param params operation parameters
+     * @param operation current operation
+     * @return a function that will convert an exception into an operation outcome
+     */
+    private Function<Throwable, ControlLoopOperation> fromException(ControlLoopOperationParams params,
+                    ControlLoopOperation operation) {
+
+        return thrown -> {
+            logger.warn("exception throw by operation {}.{} for {}", operation.getActor(), operation.getOperation(),
+                            params.getRequestId(), thrown);
+
+            /*
+             * Must make a copy of the operation, as the original could be changed by
+             * background jobs that might still be running.
+             */
+            return setOutcome(params, new ControlLoopOperation(operation), thrown);
+        };
+    }
+
+    /**
+     * Gets a function to verify that the operation is still running. If the pipeline is
+     * not running, then it returns an incomplete future, which will effectively halt
+     * subsequent operations in the pipeline. This method is intended to be used with one
+     * of the {@link CompletableFuture}'s <i>thenCompose()</i> methods.
+     *
+     * @param controller pipeline controller
+     * @param params operation parameters
+     * @return a function to verify that the operation is still running
+     */
+    protected <T> Function<T, CompletableFuture<T>> verifyRunning(
+                    PipelineControllerFuture<ControlLoopOperation> controller, ControlLoopOperationParams params) {
+
+        return value -> {
+            boolean running = controller.isRunning();
+            logger.trace("{}: verify running {} for {}", getFullName(), running, params.getRequestId());
+
+            return (running ? CompletableFuture.completedFuture(value) : new CompletableFuture<>());
+        };
+    }
+
+    /**
+     * Sets the start time of the operation and invokes the callback to indicate that the
+     * operation has started. Does nothing if the pipeline has been stopped.
+     * <p/>
+     * This assumes that the "outcome" is not {@code null}.
+     *
+     * @param params operation parameters
+     * @param callbacks used to determine if the start callback can be invoked
+     * @return a function that sets the start time and invokes the callback
+     */
+    private Function<ControlLoopOperation, ControlLoopOperation> callbackStarted(ControlLoopOperationParams params,
+                    CallbackManager callbacks) {
+
+        return outcome -> {
+
+            if (callbacks.canStart()) {
+                // haven't invoked "start" callback yet
+                outcome.setStart(callbacks.getStartTime());
+                outcome.setEnd(null);
+                params.callbackStarted(outcome);
+            }
+
+            return outcome;
+        };
+    }
+
+    /**
+     * Sets the end time of the operation and invokes the callback to indicate that the
+     * operation has completed. Does nothing if the pipeline has been stopped.
+     * <p/>
+     * This assumes that the "outcome" is not {@code null}.
+     * <p/>
+     * Note: the start time must be a reference rather than a plain value, because it's
+     * value must be gotten on-demand, when the returned function is executed at a later
+     * time.
+     *
+     * @param params operation parameters
+     * @param callbacks used to determine if the end callback can be invoked
+     * @return a function that sets the end time and invokes the callback
+     */
+    private Function<ControlLoopOperation, ControlLoopOperation> callbackCompleted(ControlLoopOperationParams params,
+                    CallbackManager callbacks) {
+
+        return operation -> {
+
+            if (callbacks.canEnd()) {
+                operation.setStart(callbacks.getStartTime());
+                operation.setEnd(callbacks.getEndTime());
+                params.callbackCompleted(operation);
+            }
+
+            return operation;
+        };
+    }
+
+    /**
+     * Sets an operation's outcome and message, based on a throwable.
+     *
+     * @param params operation parameters
+     * @param operation operation to be updated
+     * @return the updated operation
+     */
+    protected ControlLoopOperation setOutcome(ControlLoopOperationParams params, ControlLoopOperation operation,
+                    Throwable thrown) {
+        PolicyResult result = (isTimeout(thrown) ? PolicyResult.FAILURE_TIMEOUT : PolicyResult.FAILURE_EXCEPTION);
+        return setOutcome(params, operation, result);
+    }
+
+    /**
+     * Sets an operation's outcome and default message based on the result.
+     *
+     * @param params operation parameters
+     * @param operation operation to be updated
+     * @param result result of the operation
+     * @return the updated operation
+     */
+    protected ControlLoopOperation setOutcome(ControlLoopOperationParams params, ControlLoopOperation operation,
+                    PolicyResult result) {
+        logger.trace("{}: set outcome {} for {}", getFullName(), result, params.getRequestId());
+        operation.setOutcome(result.toString());
+        operation.setMessage(result == PolicyResult.SUCCESS ? ControlLoopOperation.SUCCESS_MSG
+                        : ControlLoopOperation.FAILED_MSG);
+
+        return operation;
+    }
+
+    /**
+     * Determines if a throwable is due to a timeout.
+     *
+     * @param thrown throwable of interest
+     * @return {@code true} if the throwable is due to a timeout, {@code false} otherwise
+     */
+    protected boolean isTimeout(Throwable thrown) {
+        if (thrown instanceof CompletionException) {
+            thrown = thrown.getCause();
+        }
+
+        return (thrown instanceof TimeoutException);
+    }
+
+    // these may be overridden by junit tests
+
+    /**
+     * Gets the operation timeout. Subclasses may override this method to obtain the
+     * timeout in some other way (e.g., through configuration properties).
+     *
+     * @param policy policy from which to extract the timeout
+     * @return the operation timeout, in milliseconds
+     */
+    protected long getTimeOutMillis(Policy policy) {
+        Integer timeoutSec = policy.getTimeout();
+        return (timeoutSec == null ? 0 : TimeUnit.MILLISECONDS.convert(timeoutSec, TimeUnit.SECONDS));
+    }
+
+    /**
+     * Manager for "start" and "end" callbacks.
+     */
+    private static class CallbackManager implements Runnable {
+        private final AtomicReference<Instant> startTime = new AtomicReference<>();
+        private final AtomicReference<Instant> endTime = new AtomicReference<>();
+
+        /**
+         * Determines if the "start" callback can be invoked. If so, it sets the
+         * {@link #startTime} to the current time.
+         *
+         * @return {@code true} if the "start" callback can be invoked, {@code false}
+         *         otherwise
+         */
+        public boolean canStart() {
+            return startTime.compareAndSet(null, Instant.now());
+        }
+
+        /**
+         * Determines if the "end" callback can be invoked. If so, it sets the
+         * {@link #endTime} to the current time.
+         *
+         * @return {@code true} if the "end" callback can be invoked, {@code false}
+         *         otherwise
+         */
+        public boolean canEnd() {
+            return endTime.compareAndSet(null, Instant.now());
+        }
+
+        /**
+         * Gets the start time.
+         *
+         * @return the start time, or {@code null} if {@link #canStart()} has not been
+         *         invoked yet.
+         */
+        public Instant getStartTime() {
+            return startTime.get();
+        }
+
+        /**
+         * Gets the end time.
+         *
+         * @return the end time, or {@code null} if {@link #canEnd()} has not been invoked
+         *         yet.
+         */
+        public Instant getEndTime() {
+            return endTime.get();
+        }
+
+        /**
+         * Prevents further callbacks from being executed by setting {@link #startTime}
+         * and {@link #endTime}.
+         */
+        @Override
+        public void run() {
+            canStart();
+            canEnd();
+        }
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/StartConfigPartial.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/StartConfigPartial.java
new file mode 100644
index 000000000..6c883f1b5
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/StartConfigPartial.java
@@ -0,0 +1,153 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.impl;
+
+import lombok.Getter;
+import org.onap.policy.common.capabilities.Configurable;
+import org.onap.policy.common.capabilities.Startable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Partial implementation of an object that is both startable and configurable. It
+ * provides the high level methods defined in the interface, while deferring the details
+ * to abstract methods that must be provided by the subclasses. It also manages the
+ * current {@link #state}.
+ *
+ * @param <T> type of parameters expected by {@link #configure(Object)}
+ */
+public abstract class StartConfigPartial<T> implements Startable, Configurable<T> {
+    private static final Logger logger = LoggerFactory.getLogger(StartConfigPartial.class);
+
+    @Getter
+    private final String fullName;
+
+    public enum State {
+        IDLE, CONFIGURED, ALIVE
+    }
+
+    private State state = State.IDLE;
+
+    /**
+     * Constructs the object.
+     *
+     * @param fullName full name of this object, used for logging and exception purposes
+     */
+    public StartConfigPartial(String fullName) {
+        this.fullName = fullName;
+    }
+
+    @Override
+    public synchronized boolean isAlive() {
+        return (state == State.ALIVE);
+    }
+
+    /**
+     * Determines if this object has been configured.
+     *
+     * @return {@code true} if this object has been configured, {@code false} otherwise
+     */
+    public synchronized boolean isConfigured() {
+        return (state != State.IDLE);
+    }
+
+    @Override
+    public synchronized void configure(T parameters) {
+        if (isAlive()) {
+            throw new IllegalStateException("attempt to reconfigure, but already running " + getFullName());
+        }
+
+        logger.info("initializing {}", getFullName());
+
+        doConfigure(parameters);
+
+        state = State.CONFIGURED;
+    }
+
+    @Override
+    public synchronized boolean start() {
+        switch (state) {
+            case ALIVE:
+                logger.info("{} is already running", getFullName());
+                break;
+
+            case CONFIGURED:
+                logger.info("starting {}", getFullName());
+                doStart();
+                state = State.ALIVE;
+                break;
+
+            case IDLE:
+            default:
+                throw new IllegalStateException("attempt to start unconfigured " + getFullName());
+        }
+
+        return true;
+    }
+
+    @Override
+    public synchronized boolean stop() {
+        if (isAlive()) {
+            logger.info("stopping {}", getFullName());
+            state = State.CONFIGURED;
+            doStop();
+
+        } else {
+            logger.info("{} is not running", getFullName());
+        }
+
+        return true;
+    }
+
+    @Override
+    public synchronized void shutdown() {
+        if (!isAlive()) {
+            logger.info("{} is not running", getFullName());
+            return;
+        }
+
+        logger.info("shutting down actor {}", getFullName());
+        state = State.CONFIGURED;
+        doShutdown();
+    }
+
+    /**
+     * Configures this object.
+     *
+     * @param parameters configuration parameters
+     */
+    protected abstract void doConfigure(T parameters);
+
+    /**
+     * Starts this object.
+     */
+    protected abstract void doStart();
+
+    /**
+     * Stops this object.
+     */
+    protected abstract void doStop();
+
+    /**
+     * Shuts down this object.
+     */
+    protected abstract void doShutdown();
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ControlLoopOperationParams.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ControlLoopOperationParams.java
new file mode 100644
index 000000000..08aba81f2
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ControlLoopOperationParams.java
@@ -0,0 +1,210 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ForkJoinPool;
+import java.util.function.Consumer;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import org.onap.policy.common.parameters.BeanValidationResult;
+import org.onap.policy.common.parameters.BeanValidator;
+import org.onap.policy.common.parameters.annotations.NotNull;
+import org.onap.policy.controlloop.ControlLoopOperation;
+import org.onap.policy.controlloop.actorserviceprovider.ActorService;
+import org.onap.policy.controlloop.actorserviceprovider.Util;
+import org.onap.policy.controlloop.actorserviceprovider.controlloop.ControlLoopEventContext;
+import org.onap.policy.controlloop.policy.Policy;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Parameters for control loop operations. The executor defaults to
+ * {@link ForkJoinPool#commonPool()}, but may be overridden.
+ */
+@Getter
+@Builder(toBuilder = true)
+@AllArgsConstructor
+@EqualsAndHashCode
+public class ControlLoopOperationParams {
+
+    private static final Logger logger = LoggerFactory.getLogger(ControlLoopOperationParams.class);
+
+    public static final String UNKNOWN = "-unknown-";
+
+
+    /**
+     * The actor service in which to find the actor/operation.
+     */
+    @NotNull
+    private ActorService actorService;
+
+    /**
+     * The event for which the operation applies.
+     */
+    @NotNull
+    private ControlLoopEventContext context;
+
+    /**
+     * The executor to use to run the operation.
+     */
+    @NotNull
+    @Builder.Default
+    private Executor executor = ForkJoinPool.commonPool();
+
+    /**
+     * The policy associated with the operation.
+     */
+    @NotNull
+    private Policy policy;
+
+    /**
+     * The function to invoke when the operation starts. This is optional.
+     * <p/>
+     * Note: this may be invoked multiple times, but with different actor/operations. That
+     * may happen if the current operation requires other operations to be performed first
+     * (e.g., A&AI queries, guard checks).
+     */
+    private Consumer<ControlLoopOperation> startCallback;
+
+    /**
+     * The function to invoke when the operation completes. This is optional.
+     * <p/>
+     * Note: this may be invoked multiple times, but with different actor/operations. That
+     * may happen if the current operation requires other operations to be performed first
+     * (e.g., A&AI queries, guard checks).
+     */
+    private Consumer<ControlLoopOperation> completeCallback;
+
+    /**
+     * Target entity.
+     */
+    @NotNull
+    private String target;
+
+    /**
+     * Starts the specified operation.
+     *
+     * @return a future that will return the result of the operation
+     * @throws IllegalArgumentException if the parameters are invalid
+     */
+    public CompletableFuture<ControlLoopOperation> start() {
+        BeanValidationResult result = validate();
+        if (!result.isValid()) {
+            logger.warn("parameter error in operation {}.{} for {}:\n{}", getActor(), getOperation(), getRequestId(),
+                            result.getResult());
+            throw new IllegalArgumentException("invalid parameters");
+        }
+
+        // @formatter:off
+        return actorService
+                    .getActor(policy.getActor())
+                    .getOperator(policy.getRecipe())
+                    .startOperation(this);
+        // @formatter:on
+    }
+
+    /**
+     * Gets the name of the actor from the policy.
+     *
+     * @return the actor name, or {@link #UNKNOWN} if no name is available
+     */
+    public String getActor() {
+        return (policy == null || policy.getActor() == null ? UNKNOWN : policy.getActor());
+    }
+
+    /**
+     * Gets the name of the operation from the policy.
+     *
+     * @return the operation name, or {@link #UNKNOWN} if no name is available
+     */
+    public String getOperation() {
+        return (policy == null || policy.getRecipe() == null ? UNKNOWN : policy.getRecipe());
+    }
+
+    /**
+     * Gets the requested ID of the associated event.
+     *
+     * @return the event's request ID, or {@code null} if no request ID is available
+     */
+    public UUID getRequestId() {
+        return (context == null || context.getEvent() == null ? null : context.getEvent().getRequestId());
+    }
+
+    /**
+     * Makes an operation outcome, populating it from the parameters.
+     *
+     * @return a new operation outcome
+     */
+    public ControlLoopOperation makeOutcome() {
+        ControlLoopOperation operation = new ControlLoopOperation();
+        operation.setActor(getActor());
+        operation.setOperation(getOperation());
+        operation.setTarget(target);
+
+        return operation;
+    }
+
+    /**
+     * Invokes the callback to indicate that the operation has started. Any exceptions
+     * generated by the callback are logged, but not re-thrown.
+     *
+     * @param operation the operation that is being started
+     */
+    public void callbackStarted(ControlLoopOperation operation) {
+        logger.info("started operation {}.{} for {}", operation.getActor(), operation.getOperation(), getRequestId());
+
+        if (startCallback != null) {
+            Util.logException(() -> startCallback.accept(operation), "{}.{}: start-callback threw an exception for {}",
+                            operation.getActor(), operation.getOperation(), getRequestId());
+        }
+    }
+
+    /**
+     * Invokes the callback to indicate that the operation has completed. Any exceptions
+     * generated by the callback are logged, but not re-thrown.
+     *
+     * @param operation the operation that is being started
+     */
+    public void callbackCompleted(ControlLoopOperation operation) {
+        logger.info("completed operation {}.{} outcome={} for {}", operation.getActor(), operation.getOperation(),
+                        operation.getOutcome(), getRequestId());
+
+        if (completeCallback != null) {
+            Util.logException(() -> completeCallback.accept(operation),
+                            "{}.{}: complete-callback threw an exception for {}", operation.getActor(),
+                            operation.getOperation(), getRequestId());
+        }
+    }
+
+    /**
+     * Validates the parameters.
+     *
+     * @return the validation result
+     */
+    public BeanValidationResult validate() {
+        return new BeanValidator().validateTop(ControlLoopOperationParams.class.getSimpleName(), this);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpActorParams.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpActorParams.java
new file mode 100644
index 000000000..da4fb4f0c
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpActorParams.java
@@ -0,0 +1,112 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import java.util.Map;
+import java.util.function.Function;
+import lombok.Data;
+import org.onap.policy.common.parameters.BeanValidationResult;
+import org.onap.policy.common.parameters.BeanValidator;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.common.parameters.annotations.Min;
+import org.onap.policy.common.parameters.annotations.NotBlank;
+import org.onap.policy.common.parameters.annotations.NotNull;
+import org.onap.policy.controlloop.actorserviceprovider.Util;
+
+/**
+ * Parameters used by Actors that connect to a server via HTTP. This contains the
+ * parameters that are common to all of the operations. Only the path changes for each
+ * operation, thus it includes a mapping from operation name to path.
+ */
+@Data
+@NotNull
+@NotBlank
+public class HttpActorParams {
+
+    /**
+     * Name of the HttpClient, as found in the HttpClientFactory.
+     */
+    private String clientName;
+
+    /**
+     * Amount of time, in seconds to wait for the HTTP request to complete, where zero
+     * indicates that it should wait forever. The default is zero.
+     */
+    @Min(0)
+    private long timeoutSec = 0;
+
+    /**
+     * Maps the operation name to its URI path.
+     */
+    private Map<String, String> path;
+
+    /**
+     * Extracts a specific operation's parameters from "this".
+     *
+     * @param name name of the item containing "this"
+     * @return a function to extract an operation's parameters from "this". Note: the
+     *         returned function is not thread-safe
+     */
+    public Function<String, Map<String, Object>> makeOperationParameters(String name) {
+        HttpParams subparams = HttpParams.builder().clientName(getClientName()).timeoutSec(getTimeoutSec()).build();
+
+        return operation -> {
+            String subpath = path.get(operation);
+            if (subpath == null) {
+                return null;
+            }
+
+            subparams.setPath(subpath);
+            return Util.translateToMap(name + "." + operation, subparams);
+        };
+    }
+
+    /**
+     * Validates the parameters.
+     *
+     * @param name name of the object containing these parameters
+     * @return "this"
+     * @throws IllegalArgumentException if the parameters are invalid
+     */
+    public HttpActorParams doValidation(String name) {
+        ValidationResult result = validate(name);
+        if (!result.isValid()) {
+            throw new ParameterValidationRuntimeException("invalid parameters", result);
+        }
+
+        return this;
+    }
+
+    /**
+     * Validates the parameters.
+     *
+     * @param resultName name of the result
+     *
+     * @return the validation result
+     */
+    public ValidationResult validate(String resultName) {
+        BeanValidationResult result = new BeanValidator().validateTop(resultName, this);
+
+        result.validateMap("path", path, (result2, entry) -> result2.validateNotNull(entry.getKey(), entry.getValue()));
+
+        return result;
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpParams.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpParams.java
new file mode 100644
index 000000000..695ffe4dd
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpParams.java
@@ -0,0 +1,69 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import lombok.Builder;
+import lombok.Data;
+import org.onap.policy.common.parameters.BeanValidator;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.common.parameters.annotations.Min;
+import org.onap.policy.common.parameters.annotations.NotBlank;
+import org.onap.policy.common.parameters.annotations.NotNull;
+
+/**
+ * Parameters used by Operators that connect to a server via HTTP.
+ */
+@NotNull
+@NotBlank
+@Data
+@Builder(toBuilder = true)
+public class HttpParams {
+
+    /**
+     * Name of the HttpClient, as found in the HttpClientFactory.
+     */
+    private String clientName;
+
+    /**
+     * URI path.
+     */
+    private String path;
+
+    /**
+     * Amount of time, in seconds to wait for the HTTP request to complete, where zero
+     * indicates that it should wait forever. The default is zero.
+     */
+    @Min(0)
+    @Builder.Default
+    private long timeoutSec = 0;
+
+
+    /**
+     * Validates the parameters.
+     *
+     * @param resultName name of the result
+     *
+     * @return the validation result
+     */
+    public ValidationResult validate(String resultName) {
+        return new BeanValidator().validateTop(resultName, this);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ParameterValidationRuntimeException.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ParameterValidationRuntimeException.java
new file mode 100644
index 000000000..3004e1932
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ParameterValidationRuntimeException.java
@@ -0,0 +1,57 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import lombok.Getter;
+import org.onap.policy.common.parameters.ValidationResult;
+
+/**
+ * Parameter runtime exception, with an associated validation result. This is used to
+ * throw an exception while passing a validation result up the chain.
+ * <p/>
+ * Note: the validation result is <i>not</i> included in the exception message.
+ */
+public class ParameterValidationRuntimeException extends RuntimeException {
+    private static final long serialVersionUID = 1L;
+
+    @Getter
+    private final transient ValidationResult result;
+
+
+    public ParameterValidationRuntimeException(ValidationResult result) {
+        this.result = result;
+    }
+
+    public ParameterValidationRuntimeException(String message, ValidationResult result) {
+        super(message);
+        this.result = result;
+    }
+
+    public ParameterValidationRuntimeException(Throwable cause, ValidationResult result) {
+        super(cause);
+        this.result = result;
+    }
+
+    public ParameterValidationRuntimeException(String message, Throwable cause, ValidationResult result) {
+        super(message, cause);
+        this.result = result;
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicParams.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicParams.java
new file mode 100644
index 000000000..9e6d8a15e
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicParams.java
@@ -0,0 +1,68 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import lombok.Builder;
+import lombok.Data;
+import org.onap.policy.common.parameters.BeanValidator;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.common.parameters.annotations.Min;
+import org.onap.policy.common.parameters.annotations.NotBlank;
+import org.onap.policy.common.parameters.annotations.NotNull;
+
+/**
+ * Parameters used by Operators that connect to a server via DMaaP.
+ */
+@NotNull
+@NotBlank
+@Data
+@Builder(toBuilder = true)
+public class TopicParams {
+
+    /**
+     * Name of the target topic end point to which requests should be published.
+     */
+    private String target;
+
+    /**
+     * Source topic end point, from which to read responses.
+     */
+    private String source;
+
+    /**
+     * Amount of time, in seconds to wait for the response, where zero indicates that it
+     * should wait forever. The default is zero.
+     */
+    @Min(0)
+    @Builder.Default
+    private long timeoutSec = 0;
+
+    /**
+     * Validates both the publisher and the subscriber parameters.
+     *
+     * @param resultName name of the result
+     *
+     * @return the validation result
+     */
+    public ValidationResult validate(String resultName) {
+        return new BeanValidator().validateTop(resultName, this);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/FutureManager.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/FutureManager.java
new file mode 100644
index 000000000..aac2f77b7
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/FutureManager.java
@@ -0,0 +1,89 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.pipeline;
+
+import java.util.IdentityHashMap;
+import java.util.concurrent.Future;
+import lombok.NoArgsConstructor;
+
+/**
+ * Manager that manages both futures and listeners. When {@link #stop()} is called, the
+ * listeners are executed and the futures are canceled. The various methods synchronize on
+ * "this" while they manipulate internal data structures.
+ */
+@NoArgsConstructor
+public class FutureManager extends ListenerManager {
+
+    /**
+     * Maps a future to its listener. Records the {@link Runnable} that is passed to
+     * {@link ListenerManager#add(Runnable)} when {@link #add(Future)} is invoked. This is
+     * needed if {@link #remove(Future)} is invoked, so that the same {@link Runnable} is
+     * used each time.
+     */
+    @SuppressWarnings("rawtypes")
+    private final IdentityHashMap<Future, Runnable> future2listener = new IdentityHashMap<>(5);
+
+    /**
+     * Adds a future that is to be canceled when this controller is stopped. Note: if the
+     * controller is already stopped, then the future will be canceled immediately, within
+     * the invoking thread.
+     *
+     * @param future future to be added
+     */
+    public <T> void add(Future<T> future) {
+        Runnable listener = () -> future.cancel(false);
+
+        synchronized (this) {
+            if (future2listener.putIfAbsent(future, listener) != null) {
+                // this future is already in the map, nothing more to do
+                return;
+            }
+
+            if (addOnly(listener)) {
+                // successfully added
+                return;
+            }
+        }
+
+        runListener(listener);
+    }
+
+    /**
+     * Removes a future so that it is not canceled when this controller is stopped.
+     *
+     * @param future future to be removed
+     */
+    public synchronized <T> void remove(Future<T> future) {
+        Runnable listener = future2listener.remove(future);
+        if (listener != null) {
+            remove(listener);
+        }
+    }
+
+    @Override
+    public void stop() {
+        super.stop();
+
+        synchronized (this) {
+            future2listener.clear();
+        }
+    }
+}
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
new file mode 100644
index 000000000..d34a3fb5b
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManager.java
@@ -0,0 +1,115 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.pipeline;
+
+import java.util.ArrayList;
+import java.util.IdentityHashMap;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.onap.policy.controlloop.actorserviceprovider.Util;
+
+/**
+ * Listener manager, used by operations within the pipeline to determine if they should
+ * continue to run. When {@link #stop()} is called, the listeners are executed. The
+ * various methods synchronize on "this" while they manipulate internal data structures.
+ */
+@NoArgsConstructor
+public class ListenerManager {
+
+    @Getter
+    private volatile boolean running = true;
+
+    /**
+     * Listeners to be executed when {@link #stop()} is invoked.
+     */
+    private final IdentityHashMap<Runnable, Void> listeners = new IdentityHashMap<>(5);
+
+    /**
+     * Indicates that operations within the pipeline should stop executing.
+     */
+    public void stop() {
+        ArrayList<Runnable> items;
+
+        synchronized (this) {
+            if (!running) {
+                return;
+            }
+
+            running = false;
+            items = new ArrayList<>(listeners.keySet());
+            listeners.clear();
+        }
+
+        items.forEach(this::runListener);
+    }
+
+    /**
+     * Adds a listener that is to be invoked when this controller is stopped. Note: if the
+     * controller is already stopped, then the listener will be invoked immediately,
+     * within the invoking thread.
+     *
+     * @param listener listener to be added
+     */
+    public void add(Runnable listener) {
+        if (!addOnly(listener)) {
+            runListener(listener);
+        }
+    }
+
+    /**
+     * Adds a listener that is to be invoked when this controller is stopped. Note: if the
+     * controller is already stopped, then the listener will be invoked immediately,
+     * within the invoking thread.
+     *
+     * @param listener listener to be added
+     * @return {@code true} if the the listener was added, {@code false} if it could not
+     *         be added because this manager has already been stopped
+     */
+    protected boolean addOnly(Runnable listener) {
+        synchronized (this) {
+            if (running) {
+                listeners.put(listener, null);
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    /**
+     * Runs a listener, catching any exceptions that it may throw.
+     *
+     * @param listener listener to be executed
+     */
+    protected void runListener(Runnable listener) {
+        // TODO do this asynchronously?
+        Util.logException(listener, "pipeline listener {} threw an exception", listener);
+    }
+
+    /**
+     * Removes a listener so that it is not invoked when this controller is stopped.
+     *
+     * @param listener listener to be removed
+     */
+    public synchronized void remove(Runnable listener) {
+        listeners.remove(listener);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/PipelineControllerFuture.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/PipelineControllerFuture.java
new file mode 100644
index 000000000..96c8f9e05
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/PipelineControllerFuture.java
@@ -0,0 +1,157 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.pipeline;
+
+import static org.onap.policy.controlloop.actorserviceprovider.Util.ident;
+
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Future;
+import java.util.function.BiConsumer;
+import java.util.function.Function;
+import lombok.NoArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Pipeline controller, used by operations within the pipeline to determine if they should
+ * continue to run. If {@link #cancel(boolean)} is invoked, it automatically stops the
+ * pipeline.
+ */
+@NoArgsConstructor
+public class PipelineControllerFuture<T> extends CompletableFuture<T> {
+
+    private static final Logger logger = LoggerFactory.getLogger(PipelineControllerFuture.class);
+
+    /**
+     * Tracks items added to this controller via one of the <i>add</i> methods.
+     */
+    private final FutureManager futures = new FutureManager();
+
+
+    /**
+     * Cancels and stops the pipeline, in that order.
+     */
+    @Override
+    public boolean cancel(boolean mayInterruptIfRunning) {
+        try {
+            logger.trace("{}: cancel future", ident(this));
+            return super.cancel(mayInterruptIfRunning);
+
+        } finally {
+            futures.stop();
+        }
+    }
+
+    /**
+     * Generates a function that, when invoked, will remove the given future. This is
+     * typically added onto the end of a pipeline via one of the
+     * {@link CompletableFuture#whenComplete(BiConsumer)} methods.
+     *
+     * @return a function that removes the given future
+     */
+    public <F> BiConsumer<T, Throwable> delayedRemove(Future<F> future) {
+        return (value, thrown) -> {
+            logger.trace("{}: remove future {}", ident(this), ident(future));
+            remove(future);
+        };
+    }
+
+    /**
+     * Generates a function that, when invoked, will remove the given listener. This is
+     * typically added onto the end of a pipeline via one of the
+     * {@link CompletableFuture#whenComplete(BiConsumer)} methods.
+     *
+     * @return a function that removes the given listener
+     */
+    public BiConsumer<T, Throwable> delayedRemove(Runnable listener) {
+        return (value, thrown) -> {
+            logger.trace("{}: remove listener {}", ident(this), ident(listener));
+            remove(listener);
+        };
+    }
+
+    /**
+     * Generates a function that, when invoked, will stop all pipeline listeners and
+     * complete this future. This is typically added onto the end of a pipeline via one of
+     * the {@link CompletableFuture#whenComplete(BiConsumer)} methods.
+     *
+     * @return a function that stops all pipeline listeners
+     */
+    public BiConsumer<T, Throwable> delayedComplete() {
+        return (value, thrown) -> {
+            if (thrown == null) {
+                logger.trace("{}: complete and stop future", ident(this));
+                complete(value);
+            } else {
+                logger.trace("{}: complete exceptionally and stop future", ident(this));
+                completeExceptionally(thrown);
+            }
+
+            futures.stop();
+        };
+    }
+
+    /**
+     * Adds a function whose return value is to be canceled when this controller is
+     * stopped. Note: if the controller is already stopped, then the function will
+     * <i>not</i> be executed.
+     *
+     * @param futureMaker function to be invoked in the future
+     */
+    public <F> Function<F, CompletableFuture<F>> add(Function<F, CompletableFuture<F>> futureMaker) {
+
+        return input -> {
+            if (!isRunning()) {
+                logger.trace("{}: discarded new future", ident(this));
+                return new CompletableFuture<>();
+            }
+
+            CompletableFuture<F> future = futureMaker.apply(input);
+            add(future);
+
+            return future;
+        };
+    }
+
+    public <F> void add(Future<F> future) {
+        logger.trace("{}: add future {}", ident(this), ident(future));
+        futures.add(future);
+    }
+
+    public void add(Runnable listener) {
+        logger.trace("{}: add listener {}", ident(this), ident(listener));
+        futures.add(listener);
+    }
+
+    public boolean isRunning() {
+        return futures.isRunning();
+    }
+
+    public <F> void remove(Future<F> future) {
+        logger.trace("{}: remove future {}", ident(this), ident(future));
+        futures.remove(future);
+    }
+
+    public void remove(Runnable listener) {
+        logger.trace("{}: remove listener {}", ident(this), ident(listener));
+        futures.remove(listener);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/spi/Actor.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/spi/Actor.java
index 88f3c16eb..620950a3c 100644
--- a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/spi/Actor.java
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/spi/Actor.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * Actor
  * ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2018, 2020 AT&T Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -21,9 +21,56 @@
 
 package org.onap.policy.controlloop.actorserviceprovider.spi;
 
+import java.util.Collection;
+
 import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import org.onap.policy.common.capabilities.Configurable;
+import org.onap.policy.common.capabilities.Startable;
+import org.onap.policy.controlloop.actorserviceprovider.Operator;
+
+/**
+ * This is the service interface for defining an Actor used in Control Loop Operational
+ * Policies for performing actions on runtime entities.
+ *
+ * @author pameladragosh
+ *
+ */
+public interface Actor extends Startable, Configurable<Map<String,Object>> {
+
+    /**
+     * Gets the name of the actor.
+     *
+     * @return the actor name
+     */
+    String getName();
+
+    /**
+     * Gets a particular operator.
+     *
+     * @param name name of the operation of interest
+     * @return the desired operation
+     * @throws IllegalArgumentException if no operation by the given name exists
+     */
+    Operator getOperator(String name);
+
+    /**
+     * Gets the supported operations.
+     *
+     * @return the supported operations
+     */
+    public Collection<Operator> getOperators();
+
+    /**
+     * Gets the names of the supported operations.
+     *
+     * @return the names of the supported operations
+     */
+    public Set<String> getOperationNames();
+
 
-public interface Actor {
+    // TODO old code: remove lines down to **HERE**
 
     String actor();
 
@@ -33,4 +80,5 @@ public interface Actor {
 
     List<String> recipePayloads(String recipe);
 
+    // **HERE**
 }
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceProviderTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceProviderTest.java
index 7ab21dece..139c5179b 100644
--- a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceProviderTest.java
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceProviderTest.java
@@ -4,7 +4,7 @@
  * ================================================================================
  * Copyright (C) 2018 Ericsson. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
- * Modifications Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2019-2020 AT&T Intellectual Property. All rights reserved.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -28,6 +28,8 @@ import static org.junit.Assert.assertNotNull;
 import org.junit.Test;
 import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
 
+// TODO combine this with ActorServiceTest
+
 public class ActorServiceProviderTest {
 
     private static final String DOROTHY = "Dorothy";
@@ -37,12 +39,12 @@ public class ActorServiceProviderTest {
         ActorService actorService = ActorService.getInstance();
         assertNotNull(actorService);
 
-        assertEquals(1, actorService.actors().size());
+        assertEquals(1, actorService.getActors().size());
 
         actorService = ActorService.getInstance();
         assertNotNull(actorService);
 
-        Actor dummyActor = ActorService.getInstance().actors().get(0);
+        Actor dummyActor = ActorService.getInstance().getActors().iterator().next();
         assertNotNull(dummyActor);
 
         assertEquals("DummyActor", dummyActor.actor());
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceTest.java
new file mode 100644
index 000000000..851a79129
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/ActorServiceTest.java
@@ -0,0 +1,382 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.spy;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.function.Consumer;
+import java.util.stream.Collectors;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ObjectValidationResult;
+import org.onap.policy.common.parameters.ValidationStatus;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ParameterValidationRuntimeException;
+import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+
+public class ActorServiceTest {
+    private static final String EXPECTED_EXCEPTION = "expected exception";
+    private static final String ACTOR1 = "actor A";
+    private static final String ACTOR2 = "actor B";
+    private static final String ACTOR3 = "actor C";
+    private static final String ACTOR4 = "actor D";
+
+    private Actor actor1;
+    private Actor actor2;
+    private Actor actor3;
+    private Actor actor4;
+
+    private Map<String, Object> sub1;
+    private Map<String, Object> sub2;
+    private Map<String, Object> sub3;
+    private Map<String, Object> sub4;
+    private Map<String, Object> params;
+
+    private ActorService service;
+
+
+    /**
+     * Initializes the fields, including a fully populated {@link #service}.
+     */
+    @Before
+    public void setUp() {
+        actor1 = spy(new ActorImpl(ACTOR1));
+        actor2 = spy(new ActorImpl(ACTOR2));
+        actor3 = spy(new ActorImpl(ACTOR3));
+        actor4 = spy(new ActorImpl(ACTOR4));
+
+        sub1 = Map.of("sub A", "value A");
+        sub2 = Map.of("sub B", "value B");
+        sub3 = Map.of("sub C", "value C");
+        sub4 = Map.of("sub D", "value D");
+
+        params = Map.of(ACTOR1, sub1, ACTOR2, sub2, ACTOR3, sub3, ACTOR4, sub4);
+
+        service = makeService(actor1, actor2, actor3, actor4);
+    }
+
+    @Test
+    public void testActorService() {
+        /*
+         * make a service where actors two and four have names that are duplicates of the
+         * others
+         */
+        actor2 = spy(new ActorImpl(ACTOR1));
+        actor4 = spy(new ActorImpl(ACTOR3));
+
+        service = makeService(actor1, actor2, actor3, actor4);
+
+        assertEquals(2, service.getActorNames().size());
+
+        assertSame(actor1, service.getActor(ACTOR1));
+        assertSame(actor3, service.getActor(ACTOR3));
+    }
+
+    @Test
+    public void testDoStart() {
+        service.configure(params);
+
+        setUpOp("testDoStart", actor -> when(actor.isConfigured()).thenReturn(false), Actor::start);
+
+        /*
+         * Start the service.
+         */
+        service.start();
+        assertTrue(service.isAlive());
+
+        Iterator<Actor> iter = service.getActors().iterator();
+        verify(iter.next()).start();
+        verify(iter.next(), never()).start();
+        verify(iter.next()).start();
+        verify(iter.next()).start();
+
+        // no additional types of operations
+        verify(actor1).configure(any());
+
+        // no other types of operations
+        verify(actor1, never()).stop();
+        verify(actor1, never()).shutdown();
+    }
+
+    @Test
+    public void testDoStop() {
+        service.configure(params);
+        service.start();
+
+        setUpOp("testDoStop", Actor::stop, Actor::stop);
+
+        /*
+         * Stop the service.
+         */
+        service.stop();
+        assertFalse(service.isAlive());
+
+        Iterator<Actor> iter = service.getActors().iterator();
+        verify(iter.next()).stop();
+        verify(iter.next(), times(2)).stop();
+        verify(iter.next()).stop();
+        verify(iter.next()).stop();
+
+        // no additional types of operations
+        verify(actor1).configure(any());
+        verify(actor1).start();
+
+        // no other types of operation
+        verify(actor1, never()).shutdown();
+    }
+
+    @Test
+    public void testDoShutdown() {
+        service.configure(params);
+        service.start();
+
+        setUpOp("testDoShutdown", Actor::shutdown, Actor::shutdown);
+
+        /*
+         * Shut down the service.
+         */
+        service.shutdown();
+        assertFalse(service.isAlive());
+
+        Iterator<Actor> iter = service.getActors().iterator();
+        verify(iter.next()).shutdown();
+        verify(iter.next(), times(2)).shutdown();
+        verify(iter.next()).shutdown();
+        verify(iter.next()).shutdown();
+
+        // no additional types of operations
+        verify(actor1).configure(any());
+        verify(actor1).start();
+
+        // no other types of operation
+        verify(actor1, never()).stop();
+    }
+
+    /**
+     * Applies an operation to the second actor, and then arranges for the third actor to
+     * throw an exception when its operation is performed.
+     *
+     * @param testName test name
+     * @param oper2 operation to apply to the second actor
+     * @param oper3 operation to apply to the third actor
+     */
+    private void setUpOp(String testName, Consumer<Actor> oper2, Consumer<Actor> oper3) {
+        Collection<Actor> actors = service.getActors();
+        assertEquals(testName, 4, actors.size());
+
+        Iterator<Actor> iter = actors.iterator();
+
+        // leave the first alone
+        iter.next();
+
+        // apply oper2 to the second actor
+        oper2.accept(iter.next());
+
+        // throw an exception in the third
+        oper3.accept(doThrow(new IllegalStateException(EXPECTED_EXCEPTION)).when(iter.next()));
+
+        // leave the fourth alone
+        iter.next();
+    }
+
+    @Test
+    public void testGetInstance() {
+        service = ActorService.getInstance();
+        assertNotNull(service);
+
+        assertSame(service, ActorService.getInstance());
+    }
+
+    @Test
+    public void testGetActor() {
+        assertSame(actor1, service.getActor(ACTOR1));
+        assertSame(actor3, service.getActor(ACTOR3));
+
+        assertThatIllegalArgumentException().isThrownBy(() -> service.getActor("unknown actor"));
+    }
+
+    @Test
+    public void testGetActors() {
+        // @formatter:off
+        assertEquals("[actor A, actor B, actor C, actor D]",
+                        service.getActors().stream()
+                            .map(Actor::getName)
+                            .sorted()
+                            .collect(Collectors.toList())
+                            .toString());
+        // @formatter:on
+    }
+
+    @Test
+    public void testGetActorNames() {
+        // @formatter:off
+        assertEquals("[actor A, actor B, actor C, actor D]",
+                        service.getActorNames().stream()
+                            .sorted()
+                            .collect(Collectors.toList())
+                            .toString());
+        // @formatter:on
+    }
+
+    @Test
+    public void testDoConfigure() {
+        service.configure(params);
+        assertTrue(service.isConfigured());
+
+        verify(actor1).configure(sub1);
+        verify(actor2).configure(sub2);
+        verify(actor3).configure(sub3);
+        verify(actor4).configure(sub4);
+
+        // no other types of operations
+        verify(actor1, never()).start();
+        verify(actor1, never()).stop();
+        verify(actor1, never()).shutdown();
+    }
+
+    /**
+     * Tests doConfigure() where actors throw parameter validation and runtime exceptions.
+     */
+    @Test
+    public void testDoConfigureExceptions() {
+        makeValidException(actor1);
+        makeRuntimeException(actor2);
+        makeValidException(actor3);
+
+        service.configure(params);
+        assertTrue(service.isConfigured());
+    }
+
+    /**
+     * Tests doConfigure(). Arranges for the following:
+     * <ul>
+     * <li>one actor is configured, but has parameters</li>
+     * <li>another actor is configured, but has no parameters</li>
+     * <li>another actor has no parameters and is not configured</li>
+     * </ul>
+     */
+    @Test
+    public void testDoConfigureConfigure() {
+        // need mutable parameters
+        params = new TreeMap<>(params);
+
+        // configure one actor
+        actor1.configure(sub1);
+
+        // configure another and remove its parameters
+        actor2.configure(sub2);
+        params.remove(ACTOR2);
+
+        // create a new, unconfigured actor
+        ActorImpl actor5 = spy(new ActorImpl("UNCONFIGURED"));
+        service = makeService(actor1, actor2, actor3, actor4, actor5);
+
+        /*
+         * Configure it.
+         */
+        service.configure(params);
+        assertTrue(service.isConfigured());
+
+        // this should have been configured again
+        verify(actor1, times(2)).configure(sub1);
+
+        // no parameters, so this should not have been configured again
+        verify(actor2).configure(sub2);
+
+        // these were only configured once
+        verify(actor3).configure(sub3);
+        verify(actor4).configure(sub4);
+
+        // never configured
+        verify(actor5, never()).configure(any());
+        assertFalse(actor5.isConfigured());
+
+        // start and verify that all are started except for the last
+        service.start();
+        verify(actor1).start();
+        verify(actor2).start();
+        verify(actor3).start();
+        verify(actor4).start();
+        verify(actor5, never()).start();
+    }
+
+    /**
+     * Arranges for an actor to throw a validation exception when
+     * {@link Actor#configure(Map)} is invoked.
+     *
+     * @param actor actor of interest
+     */
+    private void makeValidException(Actor actor) {
+        ParameterValidationRuntimeException ex = new ParameterValidationRuntimeException(
+                        new ObjectValidationResult(actor.getName(), null, ValidationStatus.INVALID, "null"));
+        doThrow(ex).when(actor).configure(any());
+    }
+
+    /**
+     * Arranges for an actor to throw a runtime exception when
+     * {@link Actor#configure(Map)} is invoked.
+     *
+     * @param actor actor of interest
+     */
+    private void makeRuntimeException(Actor actor) {
+        IllegalStateException ex = new IllegalStateException(EXPECTED_EXCEPTION);
+        doThrow(ex).when(actor).configure(any());
+    }
+
+    @Test
+    public void testLoadActors() {
+        assertFalse(ActorService.getInstance().getActors().isEmpty());
+        assertNotNull(ActorService.getInstance().getActor("DummyActor"));
+    }
+
+    /**
+     * Makes an actor service whose {@link ActorService#loadActors()} method returns the
+     * given actors.
+     *
+     * @param actors actors to be returned
+     * @return a new actor service
+     */
+    private ActorService makeService(Actor... actors) {
+        return new ActorService() {
+            @Override
+            protected Iterable<Actor> loadActors() {
+                return Arrays.asList(actors);
+            }
+        };
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DelayedIdentStringTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DelayedIdentStringTest.java
new file mode 100644
index 000000000..5b9856f41
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DelayedIdentStringTest.java
@@ -0,0 +1,93 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertTrue;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class DelayedIdentStringTest {
+
+    private int countToStringCalls;
+    private Object object;
+    private DelayedIdentString delay;
+
+    /**
+     * Initializes fields, including {@link #delay}.
+     */
+    @Before
+    public void setUp() {
+        countToStringCalls = 0;
+
+        object = new Object() {
+            @Override
+            public String toString() {
+                ++countToStringCalls;
+                return super.toString();
+            }
+        };
+
+        delay = new DelayedIdentString(object);
+    }
+
+    @Test
+    public void testToString() {
+        String delayed = delay.toString();
+        assertEquals(1, countToStringCalls);
+
+        String real = object.toString();
+        assertNotEquals(real, delayed);
+
+        assertThat(delayed).startsWith("@");
+        assertTrue(delayed.length() > 1);
+
+        // test case where the object is null
+        assertEquals(DelayedIdentString.NULL_STRING, new DelayedIdentString(null).toString());
+
+        // test case where the object returns null from toString()
+        object = new Object() {
+            @Override
+            public String toString() {
+                return null;
+            }
+        };
+        assertEquals(DelayedIdentString.NULL_STRING, new DelayedIdentString(object).toString());
+
+        // test case where the object's toString() does not include "@"
+        object = new Object() {
+            @Override
+            public String toString() {
+                return "some text";
+            }
+        };
+        assertEquals(object.toString(), new DelayedIdentString(object).toString());
+    }
+
+    @Test
+    public void testDelayedIdentString() {
+        // should not have called the object's toString() method yet
+        assertEquals(0, countToStringCalls);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DummyActor.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DummyActor.java
index e9cf238e2..76cadffa6 100644
--- a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DummyActor.java
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/DummyActor.java
@@ -4,6 +4,7 @@
  * ================================================================================
  * Copyright (C) 2018 Ericsson. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
+ * Modifications Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -23,10 +24,14 @@ package org.onap.policy.controlloop.actorserviceprovider;
 
 import java.util.ArrayList;
 import java.util.List;
+import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
 
-import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+public class DummyActor extends ActorImpl {
+
+    public DummyActor() {
+        super(DummyActor.class.getSimpleName());
+    }
 
-public class DummyActor implements Actor {
     @Override
     public String actor() {
         return this.getClass().getSimpleName();
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/UtilTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/UtilTest.java
new file mode 100644
index 000000000..c652e8374
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/UtilTest.java
@@ -0,0 +1,126 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.concurrent.atomic.AtomicInteger;
+import lombok.Builder;
+import lombok.Data;
+import org.junit.Test;
+
+public class UtilTest {
+
+    @Test
+    public void testIdent() {
+        Object object = new Object();
+        String result = Util.ident(object).toString();
+
+        assertNotEquals(object.toString(), result);
+        assertThat(result).startsWith("@");
+        assertTrue(result.length() > 1);
+    }
+
+    @Test
+    public void testLogException() {
+        // no exception, no log
+        AtomicInteger count = new AtomicInteger();
+        Util.logException(() -> count.incrementAndGet(), "no error");
+        assertEquals(1, count.get());
+
+        // with an exception
+        Runnable runnable = () -> {
+            count.incrementAndGet();
+            throw new IllegalStateException("expected exception");
+        };
+
+        Util.logException(runnable, "error with no args");
+        Util.logException(runnable, "error {} {} arg(s)", "with", 1);
+    }
+
+    @Test
+    public void testTranslate() {
+        // Abc => Abc
+        final Abc abc = Abc.builder().intValue(1).strValue("hello").anotherString("another").build();
+        Abc abc2 = Util.translate("abc to abc", abc, Abc.class);
+        assertEquals(abc, abc2);
+
+        // Abc => Similar
+        Similar sim = Util.translate("abc to similar", abc, Similar.class);
+        assertEquals(abc.getIntValue(), sim.getIntValue());
+        assertEquals(abc.getStrValue(), sim.getStrValue());
+
+        // Abc => Map
+        @SuppressWarnings("unchecked")
+        Map<String, Object> map = Util.translate("abc to map", abc, TreeMap.class);
+        assertEquals("{anotherString=another, intValue=1, strValue=hello}", map.toString());
+
+        // Map => Map
+        @SuppressWarnings("unchecked")
+        Map<String, Object> map2 = Util.translate("map to map", map, LinkedHashMap.class);
+        assertEquals(map.toString(), map2.toString());
+
+        // Map => Abc
+        abc2 = Util.translate("map to abc", map, Abc.class);
+        assertEquals(abc, abc2);
+    }
+
+    @Test
+    public void testTranslateToMap() {
+        assertNull(Util.translateToMap("map: null", null));
+
+        // Abc => Map
+        final Abc abc = Abc.builder().intValue(2).strValue("world").anotherString("some").build();
+        Map<String, Object> map = new TreeMap<>(Util.translateToMap("map: abc to map", abc));
+        assertEquals("{anotherString=some, intValue=2, strValue=world}", map.toString());
+
+        // Map => Map
+        Map<String, Object> map2 = Util.translateToMap("map: map to map", map);
+        assertEquals(map.toString(), map2.toString());
+
+        assertThatIllegalArgumentException().isThrownBy(() -> Util.translateToMap("map: string", "some string"))
+                        .withMessageContaining("map: string");
+    }
+
+    @Data
+    @Builder
+    public static class Abc {
+        private int intValue;
+        private String strValue;
+        private String anotherString;
+    }
+
+    // this shares some fields with Abc so the data should transfer
+    @Data
+    @Builder
+    public static class Similar {
+        private int intValue;
+        private String strValue;
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/controlloop/ControlLoopEventContextTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/controlloop/ControlLoopEventContextTest.java
new file mode 100644
index 000000000..fcc3fb12e
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/controlloop/ControlLoopEventContextTest.java
@@ -0,0 +1,60 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.controlloop;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertSame;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+
+public class ControlLoopEventContextTest {
+
+    private VirtualControlLoopEvent event;
+    private ControlLoopEventContext context;
+
+    @Before
+    public void setUp() {
+        event = new VirtualControlLoopEvent();
+        context = new ControlLoopEventContext(event);
+    }
+
+    @Test
+    public void testControlLoopEventContext() {
+        assertSame(event, context.getEvent());
+    }
+
+    @Test
+    public void testContains_testGetProperty_testSetProperty() {
+        context.setProperty("abc", "a string");
+        context.setProperty("def", 100);
+
+        assertFalse(context.contains("ghi"));
+
+        String strValue = context.getProperty("abc");
+        assertEquals("a string", strValue);
+
+        int intValue = context.getProperty("def");
+        assertEquals(100, intValue);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/ActorImplTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/ActorImplTest.java
new file mode 100644
index 000000000..7e0c35a3f
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/ActorImplTest.java
@@ -0,0 +1,379 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.impl;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.spy;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.util.Collections;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.stream.Collectors;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ObjectValidationResult;
+import org.onap.policy.common.parameters.ValidationStatus;
+import org.onap.policy.controlloop.actorserviceprovider.Operator;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ParameterValidationRuntimeException;
+
+public class ActorImplTest {
+    private static final String EXPECTED_EXCEPTION = "expected exception";
+    private static final String ACTOR_NAME = "my-actor";
+    private static final String OPER1 = "add";
+    private static final String OPER2 = "subtract";
+    private static final String OPER3 = "multiply";
+    private static final String OPER4 = "divide";
+
+    private MyOper oper1;
+    private MyOper oper2;
+    private MyOper oper3;
+    private MyOper oper4;
+
+    private Map<String, Object> sub1;
+    private Map<String, Object> sub2;
+    private Map<String, Object> sub3;
+    private Map<String, Object> sub4;
+    private Map<String, Object> params;
+
+    private ActorImpl actor;
+
+
+    /**
+     * Initializes the fields, including a fully populated {@link #actor}.
+     */
+    @Before
+    public void setUp() {
+        oper1 = spy(new MyOper(OPER1));
+        oper2 = spy(new MyOper(OPER2));
+        oper3 = spy(new MyOper(OPER3));
+        oper4 = spy(new MyOper(OPER4));
+
+        sub1 = Map.of("sub A", "value A");
+        sub2 = Map.of("sub B", "value B");
+        sub3 = Map.of("sub C", "value C");
+        sub4 = Map.of("sub D", "value D");
+
+        params = Map.of(OPER1, sub1, OPER2, sub2, OPER3, sub3, OPER4, sub4);
+
+        actor = makeActor(oper1, oper2, oper3, oper4);
+    }
+
+    @Test
+    public void testActorImpl_testGetName() {
+        assertEquals(ACTOR_NAME, actor.getName());
+        assertEquals(4, actor.getOperationNames().size());
+    }
+
+    @Test
+    public void testDoStart() {
+        actor.configure(params);
+        assertEquals(4, actor.getOperationNames().size());
+
+        /*
+         * arrange for second operator to be unconfigured and the third operator to throw
+         * an exception
+         */
+        Iterator<Operator> iter = actor.getOperators().iterator();
+        iter.next();
+        when(iter.next().isConfigured()).thenReturn(false);
+        when(iter.next().start()).thenThrow(new IllegalStateException(EXPECTED_EXCEPTION));
+
+        /*
+         * Start the actor.
+         */
+        actor.start();
+        assertTrue(actor.isAlive());
+
+        iter = actor.getOperators().iterator();
+        verify(iter.next()).start();
+        // this one isn't configured, so shouldn't attempt to start it
+        verify(iter.next(), never()).start();
+        // this one threw an exception
+        iter.next();
+        verify(iter.next()).start();
+
+        // no other types of operations
+        verify(oper1, never()).stop();
+        verify(oper1, never()).shutdown();
+    }
+
+    @Test
+    public void testDoStop() {
+        actor.configure(params);
+        actor.start();
+        assertEquals(4, actor.getOperationNames().size());
+
+        // arrange for second operator to throw an exception
+        Iterator<Operator> iter = actor.getOperators().iterator();
+        iter.next();
+        when(iter.next().stop()).thenThrow(new IllegalStateException(EXPECTED_EXCEPTION));
+
+        /*
+         * Stop the actor.
+         */
+        actor.stop();
+        assertFalse(actor.isAlive());
+
+        iter = actor.getOperators().iterator();
+        verify(iter.next()).stop();
+        // this one threw an exception
+        iter.next();
+        verify(iter.next()).stop();
+        verify(iter.next()).stop();
+
+        // no additional types of operations
+        verify(oper1).configure(any());
+        verify(oper1).start();
+
+        // no other types of operation
+        verify(oper1, never()).shutdown();
+    }
+
+    @Test
+    public void testDoShutdown() {
+        actor.configure(params);
+        actor.start();
+        assertEquals(4, actor.getOperationNames().size());
+
+        // arrange for second operator to throw an exception
+        Iterator<Operator> iter = actor.getOperators().iterator();
+        iter.next();
+        doThrow(new IllegalStateException(EXPECTED_EXCEPTION)).when(iter.next()).shutdown();
+
+        /*
+         * Stop the actor.
+         */
+        actor.shutdown();
+        assertFalse(actor.isAlive());
+
+        iter = actor.getOperators().iterator();
+        verify(iter.next()).shutdown();
+        // this one threw an exception
+        iter.next();
+        verify(iter.next()).shutdown();
+        verify(iter.next()).shutdown();
+
+        // no additional types of operations
+        verify(oper1).configure(any());
+        verify(oper1).start();
+
+        // no other types of operation
+        verify(oper1, never()).stop();
+    }
+
+    @Test
+    public void testSetOperators() {
+        // cannot set operators if already configured
+        actor.configure(params);
+        assertThatIllegalStateException().isThrownBy(() -> actor.setOperators(Collections.emptyList()));
+
+        /*
+         * make an actor where operators two and four have names that are duplicates of
+         * the others
+         */
+        oper2 = spy(new MyOper(OPER1));
+        oper4 = spy(new MyOper(OPER3));
+
+        actor = makeActor(oper1, oper2, oper3, oper4);
+
+        assertEquals(2, actor.getOperationNames().size());
+
+        assertSame(oper1, actor.getOperator(OPER1));
+        assertSame(oper3, actor.getOperator(OPER3));
+    }
+
+    @Test
+    public void testGetOperator() {
+        assertSame(oper1, actor.getOperator(OPER1));
+        assertSame(oper3, actor.getOperator(OPER3));
+
+        assertThatIllegalArgumentException().isThrownBy(() -> actor.getOperator("unknown name"));
+    }
+
+    @Test
+    public void testGetOperators() {
+        // @formatter:off
+        assertEquals("[add, divide, multiply, subtract]",
+                        actor.getOperators().stream()
+                            .map(Operator::getName)
+                            .sorted()
+                            .collect(Collectors.toList())
+                            .toString());
+        // @formatter:on
+    }
+
+    @Test
+    public void testGetOperationNames() {
+        // @formatter:off
+        assertEquals("[add, divide, multiply, subtract]",
+                        actor.getOperationNames().stream()
+                            .sorted()
+                            .collect(Collectors.toList())
+                            .toString());
+        // @formatter:on
+    }
+
+    @Test
+    public void testDoConfigure() {
+        actor.configure(params);
+        assertTrue(actor.isConfigured());
+
+        verify(oper1).configure(sub1);
+        verify(oper2).configure(sub2);
+        verify(oper3).configure(sub3);
+        verify(oper4).configure(sub4);
+
+        // no other types of operations
+        verify(oper1, never()).start();
+        verify(oper1, never()).stop();
+        verify(oper1, never()).shutdown();
+    }
+
+    /**
+     * Tests doConfigure() where operators throw parameter validation and runtime
+     * exceptions.
+     */
+    @Test
+    public void testDoConfigureExceptions() {
+        makeValidException(oper1);
+        makeRuntimeException(oper2);
+        makeValidException(oper3);
+
+        actor.configure(params);
+        assertTrue(actor.isConfigured());
+    }
+
+    /**
+     * Tests doConfigure(). Arranges for the following:
+     * <ul>
+     * <li>one operator is configured, but has parameters</li>
+     * <li>another operator is configured, but has no parameters</li>
+     * <li>another operator has no parameters and is not configured</li>
+     * </ul>
+     */
+    @Test
+    public void testDoConfigureConfigure() {
+        // need mutable parameters
+        params = new TreeMap<>(params);
+
+        // configure one operator
+        oper1.configure(sub1);
+
+        // configure another and remove its parameters
+        oper2.configure(sub2);
+        params.remove(OPER2);
+
+        // create a new, unconfigured actor
+        Operator oper5 = spy(new MyOper("UNCONFIGURED"));
+        actor = makeActor(oper1, oper2, oper3, oper4, oper5);
+
+        /*
+         * Configure it.
+         */
+        actor.configure(params);
+        assertTrue(actor.isConfigured());
+
+        // this should have been configured again
+        verify(oper1, times(2)).configure(sub1);
+
+        // no parameters, so this should not have been configured again
+        verify(oper2).configure(sub2);
+
+        // these were only configured once
+        verify(oper3).configure(sub3);
+        verify(oper4).configure(sub4);
+
+        // never configured
+        verify(oper5, never()).configure(any());
+        assertFalse(oper5.isConfigured());
+
+        // start and verify that all are started except for the last
+        actor.start();
+        verify(oper1).start();
+        verify(oper2).start();
+        verify(oper3).start();
+        verify(oper4).start();
+        verify(oper5, never()).start();
+    }
+
+    /**
+     * Arranges for an operator to throw a validation exception when
+     * {@link Operator#configure(Map)} is invoked.
+     *
+     * @param oper operator of interest
+     */
+    private void makeValidException(Operator oper) {
+        ParameterValidationRuntimeException ex = new ParameterValidationRuntimeException(
+                        new ObjectValidationResult(actor.getName(), null, ValidationStatus.INVALID, "null"));
+        doThrow(ex).when(oper).configure(any());
+    }
+
+    /**
+     * Arranges for an operator to throw a runtime exception when
+     * {@link Operator#configure(Map)} is invoked.
+     *
+     * @param oper operator of interest
+     */
+    private void makeRuntimeException(Operator oper) {
+        IllegalStateException ex = new IllegalStateException(EXPECTED_EXCEPTION);
+        doThrow(ex).when(oper).configure(any());
+    }
+
+    @Test
+    public void testMakeOperatorParameters() {
+        actor.configure(params);
+
+        // each operator should have received its own parameters
+        verify(oper1).configure(sub1);
+        verify(oper2).configure(sub2);
+        verify(oper3).configure(sub3);
+        verify(oper4).configure(sub4);
+    }
+
+    /**
+     * Makes an actor with the given operators.
+     *
+     * @param operators associated operators
+     * @return a new actor
+     */
+    private ActorImpl makeActor(Operator... operators) {
+        return new ActorImpl(ACTOR_NAME, operators);
+    }
+
+    private static class MyOper extends OperatorPartial implements Operator {
+
+        public MyOper(String name) {
+            super(ACTOR_NAME, name);
+        }
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperatorPartialTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperatorPartialTest.java
new file mode 100644
index 000000000..864ac829a
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperatorPartialTest.java
@@ -0,0 +1,978 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.impl;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.spy;
+import static org.mockito.Mockito.verify;
+
+import java.time.Instant;
+import java.util.Arrays;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Queue;
+import java.util.TreeMap;
+import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionException;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import lombok.Getter;
+import lombok.Setter;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.controlloop.ControlLoopOperation;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+import org.onap.policy.controlloop.actorserviceprovider.controlloop.ControlLoopEventContext;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ControlLoopOperationParams;
+import org.onap.policy.controlloop.policy.Policy;
+import org.onap.policy.controlloop.policy.PolicyResult;
+
+public class OperatorPartialTest {
+    private static final int MAX_PARALLEL_REQUESTS = 10;
+    private static final String EXPECTED_EXCEPTION = "expected exception";
+    private static final String ACTOR = "my-actor";
+    private static final String OPERATOR = "my-operator";
+    private static final String TARGET = "my-target";
+    private static final int TIMEOUT = 1000;
+    private static final UUID REQ_ID = UUID.randomUUID();
+
+    private static final List<PolicyResult> FAILURE_RESULTS = Arrays.asList(PolicyResult.values()).stream()
+                    .filter(result -> result != PolicyResult.SUCCESS).collect(Collectors.toList());
+
+    private static final List<String> FAILURE_STRINGS =
+                    FAILURE_RESULTS.stream().map(Object::toString).collect(Collectors.toList());
+
+    private VirtualControlLoopEvent event;
+    private Map<String, Object> config;
+    private ControlLoopEventContext context;
+    private MyExec executor;
+    private Policy policy;
+    private ControlLoopOperationParams params;
+
+    private MyOper oper;
+
+    private int numStart;
+    private int numEnd;
+
+    private Instant tstart;
+
+    private ControlLoopOperation opstart;
+    private ControlLoopOperation opend;
+
+    /**
+     * Initializes the fields, including {@link #oper}.
+     */
+    @Before
+    public void setUp() {
+        event = new VirtualControlLoopEvent();
+        event.setRequestId(REQ_ID);
+
+        config = new TreeMap<>();
+        context = new ControlLoopEventContext(event);
+        executor = new MyExec();
+
+        policy = new Policy();
+        policy.setActor(ACTOR);
+        policy.setRecipe(OPERATOR);
+        policy.setTimeout(TIMEOUT);
+
+        params = ControlLoopOperationParams.builder().completeCallback(this::completer).context(context)
+                        .executor(executor).policy(policy).startCallback(this::starter).target(TARGET).build();
+
+        oper = new MyOper();
+        oper.configure(new TreeMap<>());
+        oper.start();
+
+        tstart = null;
+
+        opstart = null;
+        opend = null;
+    }
+
+    @Test
+    public void testOperatorPartial_testGetActorName_testGetName() {
+        assertEquals(ACTOR, oper.getActorName());
+        assertEquals(OPERATOR, oper.getName());
+        assertEquals(ACTOR + "." + OPERATOR, oper.getFullName());
+    }
+
+    @Test
+    public void testDoStart() {
+        oper = spy(new MyOper());
+
+        oper.configure(config);
+        oper.start();
+
+        verify(oper).doStart();
+
+        // others should not have been invoked
+        verify(oper, never()).doStop();
+        verify(oper, never()).doShutdown();
+    }
+
+    @Test
+    public void testDoStop() {
+        oper = spy(new MyOper());
+
+        oper.configure(config);
+        oper.start();
+        oper.stop();
+
+        verify(oper).doStop();
+
+        // should not have been re-invoked
+        verify(oper).doStart();
+
+        // others should not have been invoked
+        verify(oper, never()).doShutdown();
+    }
+
+    @Test
+    public void testDoShutdown() {
+        oper = spy(new MyOper());
+
+        oper.configure(config);
+        oper.start();
+        oper.shutdown();
+
+        verify(oper).doShutdown();
+
+        // should not have been re-invoked
+        verify(oper).doStart();
+
+        // others should not have been invoked
+        verify(oper, never()).doStop();
+    }
+
+    @Test
+    public void testStartOperation_testVerifyRunning() {
+        verifyRun("testStartOperation", 1, 1, PolicyResult.SUCCESS);
+    }
+
+    /**
+     * Tests startOperation() when the operator is not running.
+     */
+    @Test
+    public void testStartOperationNotRunning() {
+        // use a new operator, one that hasn't been started yet
+        oper = new MyOper();
+        oper.configure(new TreeMap<>());
+
+        assertThatIllegalStateException().isThrownBy(() -> oper.startOperation(params));
+    }
+
+    /**
+     * Tests startOperation() when the operation has a preprocessor.
+     */
+    @Test
+    public void testStartOperationWithPreprocessor_testStartPreprocessor() {
+        AtomicInteger count = new AtomicInteger();
+
+        // @formatter:off
+        Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> preproc =
+            oper -> CompletableFuture.supplyAsync(() -> {
+                count.incrementAndGet();
+                oper.setOutcome(PolicyResult.SUCCESS.toString());
+                return oper;
+            }, executor);
+        // @formatter:on
+
+        oper.setPreProcessor(preproc);
+
+        verifyRun("testStartOperationWithPreprocessor_testStartPreprocessor", 1, 1, PolicyResult.SUCCESS);
+
+        assertEquals(1, count.get());
+    }
+
+    /**
+     * Tests startOperation() with multiple running requests.
+     */
+    @Test
+    public void testStartOperationMultiple() {
+        for (int count = 0; count < MAX_PARALLEL_REQUESTS; ++count) {
+            oper.startOperation(params);
+        }
+
+        assertTrue(executor.runAll());
+
+        assertNotNull(opstart);
+        assertNotNull(opend);
+        assertEquals(PolicyResult.SUCCESS.toString(), opend.getOutcome());
+
+        assertEquals(MAX_PARALLEL_REQUESTS, numStart);
+        assertEquals(MAX_PARALLEL_REQUESTS, oper.getCount());
+        assertEquals(MAX_PARALLEL_REQUESTS, numEnd);
+    }
+
+    /**
+     * Tests startPreprocessor() when the preprocessor returns a failure.
+     */
+    @Test
+    public void testStartPreprocessorFailure() {
+        // arrange for the preprocessor to return a failure
+        oper.setPreProcessor(oper -> {
+            oper.setOutcome(PolicyResult.FAILURE_GUARD.toString());
+            return CompletableFuture.completedFuture(oper);
+        });
+
+        verifyRun("testStartPreprocessorFailure", 1, 0, PolicyResult.FAILURE_GUARD);
+    }
+
+    /**
+     * Tests startPreprocessor() when the preprocessor throws an exception.
+     */
+    @Test
+    public void testStartPreprocessorException() {
+        // arrange for the preprocessor to throw an exception
+        oper.setPreProcessor(oper -> {
+            throw new IllegalStateException(EXPECTED_EXCEPTION);
+        });
+
+        verifyRun("testStartPreprocessorException", 1, 0, PolicyResult.FAILURE_GUARD);
+    }
+
+    /**
+     * Tests startPreprocessor() when the pipeline is not running.
+     */
+    @Test
+    public void testStartPreprocessorNotRunning() {
+        // arrange for the preprocessor to return success, which will be ignored
+        oper.setPreProcessor(oper -> {
+            oper.setOutcome(PolicyResult.SUCCESS.toString());
+            return CompletableFuture.completedFuture(oper);
+        });
+
+        oper.startOperation(params).cancel(false);
+        assertTrue(executor.runAll());
+
+        assertNull(opstart);
+        assertNull(opend);
+
+        assertEquals(0, numStart);
+        assertEquals(0, oper.getCount());
+        assertEquals(0, numEnd);
+    }
+
+    /**
+     * Tests startPreprocessor() when the preprocessor <b>builder</b> throws an exception.
+     */
+    @Test
+    public void testStartPreprocessorBuilderException() {
+        oper = new MyOper() {
+            @Override
+            protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doPreprocessorAsFuture(
+                            ControlLoopOperationParams params) {
+                throw new IllegalStateException(EXPECTED_EXCEPTION);
+            }
+        };
+
+        oper.configure(new TreeMap<>());
+        oper.start();
+
+        assertThatIllegalStateException().isThrownBy(() -> oper.startOperation(params));
+
+        // should be nothing in the queue
+        assertEquals(0, executor.getQueueLength());
+    }
+
+    @Test
+    public void testDoPreprocessorAsFuture() {
+        assertNull(oper.doPreprocessorAsFuture(params));
+    }
+
+    @Test
+    public void testStartOperationOnly_testDoOperationAsFuture() {
+        oper.startOperation(params);
+        assertTrue(executor.runAll());
+
+        assertEquals(1, oper.getCount());
+    }
+
+    /**
+     * Tests startOperationOnce() when
+     * {@link OperatorPartial#doOperationAsFuture(ControlLoopOperationParams)} throws an
+     * exception.
+     */
+    @Test
+    public void testStartOperationOnceBuilderException() {
+        oper = new MyOper() {
+            @Override
+            protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doOperationAsFuture(
+                            ControlLoopOperationParams params, int attempt) {
+                throw new IllegalStateException(EXPECTED_EXCEPTION);
+            }
+        };
+
+        oper.configure(new TreeMap<>());
+        oper.start();
+
+        assertThatIllegalStateException().isThrownBy(() -> oper.startOperation(params));
+
+        // should be nothing in the queue
+        assertEquals(0, executor.getQueueLength());
+    }
+
+    @Test
+    public void testIsSuccess() {
+        ControlLoopOperation outcome = new ControlLoopOperation();
+
+        outcome.setOutcome(PolicyResult.SUCCESS.toString());
+        assertTrue(oper.isSuccess(outcome));
+
+        for (String failure : FAILURE_STRINGS) {
+            outcome.setOutcome(failure);
+            assertFalse("testIsSuccess-" + failure, oper.isSuccess(outcome));
+        }
+    }
+
+    @Test
+    public void testIsActorFailed() {
+        assertFalse(oper.isActorFailed(null));
+
+        ControlLoopOperation outcome = params.makeOutcome();
+
+        // incorrect outcome
+        outcome.setOutcome(PolicyResult.SUCCESS.toString());
+        assertFalse(oper.isActorFailed(outcome));
+
+        outcome.setOutcome(PolicyResult.FAILURE_RETRIES.toString());
+        assertFalse(oper.isActorFailed(outcome));
+
+        // correct outcome
+        outcome.setOutcome(PolicyResult.FAILURE.toString());
+
+        // incorrect actor
+        outcome.setActor(TARGET);
+        assertFalse(oper.isActorFailed(outcome));
+        outcome.setActor(null);
+        assertFalse(oper.isActorFailed(outcome));
+        outcome.setActor(ACTOR);
+
+        // incorrect operation
+        outcome.setOperation(TARGET);
+        assertFalse(oper.isActorFailed(outcome));
+        outcome.setOperation(null);
+        assertFalse(oper.isActorFailed(outcome));
+        outcome.setOperation(OPERATOR);
+
+        // correct values
+        assertTrue(oper.isActorFailed(outcome));
+    }
+
+    @Test
+    public void testDoOperation() {
+        /*
+         * Use an operator that doesn't override doOperation().
+         */
+        OperatorPartial oper2 = new OperatorPartial(ACTOR, OPERATOR) {};
+
+        oper2.configure(new TreeMap<>());
+        oper2.start();
+
+        oper2.startOperation(params);
+        assertTrue(executor.runAll());
+
+        assertNotNull(opend);
+        assertEquals(PolicyResult.FAILURE_EXCEPTION.toString(), opend.getOutcome());
+    }
+
+    @Test
+    public void testTimeout() throws Exception {
+
+        // use a real executor
+        params = params.toBuilder().executor(ForkJoinPool.commonPool()).build();
+
+        // trigger timeout very quickly
+        oper = new MyOper() {
+            @Override
+            protected long getTimeOutMillis(Policy policy) {
+                return 1;
+            }
+
+            @Override
+            protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doOperationAsFuture(
+                            ControlLoopOperationParams params, int attempt) {
+
+                return outcome -> {
+                    ControlLoopOperation outcome2 = params.makeOutcome();
+                    outcome2.setOutcome(PolicyResult.SUCCESS.toString());
+
+                    /*
+                     * Create an incomplete future that will timeout after the operation's
+                     * timeout. If it fires before the other timer, then it will return a
+                     * SUCCESS outcome.
+                     */
+                    CompletableFuture<ControlLoopOperation> future = new CompletableFuture<>();
+                    future = future.orTimeout(1, TimeUnit.SECONDS).handleAsync((unused1, unused2) -> outcome,
+                                    params.getExecutor());
+
+                    return future;
+                };
+            }
+        };
+
+        oper.configure(new TreeMap<>());
+        oper.start();
+
+        assertEquals(PolicyResult.FAILURE_TIMEOUT.toString(), oper.startOperation(params).get().getOutcome());
+    }
+
+    /**
+     * Verifies that the timer doesn't encompass the preprocessor and doesn't stop the
+     * operation once the preprocessor completes.
+     */
+    @Test
+    public void testTimeoutInPreprocessor() throws Exception {
+
+        // use a real executor
+        params = params.toBuilder().executor(ForkJoinPool.commonPool()).build();
+
+        // trigger timeout very quickly
+        oper = new MyOper() {
+            @Override
+            protected long getTimeOutMillis(Policy policy) {
+                return 10;
+            }
+
+            @Override
+            protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doPreprocessorAsFuture(
+                            ControlLoopOperationParams params) {
+
+                return outcome -> {
+                    outcome.setOutcome(PolicyResult.SUCCESS.toString());
+
+                    /*
+                     * Create an incomplete future that will timeout after the operation's
+                     * timeout. If it fires before the other timer, then it will return a
+                     * SUCCESS outcome.
+                     */
+                    CompletableFuture<ControlLoopOperation> future = new CompletableFuture<>();
+                    future = future.orTimeout(200, TimeUnit.MILLISECONDS).handleAsync((unused1, unused2) -> outcome,
+                                    params.getExecutor());
+
+                    return future;
+                };
+            }
+        };
+
+        oper.configure(new TreeMap<>());
+        oper.start();
+
+        ControlLoopOperation result = oper.startOperation(params).get();
+        assertEquals(PolicyResult.SUCCESS.toString(), result.getOutcome());
+
+        assertNotNull(opstart);
+        assertNotNull(opend);
+        assertEquals(PolicyResult.SUCCESS.toString(), opend.getOutcome());
+
+        assertEquals(1, numStart);
+        assertEquals(1, oper.getCount());
+        assertEquals(1, numEnd);
+    }
+
+    /**
+     * Tests retry functions, when the count is set to zero and retries are exhausted.
+     */
+    @Test
+    public void testSetRetryFlag_testRetryOnFailure_ZeroRetries() {
+        policy.setRetry(0);
+        oper.setMaxFailures(10);
+
+        verifyRun("testSetRetryFlag_testRetryOnFailure_ZeroRetries", 1, 1, PolicyResult.FAILURE);
+    }
+
+    /**
+     * Tests retry functions, when the count is null and retries are exhausted.
+     */
+    @Test
+    public void testSetRetryFlag_testRetryOnFailure_NullRetries() {
+        policy.setRetry(null);
+        oper.setMaxFailures(10);
+
+        verifyRun("testSetRetryFlag_testRetryOnFailure_NullRetries", 1, 1, PolicyResult.FAILURE);
+    }
+
+    /**
+     * Tests retry functions, when retries are exhausted.
+     */
+    @Test
+    public void testSetRetryFlag_testRetryOnFailure_RetriesExhausted() {
+        final int maxRetries = 3;
+        policy.setRetry(maxRetries);
+        oper.setMaxFailures(10);
+
+        verifyRun("testVerifyRunningWhenNot", maxRetries + 1, maxRetries + 1, PolicyResult.FAILURE_RETRIES);
+    }
+
+    /**
+     * Tests retry functions, when a success follows some retries.
+     */
+    @Test
+    public void testSetRetryFlag_testRetryOnFailure_SuccessAfterRetries() {
+        policy.setRetry(10);
+
+        final int maxFailures = 3;
+        oper.setMaxFailures(maxFailures);
+
+        verifyRun("testSetRetryFlag_testRetryOnFailure_SuccessAfterRetries", maxFailures + 1, maxFailures + 1,
+                        PolicyResult.SUCCESS);
+    }
+
+    /**
+     * Tests retry functions, when the outcome is {@code null}.
+     */
+    @Test
+    public void testSetRetryFlag_testRetryOnFailure_NullOutcome() {
+
+        // arrange to return null from doOperation()
+        oper = new MyOper() {
+            @Override
+            protected ControlLoopOperation doOperation(ControlLoopOperationParams params, int attempt,
+                            ControlLoopOperation operation) {
+
+                // update counters
+                super.doOperation(params, attempt, operation);
+                return null;
+            }
+        };
+
+        oper.configure(new TreeMap<>());
+        oper.start();
+
+        verifyRun("testSetRetryFlag_testRetryOnFailure_NullOutcome", 1, 1, PolicyResult.FAILURE, null, noop());
+    }
+
+    @Test
+    public void testGetActorOutcome() {
+        assertNull(oper.getActorOutcome(null));
+
+        ControlLoopOperation outcome = params.makeOutcome();
+        outcome.setOutcome(TARGET);
+
+        // wrong actor - should be null
+        outcome.setActor(null);
+        assertNull(oper.getActorOutcome(outcome));
+        outcome.setActor(TARGET);
+        assertNull(oper.getActorOutcome(outcome));
+        outcome.setActor(ACTOR);
+
+        // wrong operation - should be null
+        outcome.setOperation(null);
+        assertNull(oper.getActorOutcome(outcome));
+        outcome.setOperation(TARGET);
+        assertNull(oper.getActorOutcome(outcome));
+        outcome.setOperation(OPERATOR);
+
+        assertEquals(TARGET, oper.getActorOutcome(outcome));
+    }
+
+    @Test
+    public void testOnSuccess() throws Exception {
+        AtomicInteger count = new AtomicInteger();
+
+        final Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> nextStep = oper -> {
+            count.incrementAndGet();
+            return CompletableFuture.completedFuture(oper);
+        };
+
+        // pass it a null outcome
+        ControlLoopOperation outcome = oper.onSuccess(params, nextStep).apply(null).get();
+        assertNotNull(outcome);
+        assertEquals(PolicyResult.FAILURE.toString(), outcome.getOutcome());
+        assertEquals(0, count.get());
+
+        // pass it an unpopulated (i.e., failed) outcome
+        outcome = new ControlLoopOperation();
+        assertSame(outcome, oper.onSuccess(params, nextStep).apply(outcome).get());
+        assertEquals(0, count.get());
+
+        // pass it a successful outcome
+        outcome = params.makeOutcome();
+        outcome.setOutcome(PolicyResult.SUCCESS.toString());
+        assertSame(outcome, oper.onSuccess(params, nextStep).apply(outcome).get());
+        assertEquals(PolicyResult.SUCCESS.toString(), outcome.getOutcome());
+        assertEquals(1, count.get());
+    }
+
+    /**
+     * Tests onSuccess() and handleFailure() when the outcome is a success.
+     */
+    @Test
+    public void testOnSuccessTrue_testHandleFailureTrue() {
+        // arrange to return a success from the preprocessor
+        oper.setPreProcessor(oper -> {
+            oper.setOutcome(PolicyResult.SUCCESS.toString());
+            return CompletableFuture.completedFuture(oper);
+        });
+
+        verifyRun("testOnSuccessTrue_testHandleFailureTrue", 1, 1, PolicyResult.SUCCESS);
+    }
+
+    /**
+     * Tests onSuccess() and handleFailure() when the outcome is <i>not</i> a success.
+     */
+    @Test
+    public void testOnSuccessFalse_testHandleFailureFalse() throws Exception {
+        // arrange to return a failure from the preprocessor
+        oper.setPreProcessor(oper -> {
+            oper.setOutcome(PolicyResult.FAILURE.toString());
+            return CompletableFuture.completedFuture(oper);
+        });
+
+        verifyRun("testOnSuccessFalse_testHandleFailureFalse", 1, 0, PolicyResult.FAILURE_GUARD);
+    }
+
+    /**
+     * Tests onSuccess() and handleFailure() when the outcome is {@code null}.
+     */
+    @Test
+    public void testOnSuccessFalse_testHandleFailureNull() throws Exception {
+        // arrange to return null from the preprocessor
+        oper.setPreProcessor(oper -> {
+            return CompletableFuture.completedFuture(null);
+        });
+
+        verifyRun("testOnSuccessFalse_testHandleFailureNull", 1, 0, PolicyResult.FAILURE_GUARD);
+    }
+
+    @Test
+    public void testFromException() {
+        // arrange to generate an exception when operation runs
+        oper.setGenException(true);
+
+        verifyRun("testFromException", 1, 1, PolicyResult.FAILURE_EXCEPTION);
+    }
+
+    /**
+     * Tests fromException() when there is no exception.
+     */
+    @Test
+    public void testFromExceptionNoExcept() {
+        verifyRun("testFromExceptionNoExcept", 1, 1, PolicyResult.SUCCESS);
+    }
+
+    /**
+     * Tests verifyRunning() when the pipeline is not running.
+     */
+    @Test
+    public void testVerifyRunningWhenNot() {
+        verifyRun("testVerifyRunningWhenNot", 0, 0, PolicyResult.SUCCESS, future -> future.cancel(false));
+    }
+
+    /**
+     * Tests callbackStarted() when the pipeline has already been stopped.
+     */
+    @Test
+    public void testCallbackStartedNotRunning() {
+        AtomicReference<Future<ControlLoopOperation>> future = new AtomicReference<>();
+
+        /*
+         * arrange to stop the controller when the start-callback is invoked, but capture
+         * the outcome
+         */
+        params = params.toBuilder().startCallback(oper -> {
+            starter(oper);
+            future.get().cancel(false);
+        }).build();
+
+        future.set(oper.startOperation(params));
+        assertTrue(executor.runAll());
+
+        // should have only run once
+        assertEquals(1, numStart);
+    }
+
+    /**
+     * Tests callbackCompleted() when the pipeline has already been stopped.
+     */
+    @Test
+    public void testCallbackCompletedNotRunning() {
+        AtomicReference<Future<ControlLoopOperation>> future = new AtomicReference<>();
+
+        // arrange to stop the controller when the start-callback is invoked
+        params = params.toBuilder().startCallback(oper -> {
+            future.get().cancel(false);
+        }).build();
+
+        future.set(oper.startOperation(params));
+        assertTrue(executor.runAll());
+
+        // should not have been set
+        assertNull(opend);
+        assertEquals(0, numEnd);
+    }
+
+    @Test
+    public void testSetOutcomeControlLoopOperationThrowable() {
+        final CompletionException timex = new CompletionException(new TimeoutException(EXPECTED_EXCEPTION));
+
+        ControlLoopOperation outcome;
+
+        outcome = new ControlLoopOperation();
+        oper.setOutcome(params, outcome, timex);
+        assertEquals(ControlLoopOperation.FAILED_MSG, outcome.getMessage());
+        assertEquals(PolicyResult.FAILURE_TIMEOUT.toString(), outcome.getOutcome());
+
+        outcome = new ControlLoopOperation();
+        oper.setOutcome(params, outcome, new IllegalStateException());
+        assertEquals(ControlLoopOperation.FAILED_MSG, outcome.getMessage());
+        assertEquals(PolicyResult.FAILURE_EXCEPTION.toString(), outcome.getOutcome());
+    }
+
+    @Test
+    public void testSetOutcomeControlLoopOperationPolicyResult() {
+        ControlLoopOperation outcome;
+
+        outcome = new ControlLoopOperation();
+        oper.setOutcome(params, outcome, PolicyResult.SUCCESS);
+        assertEquals(ControlLoopOperation.SUCCESS_MSG, outcome.getMessage());
+        assertEquals(PolicyResult.SUCCESS.toString(), outcome.getOutcome());
+
+        for (PolicyResult result : FAILURE_RESULTS) {
+            outcome = new ControlLoopOperation();
+            oper.setOutcome(params, outcome, result);
+            assertEquals(result.toString(), ControlLoopOperation.FAILED_MSG, outcome.getMessage());
+            assertEquals(result.toString(), result.toString(), outcome.getOutcome());
+        }
+    }
+
+    @Test
+    public void testIsTimeout() {
+        final TimeoutException timex = new TimeoutException(EXPECTED_EXCEPTION);
+
+        assertFalse(oper.isTimeout(new IllegalStateException()));
+        assertFalse(oper.isTimeout(new IllegalStateException(timex)));
+        assertFalse(oper.isTimeout(new CompletionException(new IllegalStateException(timex))));
+        assertFalse(oper.isTimeout(new CompletionException(null)));
+        assertFalse(oper.isTimeout(new CompletionException(new CompletionException(timex))));
+
+        assertTrue(oper.isTimeout(timex));
+        assertTrue(oper.isTimeout(new CompletionException(timex)));
+    }
+
+    @Test
+    public void testGetTimeOutMillis() {
+        assertEquals(TIMEOUT * 1000, oper.getTimeOutMillis(policy));
+
+        policy.setTimeout(null);
+        assertEquals(0, oper.getTimeOutMillis(policy));
+    }
+
+    private void starter(ControlLoopOperation oper) {
+        ++numStart;
+        tstart = oper.getStart();
+        opstart = oper;
+    }
+
+    private void completer(ControlLoopOperation oper) {
+        ++numEnd;
+        opend = oper;
+    }
+
+    /**
+     * Gets a function that does nothing.
+     *
+     * @param <T> type of input parameter expected by the function
+     * @return a function that does nothing
+     */
+    private <T> Consumer<T> noop() {
+        return unused -> {
+        };
+    }
+
+    /**
+     * Verifies a run.
+     *
+     * @param testName test name
+     * @param expectedCallbacks number of callbacks expected
+     * @param expectedOperations number of operation invocations expected
+     * @param expectedResult expected outcome
+     */
+    private void verifyRun(String testName, int expectedCallbacks, int expectedOperations,
+                    PolicyResult expectedResult) {
+
+        String expectedSubRequestId =
+                        (expectedResult == PolicyResult.FAILURE_EXCEPTION ? null : String.valueOf(expectedOperations));
+
+        verifyRun(testName, expectedCallbacks, expectedOperations, expectedResult, expectedSubRequestId, noop());
+    }
+
+    /**
+     * Verifies a run.
+     *
+     * @param testName test name
+     * @param expectedCallbacks number of callbacks expected
+     * @param expectedOperations number of operation invocations expected
+     * @param expectedResult expected outcome
+     * @param manipulator function to modify the future returned by
+     *        {@link OperatorPartial#startOperation(ControlLoopOperationParams)} before
+     *        the tasks in the executor are run
+     */
+    private void verifyRun(String testName, int expectedCallbacks, int expectedOperations, PolicyResult expectedResult,
+                    Consumer<CompletableFuture<ControlLoopOperation>> manipulator) {
+
+        String expectedSubRequestId =
+                        (expectedResult == PolicyResult.FAILURE_EXCEPTION ? null : String.valueOf(expectedOperations));
+
+        verifyRun(testName, expectedCallbacks, expectedOperations, expectedResult, expectedSubRequestId, manipulator);
+    }
+
+    /**
+     * Verifies a run.
+     *
+     * @param testName test name
+     * @param expectedCallbacks number of callbacks expected
+     * @param expectedOperations number of operation invocations expected
+     * @param expectedResult expected outcome
+     * @param expectedSubRequestId expected sub request ID
+     * @param manipulator function to modify the future returned by
+     *        {@link OperatorPartial#startOperation(ControlLoopOperationParams)} before
+     *        the tasks in the executor are run
+     */
+    private void verifyRun(String testName, int expectedCallbacks, int expectedOperations, PolicyResult expectedResult,
+                    String expectedSubRequestId, Consumer<CompletableFuture<ControlLoopOperation>> manipulator) {
+
+        CompletableFuture<ControlLoopOperation> future = oper.startOperation(params);
+
+        manipulator.accept(future);
+
+        assertTrue(testName, executor.runAll());
+
+        assertEquals(testName, expectedCallbacks, numStart);
+        assertEquals(testName, expectedCallbacks, numEnd);
+
+        if (expectedCallbacks > 0) {
+            assertNotNull(testName, opstart);
+            assertNotNull(testName, opend);
+            assertEquals(testName, expectedResult.toString(), opend.getOutcome());
+
+            assertSame(testName, tstart, opstart.getStart());
+            assertSame(testName, tstart, opend.getStart());
+
+            try {
+                assertTrue(future.isDone());
+                assertSame(testName, opend, future.get());
+
+            } catch (InterruptedException | ExecutionException e) {
+                throw new IllegalStateException(e);
+            }
+
+            if (expectedOperations > 0) {
+                assertEquals(testName, expectedSubRequestId, opend.getSubRequestId());
+            }
+        }
+
+        assertEquals(testName, expectedOperations, oper.getCount());
+    }
+
+    private static class MyOper extends OperatorPartial {
+        @Getter
+        private int count = 0;
+
+        @Setter
+        private boolean genException;
+
+        @Setter
+        private int maxFailures = 0;
+
+        @Setter
+        private Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> preProcessor;
+
+        public MyOper() {
+            super(ACTOR, OPERATOR);
+        }
+
+        @Override
+        protected ControlLoopOperation doOperation(ControlLoopOperationParams params, int attempt,
+                        ControlLoopOperation operation) {
+            ++count;
+            if (genException) {
+                throw new IllegalStateException(EXPECTED_EXCEPTION);
+            }
+
+            operation.setSubRequestId(String.valueOf(attempt));
+
+            if (count > maxFailures) {
+                operation.setOutcome(PolicyResult.SUCCESS.toString());
+            } else {
+                operation.setOutcome(PolicyResult.FAILURE.toString());
+            }
+
+            return operation;
+        }
+
+        @Override
+        protected Function<ControlLoopOperation, CompletableFuture<ControlLoopOperation>> doPreprocessorAsFuture(
+                        ControlLoopOperationParams params) {
+
+            return (preProcessor != null ? preProcessor : super.doPreprocessorAsFuture(params));
+        }
+    }
+
+    /**
+     * Executor that will run tasks until the queue is empty or a maximum number of tasks
+     * have been executed.
+     */
+    private static class MyExec implements Executor {
+        private static final int MAX_TASKS = MAX_PARALLEL_REQUESTS * 100;
+
+        private Queue<Runnable> commands = new LinkedList<>();
+
+        public MyExec() {
+            // do nothing
+        }
+
+        public int getQueueLength() {
+            return commands.size();
+        }
+
+        @Override
+        public void execute(Runnable command) {
+            commands.add(command);
+        }
+
+        public boolean runAll() {
+            for (int count = 0; count < MAX_TASKS && !commands.isEmpty(); ++count) {
+                commands.remove().run();
+            }
+
+            return commands.isEmpty();
+        }
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/StartConfigPartialTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/StartConfigPartialTest.java
new file mode 100644
index 000000000..7a822c1d9
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/StartConfigPartialTest.java
@@ -0,0 +1,212 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.impl;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.spy;
+import static org.mockito.Mockito.verify;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class StartConfigPartialTest {
+    private static final IllegalArgumentException EXPECTED_EXCEPTION =
+                    new IllegalArgumentException("expected exception");
+    private static final String MY_NAME = "my-name";
+    private static final String PARAMS = "config data";
+    private static final String PARAMS2 = "config data #2";
+    private static final String PARAMSX = "config data exception";
+
+    private StartConfigPartial<String> config;
+
+    /**
+     * Creates a config whose doXxx() methods do nothing.
+     */
+    @Before
+    public void setUp() {
+        config = new StartConfigPartial<>(MY_NAME) {
+            @Override
+            protected void doConfigure(String parameters) {
+                // do nothing
+            }
+
+            @Override
+            protected void doStart() {
+                // do nothing
+            }
+
+            @Override
+            protected void doStop() {
+                // do nothing
+            }
+
+            @Override
+            protected void doShutdown() {
+                // do nothing
+            }
+        };
+
+        config = spy(config);
+    }
+
+    @Test
+    public void testConfigImpl_testGetFullName() {
+        assertEquals(MY_NAME, config.getFullName());
+    }
+
+    @Test
+    public void testIsAlive() {
+        assertFalse(config.isAlive());
+    }
+
+    @Test
+    public void testIsConfigured_testConfigure() {
+        // throw an exception during doConfigure(), but should remain unconfigured
+        assertFalse(config.isConfigured());
+        doThrow(EXPECTED_EXCEPTION).when(config).doConfigure(PARAMSX);
+        assertThatIllegalArgumentException().isThrownBy(() -> config.configure(PARAMSX)).isEqualTo(EXPECTED_EXCEPTION);
+        assertFalse(config.isConfigured());
+
+        assertFalse(config.isConfigured());
+        config.configure(PARAMS);
+        verify(config).doConfigure(PARAMS);
+        assertTrue(config.isConfigured());
+
+        // should not be able to re-configure while running
+        config.start();
+        assertThatIllegalStateException().isThrownBy(() -> config.configure(PARAMS2)).withMessageContaining(MY_NAME);
+        verify(config, never()).doConfigure(PARAMS2);
+
+        // should be able to re-configure after stopping
+        config.stop();
+        config.configure(PARAMS2);
+        verify(config).doConfigure(PARAMS2);
+        assertTrue(config.isConfigured());
+
+        // should remain configured after exception
+        doThrow(EXPECTED_EXCEPTION).when(config).doConfigure(PARAMSX);
+        assertThatIllegalArgumentException().isThrownBy(() -> config.configure(PARAMSX)).isEqualTo(EXPECTED_EXCEPTION);
+        assertTrue(config.isConfigured());
+    }
+
+    @Test
+    public void testStart() {
+        assertFalse(config.isAlive());
+
+        // can't start if not configured yet
+        assertThatIllegalStateException().isThrownBy(() -> config.start()).withMessageContaining(MY_NAME);
+        assertFalse(config.isAlive());
+
+        config.configure(PARAMS);
+
+        config.start();
+        verify(config).doStart();
+        assertTrue(config.isAlive());
+        assertTrue(config.isConfigured());
+
+        // ok to restart when running, but shouldn't invoke doStart() again
+        config.start();
+        verify(config).doStart();
+        assertTrue(config.isAlive());
+        assertTrue(config.isConfigured());
+
+        // should never have invoked these
+        verify(config, never()).doStop();
+        verify(config, never()).doShutdown();
+
+        // throw exception when started again, but should remain stopped
+        config.stop();
+        doThrow(EXPECTED_EXCEPTION).when(config).doStart();
+        assertThatIllegalArgumentException().isThrownBy(() -> config.start()).isEqualTo(EXPECTED_EXCEPTION);
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+    }
+
+    @Test
+    public void testStop() {
+        config.configure(PARAMS);
+
+        // ok to stop if not running, but shouldn't invoke doStop()
+        config.stop();
+        verify(config, never()).doStop();
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+
+        config.start();
+
+        // now stop should have an effect
+        config.stop();
+        verify(config).doStop();
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+
+        // should have only invoked this once
+        verify(config).doStart();
+
+        // should never have invoked these
+        verify(config, never()).doShutdown();
+
+        // throw exception when stopped again, but should go ahead and stop
+        config.start();
+        doThrow(EXPECTED_EXCEPTION).when(config).doStop();
+        assertThatIllegalArgumentException().isThrownBy(() -> config.stop()).isEqualTo(EXPECTED_EXCEPTION);
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+    }
+
+    @Test
+    public void testShutdown() {
+        config.configure(PARAMS);
+
+        // ok to shutdown if not running, but shouldn't invoke doShutdown()
+        config.shutdown();
+        verify(config, never()).doShutdown();
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+
+        config.start();
+
+        // now stop should have an effect
+        config.shutdown();
+        verify(config).doShutdown();
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+
+        // should have only invoked this once
+        verify(config).doStart();
+
+        // should never have invoked these
+        verify(config, never()).doStop();
+
+        // throw exception when shut down again, but should go ahead and shut down
+        config.start();
+        doThrow(EXPECTED_EXCEPTION).when(config).doShutdown();
+        assertThatIllegalArgumentException().isThrownBy(() -> config.shutdown()).isEqualTo(EXPECTED_EXCEPTION);
+        assertFalse(config.isAlive());
+        assertTrue(config.isConfigured());
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ControlLoopOperationParamsTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ControlLoopOperationParamsTest.java
new file mode 100644
index 000000000..0c8e77d38
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ControlLoopOperationParamsTest.java
@@ -0,0 +1,314 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doAnswer;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.onap.policy.common.parameters.BeanValidationResult;
+import org.onap.policy.controlloop.ControlLoopOperation;
+import org.onap.policy.controlloop.VirtualControlLoopEvent;
+import org.onap.policy.controlloop.actorserviceprovider.ActorService;
+import org.onap.policy.controlloop.actorserviceprovider.Operator;
+import org.onap.policy.controlloop.actorserviceprovider.controlloop.ControlLoopEventContext;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ControlLoopOperationParams.ControlLoopOperationParamsBuilder;
+import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
+import org.onap.policy.controlloop.policy.Policy;
+
+public class ControlLoopOperationParamsTest {
+    private static final String EXPECTED_EXCEPTION = "expected exception";
+    private static final String ACTOR = "my-actor";
+    private static final String OPERATION = "my-operation";
+    private static final String TARGET = "my-target";
+    private static final UUID REQ_ID = UUID.randomUUID();
+
+    @Mock
+    private Actor actor;
+
+    @Mock
+    private ActorService actorService;
+
+    @Mock
+    private Consumer<ControlLoopOperation> completer;
+
+    @Mock
+    private ControlLoopEventContext context;
+
+    @Mock
+    private VirtualControlLoopEvent event;
+
+    @Mock
+    private Executor executor;
+
+    @Mock
+    private CompletableFuture<ControlLoopOperation> operation;
+
+    @Mock
+    private Operator operator;
+
+    @Mock
+    private Policy policy;
+
+    @Mock
+    private Consumer<ControlLoopOperation> starter;
+
+    private ControlLoopOperationParams params;
+    private ControlLoopOperation outcome;
+
+
+    /**
+     * Initializes mocks and sets {@link #params} to a fully-loaded set of parameters.
+     */
+    @Before
+    public void setUp() {
+        MockitoAnnotations.initMocks(this);
+
+        when(actorService.getActor(ACTOR)).thenReturn(actor);
+        when(actor.getOperator(OPERATION)).thenReturn(operator);
+        when(operator.startOperation(any())).thenReturn(operation);
+
+        when(event.getRequestId()).thenReturn(REQ_ID);
+
+        when(context.getEvent()).thenReturn(event);
+
+        when(policy.getActor()).thenReturn(ACTOR);
+        when(policy.getRecipe()).thenReturn(OPERATION);
+
+        params = ControlLoopOperationParams.builder().actorService(actorService).completeCallback(completer)
+                        .context(context).executor(executor).policy(policy).startCallback(starter).target(TARGET)
+                        .build();
+
+        outcome = params.makeOutcome();
+    }
+
+    @Test
+    public void testStart() {
+        assertSame(operation, params.start());
+
+        assertThatIllegalArgumentException().isThrownBy(() -> params.toBuilder().context(null).build().start());
+    }
+
+    @Test
+    public void testGetActor() {
+        assertEquals(ACTOR, params.getActor());
+
+        // try with null policy
+        assertEquals(ControlLoopOperationParams.UNKNOWN, params.toBuilder().policy(null).build().getActor());
+
+        // try with null name in the policy
+        when(policy.getActor()).thenReturn(null);
+        assertEquals(ControlLoopOperationParams.UNKNOWN, params.getActor());
+    }
+
+    @Test
+    public void testGetOperation() {
+        assertEquals(OPERATION, params.getOperation());
+
+        // try with null policy
+        assertEquals(ControlLoopOperationParams.UNKNOWN, params.toBuilder().policy(null).build().getOperation());
+
+        // try with null name in the policy
+        when(policy.getRecipe()).thenReturn(null);
+        assertEquals(ControlLoopOperationParams.UNKNOWN, params.getOperation());
+    }
+
+    @Test
+    public void testGetRequestId() {
+        assertSame(REQ_ID, params.getRequestId());
+
+        // try with null context
+        assertNull(params.toBuilder().context(null).build().getRequestId());
+
+        // try with null event
+        when(context.getEvent()).thenReturn(null);
+        assertNull(params.getRequestId());
+    }
+
+    @Test
+    public void testMakeOutcome() {
+        assertEquals(ACTOR, outcome.getActor());
+        assertEquals(OPERATION, outcome.getOperation());
+        checkRemainingFields("with actor");
+
+        // try again with a null policy
+        outcome = params.toBuilder().policy(null).build().makeOutcome();
+        assertEquals(ControlLoopOperationParams.UNKNOWN, outcome.getActor());
+        assertEquals(ControlLoopOperationParams.UNKNOWN, outcome.getOperation());
+        checkRemainingFields("unknown actor");
+    }
+
+    protected void checkRemainingFields(String testName) {
+        assertEquals(testName, TARGET, outcome.getTarget());
+        assertNotNull(testName, outcome.getStart());
+        assertNull(testName, outcome.getEnd());
+        assertNull(testName, outcome.getSubRequestId());
+        assertNull(testName, outcome.getOutcome());
+        assertNull(testName, outcome.getMessage());
+    }
+
+    @Test
+    public void testCallbackStarted() {
+        params.callbackStarted(outcome);
+        verify(starter).accept(outcome);
+
+        // modify starter to throw an exception
+        AtomicInteger count = new AtomicInteger();
+        doAnswer(args -> {
+            count.incrementAndGet();
+            throw new IllegalStateException(EXPECTED_EXCEPTION);
+        }).when(starter).accept(outcome);
+
+        params.callbackStarted(outcome);
+        verify(starter, times(2)).accept(outcome);
+        assertEquals(1, count.get());
+
+        // repeat with no start-callback - no additional calls expected
+        params.toBuilder().startCallback(null).build().callbackStarted(outcome);
+        verify(starter, times(2)).accept(outcome);
+        assertEquals(1, count.get());
+
+        // should not call complete-callback
+        verify(completer, never()).accept(any());
+    }
+
+    @Test
+    public void testCallbackCompleted() {
+        params.callbackCompleted(outcome);
+        verify(completer).accept(outcome);
+
+        // modify completer to throw an exception
+        AtomicInteger count = new AtomicInteger();
+        doAnswer(args -> {
+            count.incrementAndGet();
+            throw new IllegalStateException(EXPECTED_EXCEPTION);
+        }).when(completer).accept(outcome);
+
+        params.callbackCompleted(outcome);
+        verify(completer, times(2)).accept(outcome);
+        assertEquals(1, count.get());
+
+        // repeat with no complete-callback - no additional calls expected
+        params.toBuilder().completeCallback(null).build().callbackCompleted(outcome);
+        verify(completer, times(2)).accept(outcome);
+        assertEquals(1, count.get());
+
+        // should not call start-callback
+        verify(starter, never()).accept(any());
+    }
+
+    @Test
+    public void testValidateFields() {
+        testValidate("actorService", "null", bldr -> bldr.actorService(null));
+        testValidate("context", "null", bldr -> bldr.context(null));
+        testValidate("executor", "null", bldr -> bldr.executor(null));
+        testValidate("policy", "null", bldr -> bldr.policy(null));
+        testValidate("target", "null", bldr -> bldr.target(null));
+
+        // check edge cases
+        assertTrue(params.toBuilder().build().validate().isValid());
+
+        // these can be null
+        assertTrue(params.toBuilder().startCallback(null).completeCallback(null).build().validate().isValid());
+
+        // test with minimal fields
+        assertTrue(ControlLoopOperationParams.builder().actorService(actorService).context(context).policy(policy)
+                        .target(TARGET).build().validate().isValid());
+    }
+
+    private void testValidate(String fieldName, String expected,
+                    Function<ControlLoopOperationParamsBuilder, ControlLoopOperationParamsBuilder> makeInvalid) {
+
+        // original params should be valid
+        BeanValidationResult result = params.validate();
+        assertTrue(fieldName, result.isValid());
+
+        // make invalid params
+        result = makeInvalid.apply(params.toBuilder()).build().validate();
+        assertFalse(fieldName, result.isValid());
+        assertThat(result.getResult()).contains(fieldName).contains(expected);
+    }
+
+    @Test
+    public void testBuilder_testToBuilder() {
+        assertEquals(params, params.toBuilder().build());
+    }
+
+    @Test
+    public void testActorService() {
+        assertSame(actorService, params.getActorService());
+    }
+
+    @Test
+    public void testGetContext() {
+        assertSame(context, params.getContext());
+    }
+
+    @Test
+    public void testGetExecutor() {
+        assertSame(executor, params.getExecutor());
+
+        // should use default when unspecified
+        assertSame(ForkJoinPool.commonPool(), ControlLoopOperationParams.builder().build().getExecutor());
+    }
+
+    @Test
+    public void testGetPolicy() {
+        assertSame(policy, params.getPolicy());
+    }
+
+    @Test
+    public void testGetStartCallback() {
+        assertSame(starter, params.getStartCallback());
+    }
+
+    @Test
+    public void testGetCompleteCallback() {
+        assertSame(completer, params.getCompleteCallback());
+    }
+
+    @Test
+    public void testGetTarget() {
+        assertEquals(TARGET, params.getTarget());
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpActorParamsTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpActorParamsTest.java
new file mode 100644
index 000000000..1763388f2
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpActorParamsTest.java
@@ -0,0 +1,130 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatCode;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ValidationResult;
+
+public class HttpActorParamsTest {
+
+    private static final String CONTAINER = "my-container";
+    private static final String CLIENT = "my-client";
+    private static final long TIMEOUT = 10;
+
+    private static final String PATH1 = "path #1";
+    private static final String PATH2 = "path #2";
+    private static final String URI1 = "uri #1";
+    private static final String URI2 = "uri #2";
+
+    private Map<String, String> paths;
+    private HttpActorParams params;
+
+    /**
+     * Initializes {@link #paths} with two items and {@link params} with a fully populated
+     * object.
+     */
+    @Before
+    public void setUp() {
+        paths = new TreeMap<>();
+        paths.put(PATH1, URI1);
+        paths.put(PATH2, URI2);
+
+        params = makeHttpActorParams();
+    }
+
+    @Test
+    public void testMakeOperationParameters() {
+        Function<String, Map<String, Object>> maker = params.makeOperationParameters(CONTAINER);
+        assertNull(maker.apply("unknown-operation"));
+
+        Map<String, Object> subparam = maker.apply(PATH1);
+        assertNotNull(subparam);
+        assertEquals("{clientName=my-client, path=uri #1, timeoutSec=10}", new TreeMap<>(subparam).toString());
+
+        subparam = maker.apply(PATH2);
+        assertNotNull(subparam);
+        assertEquals("{clientName=my-client, path=uri #2, timeoutSec=10}", new TreeMap<>(subparam).toString());
+    }
+
+    @Test
+    public void testDoValidation() {
+        assertThatCode(() -> params.doValidation(CONTAINER)).doesNotThrowAnyException();
+
+        // invalid param
+        params.setClientName(null);
+        assertThatThrownBy(() -> params.doValidation(CONTAINER))
+                        .isInstanceOf(ParameterValidationRuntimeException.class);
+    }
+
+    @Test
+    public void testValidate() {
+        testValidateField("clientName", "null", params2 -> params2.setClientName(null));
+        testValidateField("path", "null", params2 -> params2.setPath(null));
+        testValidateField("timeoutSec", "minimum", params2 -> params2.setTimeoutSec(-1));
+
+        // check edge cases
+        params.setTimeoutSec(0);
+        assertTrue(params.validate(CONTAINER).isValid());
+
+        params.setTimeoutSec(1);
+        assertTrue(params.validate(CONTAINER).isValid());
+
+        // one path value is null
+        testValidateField(PATH2, "null", params2 -> paths.put(PATH2, null));
+    }
+
+    private void testValidateField(String fieldName, String expected, Consumer<HttpActorParams> makeInvalid) {
+
+        // original params should be valid
+        ValidationResult result = params.validate(CONTAINER);
+        assertTrue(fieldName, result.isValid());
+
+        // make invalid params
+        HttpActorParams params2 = makeHttpActorParams();
+        makeInvalid.accept(params2);
+        result = params2.validate(CONTAINER);
+        assertFalse(fieldName, result.isValid());
+        assertThat(result.getResult()).contains(CONTAINER).contains(fieldName).contains(expected);
+    }
+
+    private HttpActorParams makeHttpActorParams() {
+        HttpActorParams params2 = new HttpActorParams();
+        params2.setClientName(CLIENT);
+        params2.setTimeoutSec(TIMEOUT);
+        params2.setPath(paths);
+
+        return params2;
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpParamsTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpParamsTest.java
new file mode 100644
index 000000000..829c480d1
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/HttpParamsTest.java
@@ -0,0 +1,80 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+import java.util.function.Function;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.HttpParams.HttpParamsBuilder;
+
+public class HttpParamsTest {
+
+    private static final String CONTAINER = "my-container";
+    private static final String CLIENT = "my-client";
+    private static final String PATH = "my-path";
+    private static final long TIMEOUT = 10;
+
+    private HttpParams params;
+
+    @Before
+    public void setUp() {
+        params = HttpParams.builder().clientName(CLIENT).path(PATH).timeoutSec(TIMEOUT).build();
+    }
+
+    @Test
+    public void testValidate() {
+        testValidateField("clientName", "null", bldr -> bldr.clientName(null));
+        testValidateField("path", "null", bldr -> bldr.path(null));
+        testValidateField("timeoutSec", "minimum", bldr -> bldr.timeoutSec(-1));
+
+        // check edge cases
+        assertTrue(params.toBuilder().timeoutSec(0).build().validate(CONTAINER).isValid());
+        assertTrue(params.toBuilder().timeoutSec(1).build().validate(CONTAINER).isValid());
+    }
+
+    @Test
+    public void testBuilder_testToBuilder() {
+        assertEquals(CLIENT, params.getClientName());
+        assertEquals(PATH, params.getPath());
+        assertEquals(TIMEOUT, params.getTimeoutSec());
+
+        assertEquals(params, params.toBuilder().build());
+    }
+
+    private void testValidateField(String fieldName, String expected,
+                    Function<HttpParamsBuilder, HttpParamsBuilder> makeInvalid) {
+
+        // original params should be valid
+        ValidationResult result = params.validate(CONTAINER);
+        assertTrue(fieldName, result.isValid());
+
+        // make invalid params
+        result = makeInvalid.apply(params.toBuilder()).build().validate(CONTAINER);
+        assertFalse(fieldName, result.isValid());
+        assertThat(result.getResult()).contains(fieldName).contains(expected);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ParameterValidationRuntimeExceptionTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ParameterValidationRuntimeExceptionTest.java
new file mode 100644
index 000000000..9879f604f
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/ParameterValidationRuntimeExceptionTest.java
@@ -0,0 +1,82 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertSame;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ObjectValidationResult;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.common.parameters.ValidationStatus;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.ParameterValidationRuntimeException;
+
+public class ParameterValidationRuntimeExceptionTest {
+
+    private static final String THE_MESSAGE = "the message";
+    private static final IllegalStateException EXPECTED_EXCEPTION = new IllegalStateException("expected exception");
+
+    private ValidationResult result;
+
+    @Before
+    public void setUp() {
+        result = new ObjectValidationResult("param", null, ValidationStatus.INVALID, "null");
+    }
+
+    @Test
+    public void testParameterValidationExceptionValidationResult() {
+        ParameterValidationRuntimeException ex = new ParameterValidationRuntimeException(result);
+        assertSame(result, ex.getResult());
+        assertNull(ex.getMessage());
+    }
+
+    @Test
+    public void testParameterValidationExceptionValidationResultString() {
+        ParameterValidationRuntimeException ex = new ParameterValidationRuntimeException(THE_MESSAGE, result);
+        assertSame(result, ex.getResult());
+        assertEquals(THE_MESSAGE, ex.getMessage());
+    }
+
+    @Test
+    public void testParameterValidationExceptionValidationResultThrowable() {
+        ParameterValidationRuntimeException ex = new ParameterValidationRuntimeException(EXPECTED_EXCEPTION, result);
+        assertSame(result, ex.getResult());
+        assertEquals(EXPECTED_EXCEPTION.toString(), ex.getMessage());
+        assertEquals(EXPECTED_EXCEPTION, ex.getCause());
+    }
+
+    @Test
+    public void testParameterValidationExceptionValidationResultStringThrowable() {
+        ParameterValidationRuntimeException ex =
+                        new ParameterValidationRuntimeException(THE_MESSAGE, EXPECTED_EXCEPTION,  result);
+        assertSame(result, ex.getResult());
+        assertEquals(THE_MESSAGE, ex.getMessage());
+        assertEquals(EXPECTED_EXCEPTION, ex.getCause());
+    }
+
+    @Test
+    public void testGetResult() {
+        ParameterValidationRuntimeException ex = new ParameterValidationRuntimeException(result);
+        assertSame(result, ex.getResult());
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicParamsTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicParamsTest.java
new file mode 100644
index 000000000..4834c98d2
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicParamsTest.java
@@ -0,0 +1,80 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.parameters;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+import java.util.function.Function;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ValidationResult;
+import org.onap.policy.controlloop.actorserviceprovider.parameters.TopicParams.TopicParamsBuilder;
+
+public class TopicParamsTest {
+
+    private static final String CONTAINER = "my-container";
+    private static final String TARGET = "my-target";
+    private static final String SOURCE = "my-source";
+    private static final long TIMEOUT = 10;
+
+    private TopicParams params;
+
+    @Before
+    public void setUp() {
+        params = TopicParams.builder().target(TARGET).source(SOURCE).timeoutSec(TIMEOUT).build();
+    }
+
+    @Test
+    public void testValidate() {
+        testValidateField("target", "null", bldr -> bldr.target(null));
+        testValidateField("source", "null", bldr -> bldr.source(null));
+        testValidateField("timeoutSec", "minimum", bldr -> bldr.timeoutSec(-1));
+
+        // check edge cases
+        assertTrue(params.toBuilder().timeoutSec(0).build().validate(CONTAINER).isValid());
+        assertTrue(params.toBuilder().timeoutSec(1).build().validate(CONTAINER).isValid());
+    }
+
+    @Test
+    public void testBuilder_testToBuilder() {
+        assertEquals(TARGET, params.getTarget());
+        assertEquals(SOURCE, params.getSource());
+        assertEquals(TIMEOUT, params.getTimeoutSec());
+
+        assertEquals(params, params.toBuilder().build());
+    }
+
+    private void testValidateField(String fieldName, String expected,
+                    Function<TopicParamsBuilder, TopicParamsBuilder> makeInvalid) {
+
+        // original params should be valid
+        ValidationResult result = params.validate(CONTAINER);
+        assertTrue(fieldName, result.isValid());
+
+        // make invalid params
+        result = makeInvalid.apply(params.toBuilder()).build().validate(CONTAINER);
+        assertFalse(fieldName, result.isValid());
+        assertThat(result.getResult()).contains(fieldName).contains(expected);
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/FutureManagerTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/FutureManagerTest.java
new file mode 100644
index 000000000..de1cf0f8d
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/FutureManagerTest.java
@@ -0,0 +1,142 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.pipeline;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.util.concurrent.Future;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+
+public class FutureManagerTest {
+
+    private static final String EXPECTED_EXCEPTION = "expected exception";
+
+    @Mock
+    private Future<String> future1;
+
+    @Mock
+    private Future<String> future2;
+
+    @Mock
+    private Future<String> future3;
+
+    private FutureManager mgr;
+
+    /**
+     * Initializes fields, including {@link #mgr}.
+     */
+    @Before
+    public void setUp() {
+        MockitoAnnotations.initMocks(this);
+
+        mgr = new FutureManager();
+    }
+
+    @Test
+    public void testStop() {
+        mgr.add(future1);
+        mgr.add(future2);
+        mgr.add(future3);
+
+        // arrange for one to throw an exception
+        when(future2.cancel(anyBoolean())).thenThrow(new IllegalStateException(EXPECTED_EXCEPTION));
+
+        // nothing should have been canceled yet
+        verify(future1, never()).cancel(anyBoolean());
+        verify(future2, never()).cancel(anyBoolean());
+        verify(future3, never()).cancel(anyBoolean());
+
+        assertTrue(mgr.isRunning());
+
+        // stop the controller
+
+        // stop the controller
+        mgr.stop();
+
+        // all controllers should now be stopped
+        assertFalse(mgr.isRunning());
+
+        // everything should have been invoked
+        verify(future1).cancel(anyBoolean());
+        verify(future2).cancel(anyBoolean());
+        verify(future3).cancel(anyBoolean());
+
+        // re-invoking stop should have no effect on the listeners
+        mgr.stop();
+
+        verify(future1).cancel(anyBoolean());
+        verify(future2).cancel(anyBoolean());
+        verify(future3).cancel(anyBoolean());
+    }
+
+    @Test
+    public void testAdd() {
+        // still running - this should not be invoked
+        mgr.add(future1);
+        verify(future1, never()).cancel(anyBoolean());
+
+        // re-add should have no impact
+        mgr.add(future1);
+        verify(future1, never()).cancel(anyBoolean());
+
+        mgr.stop();
+
+        verify(future1).cancel(anyBoolean());
+
+        // new additions should be invoked immediately
+        mgr.add(future2);
+        verify(future2).cancel(anyBoolean());
+
+        // should work with exceptions, too
+        when(future3.cancel(anyBoolean())).thenThrow(new IllegalStateException(EXPECTED_EXCEPTION));
+        mgr.add(future3);
+    }
+
+    @Test
+    public void testRemove() {
+        mgr.add(future1);
+        mgr.add(future2);
+
+        verify(future1, never()).cancel(anyBoolean());
+        verify(future2, never()).cancel(anyBoolean());
+
+        // remove the second
+        mgr.remove(future2);
+
+        // should be able to remove it again
+        mgr.remove(future2);
+
+        mgr.stop();
+
+        // first should have run, but not the second
+        verify(future1).cancel(anyBoolean());
+
+        verify(future2, never()).cancel(anyBoolean());
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManagerTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManagerTest.java
new file mode 100644
index 000000000..4a882d422
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/ListenerManagerTest.java
@@ -0,0 +1,134 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.pipeline;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+
+public class ListenerManagerTest {
+
+    private static final String EXPECTED_EXCEPTION = "expected exception";
+
+    @Mock
+    private Runnable runnable1;
+
+    @Mock
+    private Runnable runnable2;
+
+    @Mock
+    private Runnable runnable3;
+
+    private ListenerManager mgr;
+
+    /**
+     * Initializes fields, including {@link #mgr}.
+     */
+    @Before
+    public void setUp() {
+        MockitoAnnotations.initMocks(this);
+
+        mgr = new ListenerManager();
+    }
+
+    @Test
+    public void testStop_testIsRunning() {
+        mgr.add(runnable1);
+        mgr.add(runnable2);
+        mgr.add(runnable3);
+
+        // arrange for one to throw an exception
+        doThrow(new IllegalStateException(EXPECTED_EXCEPTION)).when(runnable2).run();
+
+        // nothing should have been canceled yet
+        verify(runnable1, never()).run();
+        verify(runnable2, never()).run();
+        verify(runnable3, never()).run();
+
+        assertTrue(mgr.isRunning());
+
+        // stop the controller
+        mgr.stop();
+
+        // all controllers should now be stopped
+        assertFalse(mgr.isRunning());
+
+        // everything should have been invoked
+        verify(runnable1).run();
+        verify(runnable2).run();
+        verify(runnable3).run();
+
+        // re-invoking stop should have no effect on the listeners
+        mgr.stop();
+
+        verify(runnable1).run();
+        verify(runnable2).run();
+        verify(runnable3).run();
+    }
+
+    @Test
+    public void testAdd() {
+        // still running - this should not be invoked
+        mgr.add(runnable1);
+        verify(runnable1, never()).run();
+
+        mgr.stop();
+
+        verify(runnable1).run();
+
+        // new additions should be invoked immediately
+        mgr.add(runnable2);
+        verify(runnable2).run();
+
+        // should work with exceptions, too
+        doThrow(new IllegalStateException(EXPECTED_EXCEPTION)).when(runnable3).run();
+        mgr.add(runnable3);
+    }
+
+    @Test
+    public void testRemove() {
+        mgr.add(runnable1);
+        mgr.add(runnable2);
+
+        verify(runnable1, never()).run();
+        verify(runnable2, never()).run();
+
+        // remove the second
+        mgr.remove(runnable2);
+
+        // should be able to remove it again
+        mgr.remove(runnable2);
+
+        mgr.stop();
+
+        // first should have run, but not the second
+        verify(runnable1).run();
+
+        verify(runnable2, never()).run();
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/PipelineControllerFutureTest.java b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/PipelineControllerFutureTest.java
new file mode 100644
index 000000000..b421c1ce2
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/pipeline/PipelineControllerFutureTest.java
@@ -0,0 +1,254 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.controlloop.actorserviceprovider.pipeline;
+
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotSame;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Future;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.function.BiConsumer;
+import java.util.function.Function;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+
+public class PipelineControllerFutureTest {
+    private static final IllegalStateException EXPECTED_EXCEPTION = new IllegalStateException("expected exception");
+    private static final String TEXT = "some text";
+
+    @Mock
+    private Runnable runnable1;
+
+    @Mock
+    private Runnable runnable2;
+
+    @Mock
+    private Future<String> future1;
+
+    @Mock
+    private Future<String> future2;
+
+    @Mock
+    private CompletableFuture<String> compFuture;
+
+
+    private PipelineControllerFuture<String> controller;
+
+
+    /**
+     * Initializes fields, including {@link #controller}. Adds all runners and futures to
+     * the controller.
+     */
+    @Before
+    public void setUp() {
+        MockitoAnnotations.initMocks(this);
+
+        controller = new PipelineControllerFuture<>();
+
+        controller.add(runnable1);
+        controller.add(future1);
+        controller.add(runnable2);
+        controller.add(future2);
+    }
+
+    @Test
+    public void testCancel_testAddFutureOfFBoolean_testAddRunnable__testIsRunning() {
+        assertTrue(controller.isRunning());
+
+        assertTrue(controller.cancel(false));
+
+        assertTrue(controller.isCancelled());
+        assertFalse(controller.isRunning());
+
+        verify(runnable1).run();
+        verify(runnable2).run();
+        verify(future1).cancel(anyBoolean());
+        verify(future2).cancel(anyBoolean());
+
+        // re-invoke; nothing should change
+        assertTrue(controller.cancel(true));
+
+        assertTrue(controller.isCancelled());
+        assertFalse(controller.isRunning());
+
+        verify(runnable1).run();
+        verify(runnable2).run();
+        verify(future1).cancel(anyBoolean());
+        verify(future2).cancel(anyBoolean());
+    }
+
+    @Test
+    public void testDelayedComplete() throws Exception {
+        controller.add(runnable1);
+
+        BiConsumer<String, Throwable> stopper = controller.delayedComplete();
+
+        // shouldn't have run yet
+        assertTrue(controller.isRunning());
+        verify(runnable1, never()).run();
+
+        stopper.accept(TEXT, null);
+
+        assertTrue(controller.isDone());
+        assertEquals(TEXT, controller.get());
+
+        assertFalse(controller.isRunning());
+        verify(runnable1).run();
+
+        // re-invoke; nothing should change
+        stopper.accept(TEXT, EXPECTED_EXCEPTION);
+        assertFalse(controller.isCompletedExceptionally());
+
+        assertFalse(controller.isRunning());
+        verify(runnable1).run();
+    }
+
+    /**
+     * Tests delayedComplete() when an exception is generated.
+     */
+    @Test
+    public void testDelayedCompleteWithException() throws Exception {
+        controller.add(runnable1);
+
+        BiConsumer<String, Throwable> stopper = controller.delayedComplete();
+
+        // shouldn't have run yet
+        assertTrue(controller.isRunning());
+        verify(runnable1, never()).run();
+
+        stopper.accept(TEXT, EXPECTED_EXCEPTION);
+
+        assertTrue(controller.isDone());
+        assertThatThrownBy(() -> controller.get()).hasCause(EXPECTED_EXCEPTION);
+
+        assertFalse(controller.isRunning());
+        verify(runnable1).run();
+
+        // re-invoke; nothing should change
+        stopper.accept(TEXT, null);
+        assertTrue(controller.isCompletedExceptionally());
+
+        assertFalse(controller.isRunning());
+        verify(runnable1).run();
+    }
+
+    @Test
+    public void testDelayedRemoveFutureOfF() throws Exception {
+        BiConsumer<String, Throwable> remover = controller.delayedRemove(future1);
+
+        remover.accept(TEXT, EXPECTED_EXCEPTION);
+
+        // should not have completed the controller
+        assertFalse(controller.isDone());
+
+        verify(future1, never()).cancel(anyBoolean());
+
+        controller.delayedComplete().accept(TEXT, EXPECTED_EXCEPTION);
+
+        verify(future1, never()).cancel(anyBoolean());
+        verify(future2).cancel(anyBoolean());
+    }
+
+    @Test
+    public void testDelayedRemoveRunnable() throws Exception {
+        BiConsumer<String, Throwable> remover = controller.delayedRemove(runnable1);
+
+        remover.accept(TEXT, EXPECTED_EXCEPTION);
+
+        // should not have completed the controller
+        assertFalse(controller.isDone());
+
+        verify(runnable1, never()).run();
+
+        controller.delayedComplete().accept(TEXT, EXPECTED_EXCEPTION);
+
+        verify(runnable1, never()).run();
+        verify(runnable2).run();
+    }
+
+    @Test
+    public void testRemoveFutureOfF_testRemoveRunnable() {
+        controller.remove(runnable2);
+        controller.remove(future1);
+
+        controller.cancel(true);
+
+        verify(runnable1).run();
+        verify(runnable2, never()).run();
+        verify(future1, never()).cancel(anyBoolean());
+        verify(future2).cancel(anyBoolean());
+    }
+
+    @Test
+    public void testAddFunction() {
+        AtomicReference<String> value = new AtomicReference<>();
+
+        Function<String, CompletableFuture<String>> func = controller.add(input -> {
+            value.set(input);
+            return compFuture;
+        });
+
+        assertSame(compFuture, func.apply(TEXT));
+        assertEquals(TEXT, value.get());
+
+        verify(compFuture, never()).cancel(anyBoolean());
+
+        // should not have completed the controller
+        assertFalse(controller.isDone());
+
+        // cancel - should propagate
+        controller.cancel(false);
+
+        verify(compFuture).cancel(anyBoolean());
+    }
+
+    /**
+     * Tests add(Function) when the controller is not running.
+     */
+    @Test
+    public void testAddFunctionNotRunning() {
+        AtomicReference<String> value = new AtomicReference<>();
+
+        Function<String, CompletableFuture<String>> func = controller.add(input -> {
+            value.set(input);
+            return compFuture;
+        });
+
+        controller.cancel(false);
+
+        CompletableFuture<String> fut = func.apply(TEXT);
+        assertNotSame(compFuture, fut);
+        assertFalse(fut.isDone());
+
+        assertNull(value.get());
+    }
+}
diff --git a/models-interactions/model-actors/actorServiceProvider/src/test/resources/logback-test.xml b/models-interactions/model-actors/actorServiceProvider/src/test/resources/logback-test.xml
new file mode 100644
index 000000000..f8a1e5112
--- /dev/null
+++ b/models-interactions/model-actors/actorServiceProvider/src/test/resources/logback-test.xml
@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ============LICENSE_START=======================================================
+  ONAP
+  ================================================================================
+  Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+  ================================================================================
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+  ============LICENSE_END=========================================================
+-->
+
+<configuration>
+
+    <contextName>Actors</contextName>
+    <statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener" />
+
+    <!-- USE FOR STD OUT ONLY -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <Pattern>%d %level  %msg%n</Pattern>
+        </encoder>
+    </appender>
+
+    <root level="warn">
+        <appender-ref ref="STDOUT" />
+    </root>
+
+    <!-- this is just an example -->
+    <logger name="ch.qos.logback.classic" level="off" additivity="false">
+        <appender-ref ref="STDOUT" />
+    </logger>
+</configuration>
diff --git a/models-interactions/model-impl/events/src/main/java/org/onap/policy/controlloop/ControlLoopOperation.java b/models-interactions/model-impl/events/src/main/java/org/onap/policy/controlloop/ControlLoopOperation.java
index 10457de51..11c013289 100644
--- a/models-interactions/model-impl/events/src/main/java/org/onap/policy/controlloop/ControlLoopOperation.java
+++ b/models-interactions/model-impl/events/src/main/java/org/onap/policy/controlloop/ControlLoopOperation.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * controlloop
  * ================================================================================
- * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved.
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -32,6 +32,9 @@ public class ControlLoopOperation implements Serializable {
 
     private static final long serialVersionUID = 8662706581293017099L;
 
+    public static final String SUCCESS_MSG = "Success";
+    public static final String FAILED_MSG = "Failed";
+
     private String actor;
     private String operation;
     private String target;
diff --git a/models-interactions/model-impl/sdnc/src/main/java/org/onap/policy/sdnc/SdncManager.java b/models-interactions/model-impl/sdnc/src/main/java/org/onap/policy/sdnc/SdncManager.java
index 7612eeb3f..fa18cb254 100644
--- a/models-interactions/model-impl/sdnc/src/main/java/org/onap/policy/sdnc/SdncManager.java
+++ b/models-interactions/model-impl/sdnc/src/main/java/org/onap/policy/sdnc/SdncManager.java
@@ -2,7 +2,7 @@
  * ============LICENSE_START=======================================================
  * Copyright (C) 2018 Huawei. All rights reserved.
  * ================================================================================
- * Modifications Copyright (C) 2019 AT&T Intellectual Property. All rights reserved
+ * Modifications Copyright (C) 2019-2020 AT&T Intellectual Property. All rights reserved
  * Modifications Copyright (C) 2019 Nordix Foundation.
  * Modifications Copyright (C) 2019 Samsung Electronics Co., Ltd.
  * ================================================================================
@@ -37,6 +37,8 @@ import org.onap.policy.sdnc.util.Serialization;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+// TODO this class will be deleted
+
 public final class SdncManager implements Runnable {
 
     private String sdncUrlBase;