Policy 1707 Second commit

Change-Id: I18f5b142238733d17280cf17c3d1dd28204d34e9
Signed-off-by: ITSERVICES\rb7147 <rb7147@att.com>

27 files changed, 3276 insertions, 0 deletions

diff --git a/ECOMP-ControlloopPolicy/pom.xml b/ECOMP-ControlloopPolicy/pom.xml
new file mode 100644
index 000000000..18b2c5ded
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/pom.xml
@@ -0,0 +1,33 @@
+<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>
+	<artifactId>ControlloopPolicy</artifactId>
+	<parent>
+		<groupId>org.openecomp.policy.engine</groupId>
+		<artifactId>PolicyEngineSuite</artifactId>
+		<version>1.1.0-SNAPSHOT</version>
+	</parent>
+	<dependencies>
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>4.12</version>
+			<scope>provided</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.yaml</groupId>
+			<artifactId>snakeyaml</artifactId>
+			<version>1.17</version>
+		</dependency>
+		<dependency>
+			<groupId>org.jgrapht</groupId>
+			<artifactId>jgrapht-core</artifactId>
+			<version>0.9.2</version>
+		</dependency>
+		<dependency>
+			<groupId>com.google.guava</groupId>
+			<artifactId>guava</artifactId>
+			<version>19.0</version>
+		</dependency>
+	</dependencies>
+</project>
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/CompilerException.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/CompilerException.java
new file mode 100644
index 000000000..7c124d5fd
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/CompilerException.java
@@ -0,0 +1,46 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.compiler;
+
+public class CompilerException extends Exception {
+
+	private static final long serialVersionUID = -7262217239867898601L;
+
+	public CompilerException() {
+	}
+
+	public CompilerException(String message) {
+		super(message);
+	}
+
+	public CompilerException(Throwable cause) {
+		super(cause);
+	}
+
+	public CompilerException(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public CompilerException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
+		super(message, cause, enableSuppression, writableStackTrace);
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/ControlLoopCompiler.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/ControlLoopCompiler.java
new file mode 100644
index 000000000..fca229242
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/ControlLoopCompiler.java
@@ -0,0 +1,618 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.compiler;
+
+import java.io.InputStream;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.jgrapht.DirectedGraph;
+import org.jgrapht.graph.ClassBasedEdgeFactory;
+import org.jgrapht.graph.DefaultEdge;
+import org.jgrapht.graph.DirectedMultigraph;
+import org.openecomp.policy.controlloop.policy.ControlLoop;
+import org.openecomp.policy.controlloop.policy.ControlLoopPolicy;
+import org.openecomp.policy.controlloop.policy.FinalResult;
+import org.openecomp.policy.controlloop.policy.Policy;
+import org.openecomp.policy.controlloop.policy.PolicyResult;
+import org.openecomp.policy.controlloop.policy.TargetType;
+import org.yaml.snakeyaml.Yaml;
+import org.yaml.snakeyaml.constructor.Constructor;
+
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableMap;
+
+public class ControlLoopCompiler {
+	
+	public static ControlLoopPolicy compile(ControlLoopPolicy policy, ControlLoopCompilerCallback callback) throws CompilerException {
+		//
+		// Ensure the control loop is sane
+		//
+		validateControlLoop(policy.controlLoop, callback);
+		//
+		// Validate the policies
+		//
+		validatePolicies(policy, callback);
+		return policy;
+	}
+	
+	public static ControlLoopPolicy	compile(InputStream yamlSpecification, ControlLoopCompilerCallback callback) throws CompilerException {
+		Yaml yaml = new Yaml(new Constructor(ControlLoopPolicy.class));
+		Object obj = yaml.load(yamlSpecification);
+		if (obj == null) {
+			throw new CompilerException("Could not parse yaml specification.");
+		}
+		if (! (obj instanceof ControlLoopPolicy)) {
+			throw new CompilerException("Yaml could not parse specification into required ControlLoopPolicy object");
+		}
+		return ControlLoopCompiler.compile((ControlLoopPolicy) obj, callback);
+	}
+	
+	private static void validateControlLoop(ControlLoop controlLoop, ControlLoopCompilerCallback callback) throws CompilerException {
+		if (controlLoop == null) {
+			if (callback != null) {
+				callback.onError("controlLoop cannot be null");
+			}
+		}
+		if (controlLoop.controlLoopName == null | controlLoop.controlLoopName.length() < 1) {
+			if (callback != null) {
+				callback.onError("Missing controlLoopName");
+			}
+		}
+		if (! controlLoop.version.contentEquals(ControlLoop.VERSION)) {
+			if (callback != null) {
+				callback.onError("Unsupported version for this compiler");
+			}
+		}
+		if (controlLoop.trigger_policy == null || controlLoop.trigger_policy.length() < 1) {
+			throw new CompilerException("trigger_policy is not valid");
+		}
+	    //
+	}
+
+	private static void validatePolicies(ControlLoopPolicy policy, ControlLoopCompilerCallback callback) throws CompilerException {
+		if (policy == null) {
+			throw new CompilerException("policy cannot be null");
+		}
+		//
+		// verify controlLoop overall timeout should be no less than the sum of operational policy timeouts
+		//
+		if (policy.policies == null) {
+            callback.onWarning("controlLoop is an open loop.");   
+        }
+        else{
+            int sum = 0;
+		    for (Policy operPolicy : policy.policies) {
+		    	sum += operPolicy.timeout.intValue();
+		    }
+		    if (policy.controlLoop.timeout.intValue() < sum) {
+		    	if (callback != null) {
+		    		callback.onError("controlLoop overall timeout is less than the sum of operational policy timeouts.");
+		    	}
+		    }
+		    //
+		    // For this version we can use a directed multigraph, in the future we may not be able to
+		    //
+		    DirectedGraph<NodeWrapper, LabeledEdge> graph = new DirectedMultigraph<NodeWrapper, LabeledEdge>(new ClassBasedEdgeFactory<NodeWrapper, LabeledEdge>(LabeledEdge.class));
+		    //
+		    // Check to see if the trigger Event is for OpenLoop, we do so by
+		    // attempting to create a FinalResult object from it. If its a policy id, this should
+		    // return null.
+		    //
+		    FinalResult triggerResult = FinalResult.toResult(policy.controlLoop.trigger_policy);
+		    TriggerNodeWrapper triggerNode;
+		    //
+		    // Did this turn into a FinalResult object?
+		    //
+		    if (triggerResult != null) {
+		    	//
+		    	// Ensure they didn't use some other FinalResult code
+		    	//
+		    	if (triggerResult != FinalResult.FINAL_OPENLOOP) {
+		    		throw new CompilerException("Unexpected Final Result for trigger_policy, should only be " + FinalResult.FINAL_OPENLOOP.toString() + " or a valid Policy ID");
+		    	}
+		    	//
+		    	// They really shouldn't have any policies attached.
+		    	//
+		    	if (policy.policies != null || policy.policies.size() > 0) {
+		    		if (callback != null) {
+		    			callback.onWarning("Open Loop policy contains policies. The policies will never be invoked.");
+		    		}
+		    	}
+		    	return;
+		    	//
+		    } else {
+		    	//
+		    	// Ok, not a FinalResult object so let's assume that it is a Policy. Which it should be.
+		    	//
+		    	triggerNode = new TriggerNodeWrapper(policy.controlLoop.controlLoopName);
+		    }
+		    //
+		    // Add in the trigger node
+		    //
+		    graph.addVertex(triggerNode);
+		    //
+		    // Add in our Final Result nodes. All paths should end to these nodes.
+		    //
+		    FinalResultNodeWrapper finalSuccess = new FinalResultNodeWrapper(FinalResult.FINAL_SUCCESS);
+		    FinalResultNodeWrapper finalFailure = new FinalResultNodeWrapper(FinalResult.FINAL_FAILURE);
+		    FinalResultNodeWrapper finalFailureTimeout = new FinalResultNodeWrapper(FinalResult.FINAL_FAILURE_TIMEOUT);
+		    FinalResultNodeWrapper finalFailureRetries = new FinalResultNodeWrapper(FinalResult.FINAL_FAILURE_RETRIES);
+		    FinalResultNodeWrapper finalFailureException = new FinalResultNodeWrapper(FinalResult.FINAL_FAILURE_EXCEPTION);
+		    FinalResultNodeWrapper finalFailureGuard = new FinalResultNodeWrapper(FinalResult.FINAL_FAILURE_GUARD);
+		    graph.addVertex(finalSuccess);
+		    graph.addVertex(finalFailure);
+		    graph.addVertex(finalFailureTimeout);
+		    graph.addVertex(finalFailureRetries);
+		    graph.addVertex(finalFailureException);
+		    graph.addVertex(finalFailureGuard);
+		    //
+		    // Work through the policies and add them in as nodes.
+		    //
+		    Map<Policy, PolicyNodeWrapper> mapNodes = new HashMap<Policy, PolicyNodeWrapper>();
+		    for (Policy operPolicy : policy.policies) {
+		    	//
+		    	// Check the policy id and make sure its sane
+		    	//
+		    	boolean okToAdd = true;
+		    	if (operPolicy.id == null || operPolicy.id.length() < 1) {
+		    		if (callback != null) {
+		    			callback.onError("Operational Policy has an bad ID");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	//
+		    	// Check if they decided to make the ID a result object
+		    	//
+		    	if (PolicyResult.toResult(operPolicy.id) != null) {
+		    		if (callback != null) {
+		    			callback.onError("Policy id is set to a PolicyResult " + operPolicy.id);
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (FinalResult.toResult(operPolicy.id) != null) {
+		    		if (callback != null) {
+		    			callback.onError("Policy id is set to a FinalResult " + operPolicy.id);
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	//
+		    	// Check that the actor/recipe/target are valid
+		    	// 
+		    	if (operPolicy.actor == null) {
+		    		if (callback != null) {
+		    			callback.onError("Policy actor is null");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	//
+		    	// Construct a list for all valid actors
+		    	//
+		    	ImmutableList<String> actors = ImmutableList.of("APPC", "AOTS", "MSO", "SDNO", "SDNR", "AAI");
+		    	//
+		    	if (operPolicy.actor != null && (!actors.contains(operPolicy.actor)) ) {
+		    		if (callback != null) {
+		    			callback.onError("Policy actor is invalid");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (operPolicy.recipe == null) {
+		    		if (callback != null) {
+		    			callback.onError("Policy recipe is null");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	//
+		    	// TODO:
+		    	// NOTE: We need a way to find the acceptable recipe values (either Enum or a database that has these)
+		    	// 
+		    	ImmutableMap<String, List<String>> recipes = new ImmutableMap.Builder<String, List<String>>()
+						.put("APPC", ImmutableList.of("Restart", "Rebuild", "Migrate", "ModifyConfig"))
+		    			.put("AOTS", ImmutableList.of("checkMaintenanceWindow", "checkENodeBTicketHours", "checkEquipmentStatus", "checkEimStatus", "checkEquipmentMaintenance"))
+		    			.put("MSO", ImmutableList.of("VF Module Create"))
+		    			.put("SDNO", ImmutableList.of("health-diagnostic-type", "health-diagnostic", "health-diagnostic-history", "health-diagnostic-commands", "health-diagnostic-aes"))
+		    			.put("SDNR", ImmutableList.of("Restart", "Reboot"))
+		    			.build();
+		    	//
+		    	if (operPolicy.recipe != null && (!recipes.getOrDefault(operPolicy.actor, Collections.emptyList()).contains(operPolicy.recipe))) {
+		    		if (callback != null) {
+		    			callback.onError("Policy recipe is invalid");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (operPolicy.target == null) {
+		    		if (callback != null) {
+		    			callback.onError("Policy target is null");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (operPolicy.target != null && operPolicy.target.type != TargetType.VM && operPolicy.target.type != TargetType.VFC && operPolicy.target.type != TargetType.PNF) {
+		    		if (callback != null) {
+		    			callback.onError("Policy target is invalid");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	//
+		    	// Check that policy results are connected to either default final * or another policy
+		    	//
+		    	if (FinalResult.toResult(operPolicy.success) != null && operPolicy.success != FinalResult.FINAL_SUCCESS.toString()) {
+		    		if (callback != null) {
+		    			callback.onError("Policy success is neither another policy nor FINAL_SUCCESS");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (FinalResult.toResult(operPolicy.failure) != null && operPolicy.failure != FinalResult.FINAL_FAILURE.toString()) {
+		    		if (callback != null) {
+		    			callback.onError("Policy failure is neither another policy nor FINAL_FAILURE");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (FinalResult.toResult(operPolicy.failure_retries) != null && operPolicy.failure_retries != FinalResult.FINAL_FAILURE_RETRIES.toString()) {
+		    		if (callback != null) {
+		    			callback.onError("Policy failure retries is neither another policy nor FINAL_FAILURE_RETRIES");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (FinalResult.toResult(operPolicy.failure_timeout) != null && operPolicy.failure_timeout != FinalResult.FINAL_FAILURE_TIMEOUT.toString()) {
+		    		if (callback != null) {
+		    			callback.onError("Policy failure timeout is neither another policy nor FINAL_FAILURE_TIMEOUT");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (FinalResult.toResult(operPolicy.failure_exception) != null && operPolicy.failure_exception != FinalResult.FINAL_FAILURE_EXCEPTION.toString()) {
+		    		if (callback != null) {
+		    			callback.onError("Policy failure exception is neither another policy nor FINAL_FAILURE_EXCEPTION");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	if (FinalResult.toResult(operPolicy.failure_guard) != null && operPolicy.failure_guard != FinalResult.FINAL_FAILURE_GUARD.toString()) {
+		    		if (callback != null) {
+		    			callback.onError("Policy failure guard is neither another policy nor FINAL_FAILURE_GUARD");
+		    		}
+		    		okToAdd = false;
+		    	}
+		    	//
+		    	// Is it still ok to add?
+		    	//
+		    	if (okToAdd == false) {
+		    		//
+		    		// Do not add it in
+		    		//
+		    		continue;
+		    	}
+		    	//
+		    	// Create wrapper policy node and save it into our map so we can
+		    	// easily retrieve it.
+		    	//
+		    	PolicyNodeWrapper node = new PolicyNodeWrapper(operPolicy);
+		    	mapNodes.put(operPolicy, node);
+		    	graph.addVertex(node);
+		    	//
+		    	// Is this the trigger policy?
+		    	//
+		    	if (operPolicy.id.equals(policy.controlLoop.trigger_policy)) {
+		    		//
+		    		// Yes add an edge from our trigger event node to this policy
+		    		//
+		    		graph.addEdge(triggerNode, node, new LabeledEdge(triggerNode, node, new TriggerEdgeWrapper("ONSET")));
+		    	}
+		    }
+		    //
+		    // last sweep to connect remaining edges for policy results
+		    //
+		    for (Policy operPolicy : policy.policies) {
+		    	PolicyNodeWrapper node = mapNodes.get(operPolicy);
+		    	//
+		    	// Just ensure this has something
+		    	//
+		    	if (node == null) {
+		    		continue;
+		    	}
+	    		if (FinalResult.isResult(operPolicy.success, FinalResult.FINAL_SUCCESS)) {
+	    			graph.addEdge(node, finalSuccess, new LabeledEdge(node, finalSuccess, new FinalResultEdgeWrapper(FinalResult.FINAL_SUCCESS)));
+	    		} else {
+	    			PolicyNodeWrapper toNode = findPolicyNode(mapNodes, operPolicy.success);
+	    			if (toNode == null) {
+	    				throw new CompilerException("Operation Policy " + operPolicy.id + " success is connected to unknown policy " + operPolicy.success);
+	    			} else {
+	    			 graph.addEdge(node, toNode, new LabeledEdge(node, toNode, new PolicyResultEdgeWrapper(PolicyResult.SUCCESS)));
+	    			}
+	    		}
+	    		if (FinalResult.isResult(operPolicy.failure, FinalResult.FINAL_FAILURE)) {
+	    			graph.addEdge(node, finalFailure, new LabeledEdge(node, finalFailure, new FinalResultEdgeWrapper(FinalResult.FINAL_FAILURE)));
+	    		} else {
+	    			PolicyNodeWrapper toNode = findPolicyNode(mapNodes, operPolicy.failure);
+	    			if (toNode == null) {
+	    				throw new CompilerException("Operation Policy " + operPolicy.id + " failure is connected to unknown policy " + operPolicy.failure);
+	    			} else {
+	    				graph.addEdge(node, toNode, new LabeledEdge(node, toNode, new PolicyResultEdgeWrapper(PolicyResult.FAILURE)));
+	    			}
+	    		}
+	    		if (FinalResult.isResult(operPolicy.failure_timeout, FinalResult.FINAL_FAILURE_TIMEOUT)) {
+	    			graph.addEdge(node, finalFailureTimeout, new LabeledEdge(node, finalFailureTimeout, new FinalResultEdgeWrapper(FinalResult.FINAL_FAILURE_TIMEOUT)));
+	    		} else {
+	    			PolicyNodeWrapper toNode = findPolicyNode(mapNodes, operPolicy.failure_timeout);
+	    			if (toNode == null) {
+	    				throw new CompilerException("Operation Policy " + operPolicy.id + " failure_timeout is connected to unknown policy " + operPolicy.failure_timeout);
+	    			} else {
+	    				graph.addEdge(node, toNode, new LabeledEdge(node, toNode, new PolicyResultEdgeWrapper(PolicyResult.FAILURE_TIMEOUT)));
+	    			}
+	    		}
+	    		if (FinalResult.isResult(operPolicy.failure_retries, FinalResult.FINAL_FAILURE_RETRIES)) {
+	    			graph.addEdge(node, finalFailureRetries, new LabeledEdge(node, finalFailureRetries, new FinalResultEdgeWrapper(FinalResult.FINAL_FAILURE_RETRIES)));
+	    		} else {
+	    			PolicyNodeWrapper toNode = findPolicyNode(mapNodes, operPolicy.failure_retries);
+	    			if (toNode == null) {
+	    				throw new CompilerException("Operation Policy " + operPolicy.id + " failure_retries is connected to unknown policy " + operPolicy.failure_retries);
+	    			} else {
+	    				graph.addEdge(node, toNode, new LabeledEdge(node, toNode, new PolicyResultEdgeWrapper(PolicyResult.FAILURE_RETRIES)));
+	    			}
+	    		}
+	    		if (FinalResult.isResult(operPolicy.failure_exception, FinalResult.FINAL_FAILURE_EXCEPTION)) {
+	    			graph.addEdge(node, finalFailureException, new LabeledEdge(node, finalFailureException, new FinalResultEdgeWrapper(FinalResult.FINAL_FAILURE_EXCEPTION)));
+	    		} else {
+	    			PolicyNodeWrapper toNode = findPolicyNode(mapNodes, operPolicy.failure_exception);
+	    			if (toNode == null) {
+	    				throw new CompilerException("Operation Policy " + operPolicy.id + " failure_exception is connected to unknown policy " + operPolicy.failure_exception);
+	    			} else {
+	    				graph.addEdge(node, toNode, new LabeledEdge(node, toNode, new PolicyResultEdgeWrapper(PolicyResult.FAILURE_EXCEPTION)));
+	    			}
+	    		}
+	    		if (FinalResult.isResult(operPolicy.failure_guard, FinalResult.FINAL_FAILURE_GUARD)) {
+	    			graph.addEdge(node, finalFailureGuard, new LabeledEdge(node, finalFailureGuard, new FinalResultEdgeWrapper(FinalResult.FINAL_FAILURE_GUARD)));
+	    		} else {
+	    			PolicyNodeWrapper toNode = findPolicyNode(mapNodes, operPolicy.failure_guard);
+	    			if (toNode == null) {
+	    				throw new CompilerException("Operation Policy " + operPolicy.id + " failure_guard is connected to unknown policy " + operPolicy.failure_guard);
+	    			} else {
+	    				graph.addEdge(node, toNode, new LabeledEdge(node, toNode, new PolicyResultEdgeWrapper(PolicyResult.FAILURE_GUARD)));
+	    			}
+	    		}
+	    	}
+		    //
+		    // Now validate all the nodes/edges
+		    //
+		    for (NodeWrapper node : graph.vertexSet()) {
+		    	if (node instanceof TriggerNodeWrapper) {
+		    		System.out.println("Trigger Node " + node.toString());
+		    		if (graph.inDegreeOf(node) > 0 ) {
+		    			//
+		    			// Really should NEVER get here unless someone messed up the code above.
+		    			//
+		    			throw new CompilerException("No inputs to event trigger");
+		    		}
+		    		//
+		    		// Should always be 1, except in the future we may support multiple events
+		    		//
+		    		if (graph.outDegreeOf(node) > 1) {
+		    			throw new CompilerException("The event trigger should only go to ONE node");
+		    		}
+		    	} else if (node instanceof FinalResultNodeWrapper) {
+		    		System.out.println("FinalResult Node " + node.toString());
+		    		//
+		    		// FinalResult nodes should NEVER have an out edge
+		    		//
+		    		if (graph.outDegreeOf(node) > 0) {
+		    			throw new CompilerException("FinalResult nodes should never have any out edges.");
+		    		}
+		    	} else if (node instanceof PolicyNodeWrapper) {
+		    		System.out.println("Policy Node " + node.toString());
+		    		//
+		    		// All Policy Nodes should have the 5 out degrees defined.
+		    		//
+		    		if (graph.outDegreeOf(node) != 6) {
+		    			throw new CompilerException("Policy node should ALWAYS have 6 out degrees.");
+		    		}
+		    		//
+		    		// Chenfei: All Policy Nodes should have at least 1 in degrees 
+		    		// 
+		    		if (graph.inDegreeOf(node) == 0) {
+		    			if (callback != null) {
+		    				callback.onWarning("Policy " + node.getID() + " is not reachable.");
+		    			}
+		    		}
+		    	}
+		    	for (LabeledEdge edge : graph.outgoingEdgesOf(node)){
+		    		System.out.println(edge.from.getID() + " invokes " + edge.to.getID() + " upon " + edge.edge.getID());
+		    	}
+		    }
+	    }	
+	}
+	
+	private static PolicyNodeWrapper findPolicyNode(Map<Policy, PolicyNodeWrapper> mapNodes, String id) {
+		for (Policy key : mapNodes.keySet()) {
+			if (key.id.equals(id)) {
+				return mapNodes.get(key);
+			}
+		}
+		return null;
+	}
+
+	private interface NodeWrapper {
+		
+		public String	getID();
+		
+	}
+	
+	private static class TriggerNodeWrapper implements NodeWrapper {
+		public String closedLoopControlName;
+		
+		public TriggerNodeWrapper(String closedLoopControlName) {
+			this.closedLoopControlName = closedLoopControlName;
+		}
+
+		@Override
+		public String toString() {
+			return "TriggerNodeWrapper [closedLoopControlName=" + closedLoopControlName + "]";
+		}
+
+		@Override
+		public String getID() {
+			return closedLoopControlName;
+		}
+		
+	}
+		
+	private static class FinalResultNodeWrapper implements NodeWrapper {
+
+		public FinalResult result;
+
+		public FinalResultNodeWrapper(FinalResult result) {
+			this.result = result;
+		}
+
+		@Override
+		public String toString() {
+			return "FinalResultNodeWrapper [result=" + result + "]";
+		}
+
+		@Override
+		public String getID() {
+			return result.toString();
+		}
+	}
+	
+	private static class PolicyNodeWrapper implements NodeWrapper {
+
+		public Policy policy;
+		
+		public PolicyNodeWrapper(Policy operPolicy) {
+			this.policy = operPolicy;
+		}
+
+		@Override
+		public String toString() {
+			return "PolicyNodeWrapper [policy=" + policy + "]";
+		}
+
+		@Override
+		public String getID() {
+			return policy.id;
+		}
+	}
+	
+	private interface EdgeWrapper {
+		
+		public String getID();
+		
+	}
+	
+	private static class TriggerEdgeWrapper implements EdgeWrapper {
+		
+		private String trigger;
+		
+		public TriggerEdgeWrapper(String trigger) {
+			this.trigger = trigger;
+		}
+
+		@Override
+		public String getID() {
+			return trigger;
+		}
+
+		@Override
+		public String toString() {
+			return "TriggerEdgeWrapper [trigger=" + trigger + "]";
+		}
+		
+	}
+	
+	private static class PolicyResultEdgeWrapper implements EdgeWrapper {
+		public PolicyResult policyResult;
+
+		public PolicyResultEdgeWrapper(PolicyResult policyResult) {
+			super();
+			this.policyResult = policyResult;
+		}
+
+		@Override
+		public String toString() {
+			return "PolicyResultEdgeWrapper [policyResult=" + policyResult + "]";
+		}
+
+		@Override
+		public String getID() {
+			return policyResult.toString();
+		}
+		
+		
+	}
+	
+	private static class FinalResultEdgeWrapper implements EdgeWrapper {
+
+		public FinalResult finalResult;
+		public FinalResultEdgeWrapper(FinalResult result) {
+			this.finalResult = result;
+		}
+
+		@Override
+		public String toString() {
+			return "FinalResultEdgeWrapper [finalResult=" + finalResult + "]";
+		}
+		
+		@Override
+		public String getID() {
+			return finalResult.toString();
+		}
+	}
+	
+	
+	private static class LabeledEdge extends DefaultEdge {
+
+		/**
+		 * 
+		 */
+		private static final long serialVersionUID = 579384429573385524L;
+		
+		private NodeWrapper from;
+		private NodeWrapper to;
+		private EdgeWrapper edge;
+		
+		public LabeledEdge(NodeWrapper from, NodeWrapper to, EdgeWrapper edge) {
+			this.from = from;
+			this.to = to;
+			this.edge = edge;
+		}
+		
+		@SuppressWarnings("unused")
+		public NodeWrapper from() {
+			return from;
+		}
+		
+		@SuppressWarnings("unused")
+		public NodeWrapper to() {
+			return to;
+		}
+		
+		@SuppressWarnings("unused")
+		public EdgeWrapper edge() {
+			return edge;
+		}
+
+		@Override
+		public String toString() {
+			return "LabeledEdge [from=" + from + ", to=" + to + ", edge=" + edge + "]";
+		}
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/ControlLoopCompilerCallback.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/ControlLoopCompilerCallback.java
new file mode 100644
index 000000000..bb6cebde4
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/compiler/ControlLoopCompilerCallback.java
@@ -0,0 +1,29 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.compiler;
+
+public interface ControlLoopCompilerCallback {
+	
+	public boolean	onWarning(String message);
+	
+	public boolean	onError(String message);
+	
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/guard/compiler/ControlLoopGuardCompiler.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/guard/compiler/ControlLoopGuardCompiler.java
new file mode 100644
index 000000000..a40bc9d53
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/guard/compiler/ControlLoopGuardCompiler.java
@@ -0,0 +1,137 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.guard.compiler;
+
+
+import java.io.InputStream;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+import org.openecomp.policy.controlloop.compiler.CompilerException;
+import org.openecomp.policy.controlloop.compiler.ControlLoopCompilerCallback;
+import org.openecomp.policy.controlloop.policy.guard.Constraint;
+import org.openecomp.policy.controlloop.policy.guard.ControlLoopGuard;
+import org.openecomp.policy.controlloop.policy.guard.GuardPolicy;
+import org.yaml.snakeyaml.Yaml;
+import org.yaml.snakeyaml.constructor.Constructor;
+
+public class ControlLoopGuardCompiler {
+	
+	public static ControlLoopGuard compile(ControlLoopGuard CLGuard, ControlLoopCompilerCallback callback) throws CompilerException {
+		//
+		// Ensure ControlLoopGuard has at least one guard policies
+		//
+		validateControlLoopGuard(CLGuard, callback);
+		//
+		// Ensure each guard policy has at least one constraints and all guard policies are unique
+		//
+		validateGuardPolicies(CLGuard.guards, callback);
+		//
+		// Ensure constraints for each guard policy are unique
+		//
+		validateConstraints(CLGuard.guards, callback);
+		
+		return CLGuard;
+	}
+	
+	public static ControlLoopGuard	compile(InputStream yamlSpecification, ControlLoopCompilerCallback callback) throws CompilerException {
+		Yaml yaml = new Yaml(new Constructor(ControlLoopGuard.class));
+		Object obj = yaml.load(yamlSpecification);
+		if (obj == null) {
+			throw new CompilerException("Could not parse yaml specification.");
+		}
+		if (! (obj instanceof ControlLoopGuard)) {
+			throw new CompilerException("Yaml could not parse specification into required ControlLoopGuard object");
+		}
+		return ControlLoopGuardCompiler.compile((ControlLoopGuard) obj, callback);
+	}
+	
+	private static void validateControlLoopGuard(ControlLoopGuard CLGuard, ControlLoopCompilerCallback callback) throws CompilerException {
+		if (CLGuard == null) {
+			if (callback != null) {
+				callback.onError("ControlLoop Guard cannot be null");
+			}
+			throw new CompilerException("ControlLoop Guard cannot be null");
+		}
+		if (CLGuard.guard == null) {
+			if (callback != null) {
+				callback.onError("Guard version cannot be null");
+			}
+		}
+		if (CLGuard.guards == null) {
+			if (callback != null) {
+				callback.onError("ControlLoop Guard should have at least one guard policies");
+			}
+		} else if (CLGuard.guards.size() < 1) {
+			if (callback != null) {
+				callback.onError("ControlLoop Guard should have at least one guard policies");
+			}
+		}
+	}
+	
+	private static void validateGuardPolicies(List<GuardPolicy> policies, ControlLoopCompilerCallback callback) throws CompilerException {
+		if (policies == null) {
+			if (callback != null) {
+				callback.onError("Guard policies should not be null");
+			}
+			throw new CompilerException("Guard policies should not be null");
+		}
+		//
+		// Ensure all guard policies are unique
+		//
+		Set<GuardPolicy> newSet = new HashSet<GuardPolicy>(policies);
+		if (newSet.size() != policies.size()) {
+			if (callback != null) {
+				callback.onWarning("There are duplicate guard policies");
+			}
+		}
+		//
+		// Ensure each guard policy has at least one constraints
+		//
+		for (GuardPolicy policy : policies) {
+			if (policy.limit_constraints == null || policy.limit_constraints.size() < 1) {
+				if (callback != null) {
+					callback.onError("Guard policy " + policy.name + " does not have any limit constraint");
+				}
+				throw new CompilerException("Guard policy " + policy.name + " does not have any limit constraint");
+			}
+		}
+	}
+	
+	private static void validateConstraints(List<GuardPolicy> policies, ControlLoopCompilerCallback callback) throws CompilerException {
+		if (policies == null) {
+			if (callback != null) {
+				callback.onError("Guard policies should not be null");
+			}
+			throw new CompilerException("Guard policies should not be null");
+		}
+		for (GuardPolicy policy : policies) {
+			Set<Constraint> newSet = new HashSet<Constraint>(policy.limit_constraints);
+			if (newSet.size() != policy.limit_constraints.size()) {
+				if (callback != null) {
+					callback.onWarning("Guard policy " + policy.name + " has duplicate limit constraints");
+				}
+			}
+		}
+	}
+	
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/ControlLoop.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/ControlLoop.java
new file mode 100644
index 000000000..fa144156e
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/ControlLoop.java
@@ -0,0 +1,97 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+public class ControlLoop {
+	
+	public static String VERSION = "2.0.0";
+
+	public String controlLoopName;
+	public final String version = VERSION;
+	public String trigger_policy = FinalResult.FINAL_OPENLOOP.toString();
+	public Integer timeout;
+	public Boolean abatement = false;
+	
+	public ControlLoop() {
+		
+	}
+	
+	public ControlLoop(ControlLoop controlLoop) {
+		this.controlLoopName = controlLoop.controlLoopName;
+		this.trigger_policy = controlLoop.trigger_policy;
+		this.timeout = controlLoop.timeout;
+		this.abatement = controlLoop.abatement;
+	}
+	@Override
+	public String toString() {
+		return "ControlLoop [controlLoopName=" + controlLoopName + ", version=" + version
+				+ ", trigger_policy=" + trigger_policy + ", timeout="
+				+ timeout + ", abatement=" + abatement + "]";
+	}
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((controlLoopName == null) ? 0 : controlLoopName.hashCode());
+		result = prime * result + ((timeout == null) ? 0 : timeout.hashCode());
+		result = prime * result + ((trigger_policy == null) ? 0 : trigger_policy.hashCode());
+		result = prime * result + ((version == null) ? 0 : version.hashCode());
+		result = prime * result + ((abatement == null) ? 0 : abatement.hashCode());
+		return result;
+	}
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		ControlLoop other = (ControlLoop) obj;
+		if (controlLoopName == null) {
+			if (other.controlLoopName != null)
+				return false;
+		} else if (!controlLoopName.equals(other.controlLoopName))
+			return false;
+		if (timeout == null) {
+			if (other.timeout != null)
+				return false;
+		} else if (!timeout.equals(other.timeout))
+			return false;
+		if (trigger_policy == null) {
+			if (other.trigger_policy != null)
+				return false;
+		} else if (!trigger_policy.equals(other.trigger_policy))
+			return false;
+		if (version == null) {
+			if (other.version != null)
+				return false;
+		} else if (!version.equals(other.version))
+			return false;
+		if (abatement == null) {
+			if (other.abatement != null)
+				return false;
+		} else if (!abatement.equals(other.abatement))
+			return false;
+		return true;
+	}
+	
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/ControlLoopPolicy.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/ControlLoopPolicy.java
new file mode 100644
index 000000000..f14229bce
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/ControlLoopPolicy.java
@@ -0,0 +1,67 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+import java.util.LinkedList;
+
+public class ControlLoopPolicy {
+	
+	public ControlLoop controlLoop;
+
+	public LinkedList<Policy> policies;
+
+	@Override
+	public String toString() {
+		return "ControlLoopPolicy [controlLoop=" + controlLoop + ", policies=" + policies + "]";
+	}
+
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((controlLoop == null) ? 0 : controlLoop.hashCode());
+		result = prime * result + ((policies == null) ? 0 : policies.hashCode());
+		return result;
+	}
+
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		ControlLoopPolicy other = (ControlLoopPolicy) obj;
+		if (controlLoop == null) {
+			if (other.controlLoop != null)
+				return false;
+		} else if (!controlLoop.equals(other.controlLoop))
+			return false;
+		if (policies == null) {
+			if (other.policies != null)
+				return false;
+		} else if (!policies.equals(other.policies))
+			return false;
+		return true;
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/FinalResult.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/FinalResult.java
new file mode 100644
index 000000000..86b174a85
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/FinalResult.java
@@ -0,0 +1,93 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+public enum FinalResult {
+	/**
+	 * The Control Loop Policy successfully completed its Operations.
+	 */
+	FINAL_SUCCESS("Final_Success"),
+	/**
+	 * The Control Loop Policy was an Open Loop and is finished.
+	 */
+	FINAL_OPENLOOP("Final_OpenLoop"),
+	/**
+	 * The Control Loop Policy failed in its last Operation Policy. NOTE: Previous Operation Policies may have been successful.
+	 */
+	FINAL_FAILURE("Final_Failure"),
+	/**
+	 * The Control Loop Policy failed because the overall timeout was met.
+	 */
+	FINAL_FAILURE_TIMEOUT("Final_Failure_Timeout"),
+	/**
+	 * The Control Loop Policy failed because an Operation Policy met its retry limit.
+	 */
+	FINAL_FAILURE_RETRIES("Final_Failure_Retries"),
+	/**
+	 * The Control Loop Policy failed due to an exception.
+	 */
+	FINAL_FAILURE_EXCEPTION("Final_Failure_Exception"), 
+	/**
+	 *  The Control Loop Policy failed due to guard denied
+	 */
+	FINAL_FAILURE_GUARD("Final_Failure_Guard")
+	;
+	
+	String result;
+	
+	private FinalResult(String result) {
+		this.result = result;
+	}
+	
+	public static FinalResult	toResult(String result) {
+		if (result.equalsIgnoreCase(FINAL_SUCCESS.toString())) {
+			return FINAL_SUCCESS;
+		}
+		if (result.equalsIgnoreCase(FINAL_OPENLOOP.toString())) {
+			return FINAL_OPENLOOP;
+		}
+		if (result.equalsIgnoreCase(FINAL_FAILURE.toString())) {
+			return FINAL_FAILURE;
+		}
+		if (result.equalsIgnoreCase(FINAL_FAILURE_TIMEOUT.toString())) {
+			return FINAL_FAILURE_TIMEOUT;
+		}
+		if (result.equalsIgnoreCase(FINAL_FAILURE_RETRIES.toString())) {
+			return FINAL_FAILURE_RETRIES;
+		}
+		if (result.equalsIgnoreCase(FINAL_FAILURE_EXCEPTION.toString())) {
+			return FINAL_FAILURE_EXCEPTION;
+		}
+		if (result.equalsIgnoreCase(FINAL_FAILURE_GUARD.toString())) {
+			return FINAL_FAILURE_GUARD;
+		}
+		return null;
+	}
+	
+	public static boolean isResult(String result, FinalResult finalResult) {
+		FinalResult toResult = FinalResult.toResult(result);
+		if (toResult == null) {
+			return false;
+		}
+		return (toResult.equals(finalResult));
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/OperationsAccumulateParams.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/OperationsAccumulateParams.java
new file mode 100644
index 000000000..6cf91ce05
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/OperationsAccumulateParams.java
@@ -0,0 +1,83 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+import java.io.Serializable;
+
+public class OperationsAccumulateParams implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = -3597358159130168247L;
+	
+	public String period;
+	public Integer limit;
+	
+	public OperationsAccumulateParams() {
+		
+	} 
+	
+	public OperationsAccumulateParams(OperationsAccumulateParams ops) {
+		this.period = ops.period;
+		this.limit = ops.limit;
+	}
+	
+	public OperationsAccumulateParams(String period, Integer limit) {
+		this.period = period;
+		this.limit = limit;
+	}
+	
+	@Override
+	public String toString() {
+		return "OperationsAccumulateParams [period=" + period + ", limit=" + limit + "]";
+	}
+	
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((period == null) ? 0 : period.hashCode());
+		result = prime * result + ((limit == null) ? 0 : limit.hashCode());
+		return result;
+	}
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		OperationsAccumulateParams other = (OperationsAccumulateParams) obj;
+		if (period == null) {
+			if (other.period != null)
+				return false;
+		} else if (!period.equals(other.period))
+			return false;
+		if (limit == null) {
+			if (other.limit != null)
+				return false;
+		} else if (!limit.equals(other.limit))
+			return false;
+		return true;
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/Policy.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/Policy.java
new file mode 100644
index 000000000..0af1eab68
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/Policy.java
@@ -0,0 +1,245 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.UUID;
+
+public class Policy {
+
+	public String id = UUID.randomUUID().toString();
+	public String name;
+	public String description;
+	public String actor;
+	public String recipe;
+	public Map<String, String> payload;
+	public Target target;
+	public OperationsAccumulateParams operationsAccumulateParams;
+	public Integer retry = 0;
+	public Integer timeout = 300;
+	public String success = FinalResult.FINAL_SUCCESS.toString();
+	public String failure = FinalResult.FINAL_FAILURE.toString();
+	public String failure_retries = FinalResult.FINAL_FAILURE_RETRIES.toString();
+	public String failure_timeout = FinalResult.FINAL_FAILURE_TIMEOUT.toString();
+	public String failure_exception = FinalResult.FINAL_FAILURE_EXCEPTION.toString();
+	public String failure_guard = FinalResult.FINAL_FAILURE_GUARD.toString();
+	
+	
+	public Policy() {
+		
+	}
+	
+	public Policy(String id) {
+		this.id = id;
+	}
+	
+	public Policy(String name, String actor, String recipe, Map<String, String> payload, Target target) {
+		this.name = name;
+		this.actor = actor;
+		this.recipe = recipe;
+		this.target = target;
+		if (payload != null) {
+//			this.payload = new LinkedList<Map<String, String>>();
+			this.payload = Collections.unmodifiableMap(payload);
+		}
+	}
+	
+	public Policy(String name, String actor, String recipe, Map<String, String> payload, Target target, Integer retries, Integer timeout) {
+		this(name, actor, recipe, payload, target);
+		this.retry = retries;
+		this.timeout = timeout;
+	}
+	
+	public Policy(String id, String name, String description, String actor, Map<String, String> payload, Target target, String recipe, Integer retries, Integer timeout) {
+		this(name, actor, recipe, payload, target, retries, timeout);
+		this.id = id;
+		this.description = description;
+	}
+	
+	public Policy(Policy policy) {
+		this.id = policy.id;
+		this.name = policy.name;
+		this.description = policy.description;
+		this.actor = policy.actor;
+		this.recipe = policy.recipe;
+		if (policy.payload != null) {
+//			this.payload = new LinkedList<Map<String, String>>();
+//			this.payload.addAll(policy.payload);
+			this.payload = Collections.unmodifiableMap(policy.payload);
+		}
+		this.target = policy.target;
+		this.operationsAccumulateParams = policy.operationsAccumulateParams;
+		this.retry = policy.retry;
+		this.timeout = policy.timeout;
+		this.success = policy.success;
+		this.failure = policy.failure;
+		this.failure_exception = policy.failure_exception;
+		this.failure_guard = policy.failure_guard;
+		this.failure_retries = policy.failure_retries;
+		this.failure_timeout = policy.failure_timeout;
+	}
+
+	public boolean isValid() {
+		try {
+			if (id == null) {
+				throw new NullPointerException();
+			}
+			if (name == null) {
+				throw new NullPointerException();
+			}
+			if (actor == null) {
+				throw new NullPointerException();
+			}
+			if (recipe == null) {
+				throw new NullPointerException();
+			}
+			if (target == null) {
+				throw new NullPointerException();
+			}
+		} catch (Exception e) {
+			return false;
+		}
+		
+		return true;
+	}
+
+	@Override
+	public String toString() {
+		return "Policy [id=" + id + ", name=" + name + ", description=" + description + ", actor=" + actor + ", recipe="
+				+ recipe + ", payload=" + payload + ", target=" + target + ", operationsAccumulateParams=" + operationsAccumulateParams + ", retry=" + retry + ", timeout=" + timeout
+				+ ", success=" + success + ", failure=" + failure + ", failure_retries=" + failure_retries
+				+ ", failure_timeout=" + failure_timeout + ", failure_exception=" + failure_exception + ", failure_guard=" + failure_guard + "]";
+	}
+
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((actor == null) ? 0 : actor.hashCode());
+		result = prime * result + ((description == null) ? 0 : description.hashCode());
+		result = prime * result + ((failure == null) ? 0 : failure.hashCode());
+		result = prime * result + ((failure_exception == null) ? 0 : failure_exception.hashCode());
+		result = prime * result + ((failure_guard == null) ? 0 : failure_guard.hashCode());
+		result = prime * result + ((failure_retries == null) ? 0 : failure_retries.hashCode());
+		result = prime * result + ((failure_timeout == null) ? 0 : failure_timeout.hashCode());
+		result = prime * result + ((id == null) ? 0 : id.hashCode());
+		result = prime * result + ((name == null) ? 0 : name.hashCode());
+		result = prime * result + ((payload == null) ? 0 : payload.hashCode());
+		result = prime * result + ((recipe == null) ? 0 : recipe.hashCode());
+		result = prime * result + ((retry == null) ? 0 : retry.hashCode());
+		result = prime * result + ((success == null) ? 0 : success.hashCode());
+		result = prime * result + ((target == null) ? 0 : target.hashCode());
+		result = prime * result + ((operationsAccumulateParams == null) ? 0 : operationsAccumulateParams.hashCode());
+		result = prime * result + ((timeout == null) ? 0 : timeout.hashCode());
+		return result;
+	}
+
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		Policy other = (Policy) obj;
+		if (actor != other.actor)
+			return false;
+		if (description == null) {
+			if (other.description != null)
+				return false;
+		} else if (!description.equals(other.description))
+			return false;
+		if (failure == null) {
+			if (other.failure != null)
+				return false;
+		} else if (!failure.equals(other.failure))
+			return false;
+		if (failure_exception == null) {
+			if (other.failure_exception != null)
+				return false;
+		} else if (!failure_exception.equals(other.failure_exception))
+			return false;
+		if (failure_guard == null) {
+			if (other.failure_guard != null)
+				return false;
+		} else if (!failure_guard.equals(other.failure_guard))
+			return false;
+		if (failure_retries == null) {
+			if (other.failure_retries != null)
+				return false;
+		} else if (!failure_retries.equals(other.failure_retries))
+			return false;
+		if (failure_timeout == null) {
+			if (other.failure_timeout != null)
+				return false;
+		} else if (!failure_timeout.equals(other.failure_timeout))
+			return false;
+		if (id == null) {
+			if (other.id != null)
+				return false;
+		} else if (!id.equals(other.id))
+			return false;
+		if (name == null) {
+			if (other.name != null)
+				return false;
+		} else if (!name.equals(other.name))
+			return false;
+		if (payload == null) {
+			if (other.payload != null)
+				return false;
+		} else if (!payload.equals(other.payload))
+			return false;
+		if (recipe == null) {
+			if (other.recipe != null)
+				return false;
+		} else if (!recipe.equals(other.recipe))
+			return false;
+		if (retry == null) {
+			if (other.retry != null)
+				return false;
+		} else if (!retry.equals(other.retry))
+			return false;
+		if (success == null) {
+			if (other.success != null)
+				return false;
+		} else if (!success.equals(other.success))
+			return false;
+		if (operationsAccumulateParams == null) {
+			if (other.operationsAccumulateParams != null)
+				return false;
+		} else if (!operationsAccumulateParams.equals(other.operationsAccumulateParams))
+			return false;
+		if (target == null) {
+			if (other.target != null)
+				return false;
+		} else if (!target.equals(other.target))
+			return false;	
+		if (timeout == null) {
+			if (other.timeout != null)
+				return false;
+		} else if (!timeout.equals(other.timeout))
+			return false;
+		return true;
+	}
+	
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/PolicyResult.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/PolicyResult.java
new file mode 100644
index 000000000..cfcd624f3
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/PolicyResult.java
@@ -0,0 +1,81 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+public enum PolicyResult {
+	/**
+	 * Operation was successful.
+	 */
+	SUCCESS("Success"),
+	/**
+	 * Operation failed.
+	 */
+	FAILURE("Failure"),
+	/**
+	 * Operation failed due to maximum retries being met.
+	 */
+	FAILURE_RETRIES("Failure_Retries"),
+	/**
+	 * Operation failed due to timeout occurring.
+	 */
+	FAILURE_TIMEOUT("Failure_Timeout"),
+	/**
+	 * Operation failed due to an exception.
+	 */
+	FAILURE_EXCEPTION("Failure_Exception"), 
+	/**
+	 * Operation failed since Guard did not permit.
+	 */
+	FAILURE_GUARD("Failure_Guard")
+	;
+	
+	private String result;
+	
+	private PolicyResult(String result) {
+		this.result = result;
+	}
+	
+	public String toString() {
+		return this.result;
+	}
+	
+	public static PolicyResult toResult(String result) {
+		if (result.equalsIgnoreCase(SUCCESS.toString())) {
+			return SUCCESS;
+		}
+		if (result.equalsIgnoreCase(FAILURE.toString())) {
+			return FAILURE;
+		}
+		if (result.equalsIgnoreCase(FAILURE_RETRIES.toString())) {
+			return FAILURE_RETRIES;
+		}
+		if (result.equalsIgnoreCase(FAILURE_TIMEOUT.toString())) {
+			return FAILURE_TIMEOUT;
+		}
+		if (result.equalsIgnoreCase(FAILURE_EXCEPTION.toString())) {
+			return FAILURE_EXCEPTION;
+		}
+		if (result.equalsIgnoreCase(FAILURE_GUARD.toString())) {
+			return FAILURE_GUARD;
+		}
+		return null;
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/Target.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/Target.java
new file mode 100644
index 000000000..9bccf0feb
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/Target.java
@@ -0,0 +1,90 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+import java.io.Serializable;
+
+public class Target implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 2180988443264988319L;
+	 
+	public String resourceID;
+	public TargetType type;
+
+	public Target() {
+		
+	}
+	
+	public Target(TargetType type) {
+		this.type = type;
+	}
+	
+	public Target(String resourceID) {
+		this.resourceID = resourceID;
+	}
+	
+	public Target(TargetType type, String resourceID) {
+		this.type = type;
+		this.resourceID = resourceID;
+	}
+	
+	public Target(Target target) {
+		this.type = target.type;
+		this.resourceID = target.resourceID;
+	}
+	
+	@Override
+	public String toString() {
+		return "Target [type=" + type + ", resourceID=" + resourceID + "]";
+	}
+	
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((type == null) ? 0 : type.hashCode());
+		result = prime * result + ((resourceID == null) ? 0 : resourceID.hashCode());
+		return result;
+	}
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		Target other = (Target) obj;
+		if (type == null) {
+			if (other.type != null)
+				return false;
+		} else if (!type.equals(other.type))
+			return false;
+		if (resourceID == null) {
+			if (other.resourceID != null)
+				return false;
+		} else if (!resourceID.equals(other.resourceID))
+			return false;
+		return true;
+	}
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/TargetType.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/TargetType.java
new file mode 100644
index 000000000..c5e4abce0
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/TargetType.java
@@ -0,0 +1,38 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy;
+
+public enum TargetType {
+	VM("VM"),
+	PNF("PNF"),
+	VFC("VFC")
+	;
+	
+	private String targetType;
+	
+	private TargetType(String targetType) {
+		this.targetType = targetType;
+	}
+	
+	public String toString() {
+		return this.targetType;
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/BuilderException.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/BuilderException.java
new file mode 100644
index 000000000..a087463b9
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/BuilderException.java
@@ -0,0 +1,33 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder;
+
+public class BuilderException extends Exception {
+
+	public BuilderException(String string) {
+		super(string);
+	}
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 610064813684337895L;
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/ControlLoopPolicyBuilder.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/ControlLoopPolicyBuilder.java
new file mode 100644
index 000000000..fb10f292c
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/ControlLoopPolicyBuilder.java
@@ -0,0 +1,208 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder;
+
+import java.util.Map;
+
+import org.openecomp.policy.controlloop.policy.ControlLoop;
+import org.openecomp.policy.controlloop.policy.OperationsAccumulateParams;
+import org.openecomp.policy.controlloop.policy.Policy;
+import org.openecomp.policy.controlloop.policy.PolicyResult;
+import org.openecomp.policy.controlloop.policy.Target;
+import org.openecomp.policy.controlloop.policy.builder.impl.ControlLoopPolicyBuilderImpl;
+
+public interface ControlLoopPolicyBuilder {
+	
+	/**
+	 *  @param abatement
+	 *  @return
+	 *  @throws BuilderException
+	 */
+	public ControlLoopPolicyBuilder setAbatement(Boolean abatement) throws BuilderException;
+	
+	
+	/**
+	 * Sets the overall timeout value for the Control Loop. If any operational policies have retries and timeouts,
+	 * then this overall timeout value should exceed all those values.
+	 * 
+	 * @param timeout
+	 * @return
+	 * @throws BuilderException
+	 */
+	public ControlLoopPolicyBuilder	setTimeout(Integer timeout) throws BuilderException;
+	
+	/**
+	 * Scans the operational policies and calculate an minimum overall timeout for the Control Loop.
+	 * 
+	 * 
+	 * @return Integer
+	 */
+	public Integer calculateTimeout();
+	
+	/**
+	 * Sets the initial trigger policy when a DCAE Closed Loop Event arrives in the ECOMP Policy Platform.
+	 * 
+	 * 
+	 * @param name
+	 * @param description
+	 * @param actor
+	 * @param target
+	 * @param recipe
+	 * @param retries
+	 * @param timeout
+	 * @return Policy
+	 * @throws BuilderException
+	 */
+	public Policy setTriggerPolicy(String name, String description, String actor, Target target, String recipe, Map<String, String> payload, Integer retries, Integer timeout) throws BuilderException;
+	
+	/**
+	 * 
+	 * Changes the trigger policy to point to another existing Policy.
+	 * 
+	 * 
+	 * @param id
+	 * @return ControlLoop
+	 * @throws BuilderException
+	 */
+	public ControlLoop	setTriggerPolicy(String id) throws BuilderException;
+	
+	/**
+	 * @return
+	 */
+	public boolean	isOpenLoop();
+	
+	/**
+	 * @return
+	 * @throws BuilderException
+	 */
+	public Policy	getTriggerPolicy() throws BuilderException;
+	
+	/**
+	 * Simply returns a copy of the ControlLoop information.
+	 * 
+	 * 
+	 * @return ControlLoop
+	 */
+	public ControlLoop	getControlLoop();
+	
+	/**
+	 * Creates a policy that is chained to the result of another Policy.
+	 * 
+	 * 
+	 * @param name
+	 * @param description
+	 * @param actor
+	 * @param target
+	 * @param recipe
+	 * @param retries
+	 * @param timeout
+	 * @param policyID
+	 * @param results
+	 * @return
+	 * @throws BuilderException
+	 */
+	public Policy setPolicyForPolicyResult(String name, String description, String actor,
+			Target target, String recipe, Map<String, String> payload, Integer retries, Integer timeout, String policyID, PolicyResult... results) throws BuilderException;
+	
+	
+	/**
+	 * Sets the policy result(s) to an existing Operational Policy.
+	 * 
+	 * 
+	 * @param policyResultID
+	 * @param policyID
+	 * @param results
+	 * @return
+	 * @throws BuilderException
+	 */
+	public Policy setPolicyForPolicyResult(String policyResultID, String policyID, PolicyResult... results) throws BuilderException;
+	
+	/**
+	 * Removes an Operational Policy. Be mindful that if any other Operational Policies have results that point to this policy, any
+	 * policies that have results pointing to this policy will have their result reset to the appropriate default FINAL_* result.
+	 * 
+	 * 
+	 * @param policyID
+	 * @return
+	 * @throws BuilderException
+	 */
+	public boolean removePolicy(String policyID) throws BuilderException;
+	
+	/**
+	 * Resets a policy's results to defualt FINAL_* codes.
+	 * 
+	 * 
+	 * @return Policy
+	 * @throws BuilderException - Policy does not exist
+	 */
+	public Policy	resetPolicyResults(String policyID) throws BuilderException;
+	
+	/**
+	 * Removes all existing Operational Policies and reverts back to an Open Loop.
+	 * 
+	 * @return
+	 */
+	public ControlLoopPolicyBuilder	removeAllPolicies();
+		
+	/**
+	 * Adds an operationsAccumulateParams to an existing operational policy
+	 * 
+	 * @return Policy
+	 * @throws BuilderException - Policy does not exist
+	 */
+	public Policy addOperationsAccumulateParams(String policyID, OperationsAccumulateParams operationsAccumulateParams) throws BuilderException;
+	
+	/**
+	 * This will compile and build the YAML specification for the Control Loop Policy. Please iterate the Results object for details.
+	 * The Results object will contains warnings and errors. If the specification compiled successfully, you will be able to retrieve the
+	 * YAML.
+	 * 
+	 * @return Results
+	 */
+	public Results	buildSpecification();
+	
+	/**
+	 * The Factory is used to build a ControlLoopPolicyBuilder implementation.
+	 * 
+	 * @author pameladragosh
+	 *
+	 */
+	public static class Factory {
+		
+		/**
+		 * Builds a basic Control Loop with an overall timeout. Use this method if you wish to create an OpenLoop, or if you 
+		 * want to interactively build a Closed Loop.
+		 * 
+		 * @param controlLoopName - Per Closed Loop AID v1.0, unique string for the closed loop.
+		 * @param timeout - Overall timeout for the Closed Loop to execute.
+		 * @return ControlLoopPolicyBuilder object
+		 * @throws BuilderException
+		 */
+		public static ControlLoopPolicyBuilder	buildControlLoop (String controlLoopName, Integer timeout) throws BuilderException {
+			
+			ControlLoopPolicyBuilder builder = new ControlLoopPolicyBuilderImpl(controlLoopName, timeout);
+			
+			return builder;
+		}		
+		
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/Message.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/Message.java
new file mode 100644
index 000000000..35aa3666f
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/Message.java
@@ -0,0 +1,29 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder;
+
+public interface Message {
+	
+	public String	getMessage();
+	
+	public MessageLevel	getLevel();
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/MessageLevel.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/MessageLevel.java
new file mode 100644
index 000000000..3c09d3813
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/MessageLevel.java
@@ -0,0 +1,29 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder;
+
+public enum MessageLevel {
+	INFO,
+	WARNING,
+	ERROR,
+	EXCEPTION
+	;
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/Results.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/Results.java
new file mode 100644
index 000000000..172524a78
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/Results.java
@@ -0,0 +1,33 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder;
+
+import java.util.List;
+
+public interface Results {
+	
+	public List<Message>	getMessages();
+	
+	public String	getSpecification();
+	
+	public boolean	isValid();
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/ControlLoopPolicyBuilderImpl.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/ControlLoopPolicyBuilderImpl.java
new file mode 100644
index 000000000..be34a0a24
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/ControlLoopPolicyBuilderImpl.java
@@ -0,0 +1,383 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder.impl;
+
+import java.util.LinkedList;
+import java.util.Map;
+import java.util.UUID;
+
+import org.openecomp.policy.controlloop.compiler.CompilerException;
+import org.openecomp.policy.controlloop.compiler.ControlLoopCompiler;
+import org.openecomp.policy.controlloop.compiler.ControlLoopCompilerCallback;
+import org.openecomp.policy.controlloop.policy.ControlLoop;
+import org.openecomp.policy.controlloop.policy.ControlLoopPolicy;
+import org.openecomp.policy.controlloop.policy.FinalResult;
+import org.openecomp.policy.controlloop.policy.OperationsAccumulateParams;
+import org.openecomp.policy.controlloop.policy.Policy;
+import org.openecomp.policy.controlloop.policy.PolicyResult;
+import org.openecomp.policy.controlloop.policy.Target;
+import org.openecomp.policy.controlloop.policy.builder.BuilderException;
+import org.openecomp.policy.controlloop.policy.builder.ControlLoopPolicyBuilder;
+import org.openecomp.policy.controlloop.policy.builder.MessageLevel;
+import org.openecomp.policy.controlloop.policy.builder.Results;
+import org.yaml.snakeyaml.DumperOptions;
+import org.yaml.snakeyaml.DumperOptions.FlowStyle;
+import org.yaml.snakeyaml.Yaml;
+
+public class ControlLoopPolicyBuilderImpl implements ControlLoopPolicyBuilder {
+
+	private ControlLoopPolicy policy;
+	
+	public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout) throws BuilderException {
+		policy = new ControlLoopPolicy();
+		policy.controlLoop = new ControlLoop();
+		policy.controlLoop.controlLoopName = controlLoopName;
+		policy.controlLoop.timeout = timeout;
+	}
+	
+	@Override
+	public ControlLoopPolicyBuilder setAbatement(Boolean abatement) throws BuilderException{
+		if (abatement == null) {
+			throw new BuilderException("abatement must not be null");
+		}
+		policy.controlLoop.abatement = abatement;
+		return this;
+	}
+	
+	@Override
+	public ControlLoopPolicyBuilder	setTimeout(Integer timeout) {
+		policy.controlLoop.timeout = timeout;
+		return this;
+	}
+	
+	@Override
+	public Policy setTriggerPolicy(String name, String description, String actor, Target target, String recipe,
+			Map<String, String> payload, Integer retries, Integer timeout) throws BuilderException {
+		
+		Policy trigger = new Policy(UUID.randomUUID().toString(), name, description, actor, payload, target, recipe, retries, timeout);
+		
+		policy.controlLoop.trigger_policy = trigger.id;
+		
+		this.addNewPolicy(trigger);
+		//
+		// Return a copy of the policy
+		//
+		return new Policy(trigger);
+	}
+
+	@Override
+	public Policy setPolicyForPolicyResult(String name, String description, String actor,
+			Target target, String recipe, Map<String, String> payload, Integer retries, Integer timeout, String policyID, PolicyResult... results) throws BuilderException {
+		//
+		// Find the existing policy
+		//
+		Policy existingPolicy = this.findPolicy(policyID);
+		if (existingPolicy == null) {
+			throw new BuilderException("Unknown policy " + policyID);
+		}
+		//
+		// Create the new Policy
+		//
+		Policy newPolicy = new Policy(UUID.randomUUID().toString(), name, description, actor, payload, target, recipe, retries, timeout);
+		//
+		// Connect the results
+		//
+		for (PolicyResult result : results) {
+			switch (result) {
+			case FAILURE:
+				existingPolicy.failure = newPolicy.id;
+				break;
+			case FAILURE_EXCEPTION:
+				existingPolicy.failure_exception = newPolicy.id;
+				break;
+			case FAILURE_RETRIES:
+				existingPolicy.failure_retries = newPolicy.id;
+				break;
+			case FAILURE_TIMEOUT:
+				existingPolicy.failure_timeout = newPolicy.id;
+				break;
+			case FAILURE_GUARD:
+				existingPolicy.failure_guard = newPolicy.id;
+				break;
+			case SUCCESS:
+				existingPolicy.success = newPolicy.id;
+				break;
+			default:
+				throw new BuilderException("Invalid PolicyResult " + result);
+			}
+		}
+		//
+		// Add it to our list
+		//
+		this.policy.policies.add(newPolicy);
+		//
+		// Return a policy to them
+		//
+		return new Policy(newPolicy);
+	}
+	
+	private class BuilderCompilerCallback implements ControlLoopCompilerCallback {
+
+		public ResultsImpl results = new ResultsImpl();
+		
+		@Override
+		public boolean onWarning(String message) {
+			results.addMessage(new MessageImpl(message, MessageLevel.WARNING));
+			return false;
+		}
+
+		@Override
+		public boolean onError(String message) {
+			results.addMessage(new MessageImpl(message, MessageLevel.ERROR));
+			return false;
+		}
+	}
+
+	@Override
+	public Results	buildSpecification() {
+		//
+		// Dump the specification
+		//
+		DumperOptions options = new DumperOptions();
+		options.setDefaultFlowStyle(FlowStyle.BLOCK);
+		options.setPrettyFlow(true);
+		Yaml yaml = new Yaml(options);
+		String dumpedYaml = yaml.dump(policy);
+		//
+		// This is our callback class for our compiler
+		//
+		BuilderCompilerCallback callback = new BuilderCompilerCallback();
+		//
+		// Compile it
+		//
+		try {
+			ControlLoopCompiler.compile(policy, callback);
+		} catch (CompilerException e) {
+			callback.results.addMessage(new MessageImpl(e.getMessage(), MessageLevel.EXCEPTION));
+		}
+		//
+		// Save the spec
+		//
+		callback.results.setSpecification(dumpedYaml);
+		return callback.results;
+	}
+
+	private void addNewPolicy(Policy policy) {
+		if (this.policy.policies == null) {
+			this.policy.policies = new LinkedList<Policy>();
+		}
+		this.policy.policies.add(policy);
+	}
+	
+	private Policy findPolicy(String id) {
+		for (Policy policy : this.policy.policies) {
+			if (policy.id.equals(id)) {
+				return policy;
+			}
+		}
+		return null;
+	}
+
+	@Override
+	public Integer calculateTimeout() {
+		int sum = 0;
+        for (Policy policy : this.policy.policies) {
+            sum += policy.timeout.intValue();
+        }
+        return new Integer(sum);
+	}
+
+	@Override
+	public ControlLoop setTriggerPolicy(String id) throws BuilderException {
+		if (id == null) {
+            throw new BuilderException("Id must not be null");
+        }
+	    Policy trigger = this.findPolicy(id);
+        if (trigger == null) {
+            throw new BuilderException("Unknown policy " + id);
+        }
+        else {
+            this.policy.controlLoop.trigger_policy = id;
+        }
+        return new ControlLoop(this.policy.controlLoop);
+    }
+
+	@Override
+	public boolean isOpenLoop() {
+        if (this.policy.controlLoop.trigger_policy.equals(FinalResult.FINAL_OPENLOOP.toString())) {
+            return true;
+        }	
+        else {
+            return false;
+        }
+	}
+
+	@Override
+	public Policy getTriggerPolicy() throws BuilderException {
+	    if (this.policy.controlLoop.trigger_policy.equals(FinalResult.FINAL_OPENLOOP.toString())) {
+            return null;
+        }
+        else {
+            Policy trigger = new Policy(this.findPolicy(this.policy.controlLoop.trigger_policy));
+            return trigger;
+        }
+    }
+
+	@Override
+	public ControlLoop getControlLoop() {
+		ControlLoop loop = new ControlLoop(this.policy.controlLoop);
+		return loop;
+	}
+
+	@Override
+	public Policy setPolicyForPolicyResult(String policyResultID, String policyID, PolicyResult... results)
+			throws BuilderException {
+		//
+        // Find the existing policy
+        //
+        Policy existingPolicy = this.findPolicy(policyID);
+        if (existingPolicy == null) {
+            throw new BuilderException(policyID + " does not exist");
+        }
+        if (this.findPolicy(policyResultID) == null) {
+            throw new BuilderException("Operational policy " + policyResultID + " does not exist");
+        }
+        //
+        // Connect the results
+        //
+        for (PolicyResult result : results) {
+            switch (result) {
+            case FAILURE:
+                existingPolicy.failure = policyResultID;
+                break;
+            case FAILURE_EXCEPTION:
+                existingPolicy.failure_exception = policyResultID;
+                break;
+            case FAILURE_RETRIES:
+            	existingPolicy.failure_retries = policyResultID;
+            	break;
+            case FAILURE_TIMEOUT:
+            	existingPolicy.failure_timeout = policyResultID;
+            	break;
+            case FAILURE_GUARD:
+            	existingPolicy.failure_guard = policyResultID;
+            	break;
+            case SUCCESS:
+            	existingPolicy.success = policyResultID;
+            	break;
+            default:
+            	throw new BuilderException("Invalid PolicyResult " + result);
+            }
+        }
+        return new Policy(this.findPolicy(policyResultID));
+	}
+
+	@Override
+	public boolean removePolicy(String policyID) throws BuilderException {
+		Policy existingPolicy = this.findPolicy(policyID);
+        if (existingPolicy == null) {
+            throw new BuilderException("Unknown policy " + policyID);
+        }
+        //
+        // Check if the policy to remove is trigger_policy
+        //
+        if (this.policy.controlLoop.trigger_policy.equals(policyID)) {
+            this.policy.controlLoop.trigger_policy = FinalResult.FINAL_OPENLOOP.toString();
+        }
+        else {
+            //
+            // Update policies
+            //
+            for (Policy policy : this.policy.policies) {
+                int index = this.policy.policies.indexOf(policy);
+                if (policy.success.equals(policyID)) {
+                    policy.success = FinalResult.FINAL_SUCCESS.toString();
+                }
+                if (policy.failure.equals(policyID)) {
+                    policy.failure = FinalResult.FINAL_FAILURE.toString();
+                }
+                if (policy.failure_retries.equals(policyID)) {
+                    policy.failure_retries = FinalResult.FINAL_FAILURE_RETRIES.toString();
+                }
+                if (policy.failure_timeout.equals(policyID)) {
+                    policy.failure_timeout = FinalResult.FINAL_FAILURE_TIMEOUT.toString();
+                }
+                if (policy.failure_exception.equals(policyID)) {
+                    policy.failure_exception = FinalResult.FINAL_FAILURE_EXCEPTION.toString();
+                }
+                if (policy.failure_guard.equals(policyID)) {
+                    policy.failure_guard = FinalResult.FINAL_FAILURE_GUARD.toString();
+                }
+                this.policy.policies.set(index, policy);
+            }
+        }
+        //
+        // remove the policy
+        //
+        boolean removed = this.policy.policies.remove(existingPolicy);
+        return removed;
+	}
+
+	@Override
+	public Policy resetPolicyResults(String policyID) throws BuilderException {
+        Policy existingPolicy = this.findPolicy(policyID);
+        if (existingPolicy == null) {
+            throw new BuilderException("Unknown policy " + policyID);
+        }
+        //
+        // reset policy results
+        //
+        existingPolicy.success = FinalResult.FINAL_SUCCESS.toString();
+        existingPolicy.failure = FinalResult.FINAL_FAILURE.toString();
+        existingPolicy.failure_retries = FinalResult.FINAL_FAILURE_RETRIES.toString();
+        existingPolicy.failure_timeout = FinalResult.FINAL_FAILURE_TIMEOUT.toString();
+        existingPolicy.failure_exception = FinalResult.FINAL_FAILURE_EXCEPTION.toString();
+        existingPolicy.failure_guard = FinalResult.FINAL_FAILURE_GUARD.toString();
+        return new Policy(existingPolicy);
+	}
+
+	@Override
+	public ControlLoopPolicyBuilder removeAllPolicies() {
+		//
+        // Remove all existing operational policies
+        //
+        this.policy.policies.clear();
+        //
+        // Revert controlLoop back to an open loop
+        //
+        this.policy.controlLoop.trigger_policy = FinalResult.FINAL_OPENLOOP.toString();
+        return this;
+	}
+	
+	@Override
+	public Policy addOperationsAccumulateParams(String policyID, OperationsAccumulateParams operationsAccumulateParams) throws BuilderException {
+		Policy existingPolicy = this.findPolicy(policyID);
+        if (existingPolicy == null) {
+            throw new BuilderException("Unknown policy " + policyID);
+        }
+        //
+        // Add operationsAccumulateParams to existingPolicy
+        //
+        existingPolicy.operationsAccumulateParams = operationsAccumulateParams;
+        return new Policy(existingPolicy);
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/MessageImpl.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/MessageImpl.java
new file mode 100644
index 000000000..3938aa899
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/MessageImpl.java
@@ -0,0 +1,46 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder.impl;
+
+import org.openecomp.policy.controlloop.policy.builder.Message;
+import org.openecomp.policy.controlloop.policy.builder.MessageLevel;
+
+public class MessageImpl implements Message {
+	
+	private String message;
+	private MessageLevel level;
+	
+	public MessageImpl(String message, MessageLevel level) {
+		this.message = message;
+		this.level = level;
+	}
+
+	@Override
+	public String getMessage() {
+		return message;
+	}
+
+	@Override
+	public MessageLevel getLevel() {
+		return level;
+	}
+
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/ResultsImpl.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/ResultsImpl.java
new file mode 100644
index 000000000..f7941533c
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/builder/impl/ResultsImpl.java
@@ -0,0 +1,55 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.builder.impl;
+
+import java.util.LinkedList;
+import java.util.List;
+
+import org.openecomp.policy.controlloop.policy.builder.Message;
+import org.openecomp.policy.controlloop.policy.builder.Results;
+
+public class ResultsImpl implements Results {
+	
+	private String specification;
+	private List<Message>	messages = new LinkedList<Message>();
+
+	@Override
+	public List<Message> getMessages() {
+		return messages;
+	}
+
+	@Override
+	public String getSpecification() {
+		return specification;
+	}
+
+	@Override
+	public boolean isValid() {
+		return (this.specification != null);
+	}
+
+	public void addMessage(Message message) {
+		this.messages.add(message);
+	}
+	
+	public void setSpecification(String spec) {
+		this.specification = spec;
+	}
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/Constraint.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/Constraint.java
new file mode 100644
index 000000000..7d7991787
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/Constraint.java
@@ -0,0 +1,140 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.guard;
+
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+
+public class Constraint {
+
+	public Integer num;
+	public String duration;
+	public Map<String, String> time_in_range;
+	
+	public LinkedList<String> blacklist;
+	
+	public Constraint() {
+		
+	}
+	
+	public Constraint(Integer num, String duration) {
+		this.num = num;
+		this.duration = duration;
+	}
+	
+	public Constraint(List<String> blacklist) {
+		this.blacklist = new LinkedList<String>(blacklist);
+		
+	}
+	
+	public Constraint(Integer num, String duration, Map<String, String> time_in_range) {
+		this(num, duration);
+		if (time_in_range != null) {
+			this.time_in_range = Collections.unmodifiableMap(time_in_range);
+		}
+	}
+	
+	public Constraint(Integer num, String duration, List<String> blacklist) {
+		this.num = num;
+		this.duration = duration;
+		this.blacklist = new LinkedList<String>(blacklist);
+	}
+	
+	public Constraint(Integer num, String duration, Map<String, String> time_in_range, List<String> blacklist) {
+		this(num, duration);
+		if (time_in_range != null) {
+			this.time_in_range = Collections.unmodifiableMap(time_in_range);
+		}
+		this.blacklist = new LinkedList<String>(blacklist);
+	}
+	
+	public Constraint(Constraint constraint) {
+		this.num = constraint.num;
+		this.duration = constraint.duration;
+		if (constraint.time_in_range != null) {
+			this.time_in_range = Collections.unmodifiableMap(constraint.time_in_range);
+		}
+		this.blacklist = new LinkedList<String>(constraint.blacklist);
+	}
+	
+	public boolean isValid() {
+		try {
+			if (num == null && duration != null) {
+				throw new NullPointerException();
+			}
+			if (duration == null && num != null) {
+				throw new NullPointerException();
+			}
+		} catch (Exception e) {
+			return false;
+		}
+		return true;
+	}
+	
+	@Override
+	public String toString() {
+		return "Constraint [num=" + num + ", duration=" + duration + ", time_in_range=" + time_in_range + ", blacklist=" + blacklist + "]";
+	}
+
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((num == null) ? 0 : num.hashCode());
+		result = prime * result + ((duration == null) ? 0 : duration.hashCode());
+		result = prime * result + ((time_in_range == null) ? 0 : time_in_range.hashCode());
+		result = prime * result + ((blacklist == null) ? 0 : blacklist.hashCode());
+		return result;
+	}
+
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		Constraint other = (Constraint) obj;
+		if (num == null) {
+			if (other.num != null) 
+				return false;
+		} else if (!num.equals(other.num))
+			return false;
+		if (duration == null) {
+			if (other.duration != null)
+				return false;
+		} else if (!duration.equals(other.duration))
+			return false;
+		if (time_in_range == null) {
+			if (other.time_in_range != null)
+				return false;
+		} else if (!time_in_range.equals(other.time_in_range))
+			return false;
+		if (blacklist == null) {
+			if (other.blacklist != null)
+				return false;
+		} else if (!blacklist.equals(other.blacklist))
+			return false;
+		return true;
+	}
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/ControlLoopGuard.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/ControlLoopGuard.java
new file mode 100644
index 000000000..37fd431a0
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/ControlLoopGuard.java
@@ -0,0 +1,76 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.guard;
+
+import java.util.LinkedList;
+
+public class ControlLoopGuard {
+	
+	public Guard guard;
+	
+	public LinkedList<GuardPolicy> guards;
+	
+	public ControlLoopGuard() {
+		
+	}
+	
+	public ControlLoopGuard(ControlLoopGuard CLGuard) {
+		this.guard = new Guard();
+		this.guards = new LinkedList<GuardPolicy>(CLGuard.guards);
+	}
+	
+	@Override
+	public String toString() {
+		return "Guard [guard=" + guard + ", GuardPolicies=" + guards + "]";
+	}
+
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((guard == null) ? 0 : guard.hashCode());
+		result = prime * result + ((guards == null) ? 0 : guards.hashCode());
+		return result;
+	}
+
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		ControlLoopGuard other = (ControlLoopGuard) obj;
+		if (guard == null) {
+			if (other.guard != null)
+				return false;
+		} else if (!guard.equals(other.guard))
+			return false;
+		if (guards == null) {
+			if (other.guards != null)
+				return false;
+		} else if (!guards.equals(other.guards))
+			return false;
+		return true;
+	}
+
+	
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/Guard.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/Guard.java
new file mode 100644
index 000000000..f3e765107
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/Guard.java
@@ -0,0 +1,59 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.guard;
+
+public class Guard {
+
+	public static String VERSION = "2.0.0";
+	
+	public final String version = VERSION;
+	
+	public Guard() {
+		
+	}
+	
+	@Override
+	public String toString() {
+		return "Guard [version=" + version + "]";
+	}
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((version == null) ? 0 : version.hashCode());
+		return result;
+	}
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		Guard other = (Guard) obj;
+		if (version == null) {
+			if (other.version != null)
+				return false;
+		} else if (!version.equals(other.version))
+			return false;
+		return true;
+	}
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/GuardPolicy.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/GuardPolicy.java
new file mode 100644
index 000000000..0195fac17
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/GuardPolicy.java
@@ -0,0 +1,166 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.guard;
+
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.UUID;
+
+public class GuardPolicy {
+
+	public String id = UUID.randomUUID().toString();
+	public String name;
+	public String description;
+	public String actor;
+	public String recipe;
+	public LinkedList<Constraint> limit_constraints;
+	
+	public GuardPolicy() {
+		
+	}
+	
+	public GuardPolicy(String id) {
+		this.id = id;
+	}
+	
+	public GuardPolicy(String name, String actor, String recipe) {
+		this.name = name;
+		this.actor = actor;
+		this.recipe = recipe;
+	}
+	
+	public GuardPolicy(String id, String name, String description, String actor, String recipe) {
+		this(name, actor, recipe);
+		this.id = id;
+		this.description = description;
+	}
+	
+	public GuardPolicy(String name, String actor, String recipe, List<Constraint> limit_constraints) {
+		this(name, actor, recipe);
+		if (limit_constraints != null) {
+			this.limit_constraints = (LinkedList<Constraint>) Collections.unmodifiableList(limit_constraints);
+		}
+	}
+	
+	public GuardPolicy(String name, String description, String actor, String recipe, List<Constraint> limit_constraints) {
+		this(name, actor, recipe, limit_constraints);
+		this.description = description;
+	}
+	
+	public GuardPolicy(String id, String name, String description, String actor, String recipe, List<Constraint> limit_constraints) {
+		this(name, description, actor, recipe, limit_constraints);
+		this.id = id;
+	}
+	
+	public GuardPolicy(GuardPolicy policy) {
+		this.id = policy.id;
+		this.name = policy.name;
+		this.description = policy.description;
+		this.actor = policy.actor;
+		this.recipe = policy.recipe;
+		if (policy.limit_constraints != null) {
+			this.limit_constraints = (LinkedList<Constraint>) Collections.unmodifiableList(policy.limit_constraints);
+		}
+	}
+	
+	public boolean isValid() {
+		try {
+			if (id == null) {
+				throw new NullPointerException();
+			}
+			if (name == null) {
+				throw new NullPointerException();
+			}
+			if (actor == null) {
+				throw new NullPointerException();
+			}
+			if (recipe == null) {
+				throw new NullPointerException();
+			}
+		} catch (Exception e) {
+			return false;
+		}
+		return true;
+	}
+	
+	@Override
+	public String toString() {
+		return "Policy [id=" + id + ", name=" + name + ", description=" + description + ", actor=" + actor + ", recipe="
+				+ recipe + ", limit_constraints=" + limit_constraints + "]";
+	}
+
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((actor == null) ? 0 : actor.hashCode());
+		result = prime * result + ((description == null) ? 0 : description.hashCode());
+		result = prime * result + ((id == null) ? 0 : id.hashCode());
+		result = prime * result + ((name == null) ? 0 : name.hashCode());
+		result = prime * result + ((limit_constraints == null) ? 0 : limit_constraints.hashCode());
+		result = prime * result + ((recipe == null) ? 0 : recipe.hashCode());
+		return result;
+	}
+
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		GuardPolicy other = (GuardPolicy) obj;
+		if (actor == null) {
+			if (other.actor != null) 
+				return false;
+		} else if (!actor.equals(other.actor))
+			return false;
+		if (description == null) {
+			if (other.description != null)
+				return false;
+		} else if (!description.equals(other.description))
+			return false;
+		if (id == null) {
+			if (other.id != null)
+				return false;
+		} else if (!id.equals(other.id))
+			return false;
+		if (name == null) {
+			if (other.name != null)
+				return false;
+		} else if (!name.equals(other.name))
+			return false;
+		if (limit_constraints == null) {
+			if (other.limit_constraints != null)
+				return false;
+		} else if (!limit_constraints.equals(other.limit_constraints))
+			return false;
+		if (recipe == null) {
+			if (other.recipe != null)
+				return false;
+		} else if (!recipe.equals(other.recipe))
+			return false;
+		return true;
+	}
+	
+	
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/builder/ControlLoopGuardBuilder.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/builder/ControlLoopGuardBuilder.java
new file mode 100644
index 000000000..c09757db6
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/builder/ControlLoopGuardBuilder.java
@@ -0,0 +1,128 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.guard.builder;
+
+import org.openecomp.policy.controlloop.policy.builder.BuilderException;
+import org.openecomp.policy.controlloop.policy.builder.Results;
+import org.openecomp.policy.controlloop.policy.guard.Constraint;
+import org.openecomp.policy.controlloop.policy.guard.ControlLoopGuard;
+import org.openecomp.policy.controlloop.policy.guard.Guard;
+import org.openecomp.policy.controlloop.policy.guard.GuardPolicy;
+import org.openecomp.policy.controlloop.policy.guard.builder.impl.ControlLoopGuardBuilderImpl;
+
+public interface ControlLoopGuardBuilder {
+	
+	/**
+	 * Adds one or more guard policies to the Control Loop Guard
+	 * 
+	 * 
+	 * @param policies
+	 * @return 
+	 * @throws BuilderException
+	 */
+	public ControlLoopGuardBuilder	addGuardPolicy(GuardPolicy... policies) throws BuilderException;
+	
+	/**
+	 * Removes one or more guard policies from the Control Loop Guard
+	 * 
+	 * 
+	 * @param policies
+	 * @return 
+	 * @throws BuilderException
+	 */
+	public ControlLoopGuardBuilder	removeGuardPolicy(GuardPolicy... policies) throws BuilderException;
+	
+	/**
+	 * Removes all guard policies from the Control Loop Guard
+	 * 
+	 * 
+	 * @param 
+	 * @return 
+	 * @throws BuilderException
+	 */
+	public ControlLoopGuardBuilder	removeAllGuardPolicies() throws BuilderException;
+	
+	/**
+	 * Adds one or more time limit constraints to the guard policy
+	 * 
+	 * 
+	 * @param id (guard policy id)
+	 * @param constraints
+	 * @return 
+	 * @throws BuilderException
+	 */
+	public ControlLoopGuardBuilder	addLimitConstraint(String id, Constraint... constraints) throws BuilderException;
+	
+	/**
+	 * Removes one or more time limit constraints from the guard policy
+	 * 
+	 * 
+	 * @param id (guard policy id)
+	 * @param constraints
+	 * @return 
+	 * @throws BuilderException
+	 */
+	public ControlLoopGuardBuilder	removeLimitConstraint(String id, Constraint... constraints) throws BuilderException;
+	
+	/**
+	 * Removes all time limit constraints from the guard policy
+	 * 
+	 * 
+	 * @param id (guard policy id)
+	 * @return 
+	 * @throws BuilderException
+	 */
+	public ControlLoopGuardBuilder	removeAllLimitConstraints(String id) throws BuilderException;
+	
+	/**
+	 *  Simply return a copy of control loop guard
+	 *  
+	 *  @return ControlLoopGuard
+	 */
+	public ControlLoopGuard getControlLoopGuard();	
+	
+	/**
+	 * This will compile and build the YAML specification for the Control Loop Guard. Please iterate the Results object for details.
+	 * The Results object will contains warnings and errors. If the specification compiled successfully, you will be able to retrieve the
+	 * YAML.
+	 * 
+	 * @return Results
+	 */
+	public Results	buildSpecification();
+	
+	/**
+	 * The Factory is used to build a ControlLoopGuardBuilder implementation.
+	 *
+	 */
+	public static class Factory {
+		
+		/**
+		 * @param guard
+		 * @return ControlLoopGuardBuilder object
+		 * @throws BuilderException
+		 */
+		public static ControlLoopGuardBuilder	buildControlLoopGuard (Guard guard) throws BuilderException {
+			
+			ControlLoopGuardBuilder builder = new ControlLoopGuardBuilderImpl(guard);
+			
+			return builder;
+		}
+	}
+}
diff --git a/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/builder/impl/ControlLoopGuardBuilderImpl.java b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/builder/impl/ControlLoopGuardBuilderImpl.java
new file mode 100644
index 000000000..b119620e3
--- /dev/null
+++ b/ECOMP-ControlloopPolicy/src/main/java/org/openecomp/policy/controlloop/policy/guard/builder/impl/ControlLoopGuardBuilderImpl.java
@@ -0,0 +1,234 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.controlloop.policy.guard.builder.impl;
+
+import java.util.LinkedList;
+
+import org.openecomp.policy.controlloop.compiler.CompilerException;
+import org.openecomp.policy.controlloop.compiler.ControlLoopCompilerCallback;
+import org.openecomp.policy.controlloop.guard.compiler.ControlLoopGuardCompiler;
+import org.openecomp.policy.controlloop.policy.builder.BuilderException;
+import org.openecomp.policy.controlloop.policy.builder.MessageLevel;
+import org.openecomp.policy.controlloop.policy.builder.Results;
+import org.openecomp.policy.controlloop.policy.builder.impl.MessageImpl;
+import org.openecomp.policy.controlloop.policy.builder.impl.ResultsImpl;
+import org.openecomp.policy.controlloop.policy.guard.Constraint;
+import org.openecomp.policy.controlloop.policy.guard.ControlLoopGuard;
+import org.openecomp.policy.controlloop.policy.guard.Guard;
+import org.openecomp.policy.controlloop.policy.guard.GuardPolicy;
+import org.openecomp.policy.controlloop.policy.guard.builder.ControlLoopGuardBuilder;
+import org.yaml.snakeyaml.DumperOptions;
+import org.yaml.snakeyaml.DumperOptions.FlowStyle;
+import org.yaml.snakeyaml.Yaml;
+
+public class ControlLoopGuardBuilderImpl implements ControlLoopGuardBuilder {
+
+	private ControlLoopGuard CLGuard;
+	
+	public ControlLoopGuardBuilderImpl(Guard guard) {
+		CLGuard = new ControlLoopGuard();
+		CLGuard.guard = guard;
+	}
+	
+	@Override
+	public ControlLoopGuardBuilder addGuardPolicy(GuardPolicy... policies) throws BuilderException {
+		if (policies == null) {
+			throw new BuilderException("GuardPolicy must not be null");
+		}
+		for (GuardPolicy policy : policies) {
+			if (!policy.isValid()) {
+				throw new BuilderException("Invalid guard policy - some required fields are missing");
+			}
+			if (CLGuard.guards == null) {
+				CLGuard.guards = new LinkedList<GuardPolicy>();
+			}
+			CLGuard.guards.add(policy);
+		}
+		return this;
+	}
+
+	@Override
+	public ControlLoopGuardBuilder removeGuardPolicy(GuardPolicy... policies) throws BuilderException {
+		if (policies == null) {
+            throw new BuilderException("GuardPolicy must not be null");
+        }
+        if (CLGuard.guards == null) {
+            throw new BuilderException("No existing guard policies to remove");
+        }
+        for (GuardPolicy policy : policies) {
+        	if (!policy.isValid()) {
+				throw new BuilderException("Invalid guard policy - some required fields are missing");
+			}
+            boolean removed = CLGuard.guards.remove(policy);    
+            if (!removed) {
+                throw new BuilderException("Unknown guard policy: " + policy.name);
+            }
+        }
+        return this;
+	}
+
+	@Override
+	public ControlLoopGuardBuilder removeAllGuardPolicies() throws BuilderException {
+		CLGuard.guards.clear();
+        return this;
+	}
+
+	@Override
+	public ControlLoopGuardBuilder addLimitConstraint(String id, Constraint... constraints) throws BuilderException {
+		if (id == null) {
+			throw new BuilderException("The id of target guard policy must not be null");
+		}
+		if (constraints == null) {
+			throw new BuilderException("Constraint much not be null");
+		}
+		boolean exist = false;
+		for (GuardPolicy policy: CLGuard.guards) {
+			//
+			// We could have only one guard policy matching the id
+			//
+			if (policy.id.equals(id)) {
+				exist = true;
+				for (Constraint cons: constraints) {
+					if (!cons.isValid()) {
+						throw new BuilderException("Invalid guard constraint - some required fields are missing");
+					}
+					if (policy.limit_constraints == null) {
+						policy.limit_constraints = new LinkedList<Constraint>();
+					}
+					policy.limit_constraints.add(cons);
+				}
+				break;
+			}
+		}
+		if (exist == false) {
+			throw new BuilderException("No existing guard policy matching the id: " + id);
+		}
+		return this;
+	}
+
+	@Override
+	public ControlLoopGuardBuilder removeLimitConstraint(String id, Constraint... constraints) throws BuilderException {
+		if (id == null) {
+			throw new BuilderException("The id of target guard policy must not be null");
+		}
+		if (constraints == null) {
+			throw new BuilderException("Constraint much not be null");
+		}
+		boolean exist = false;
+		for (GuardPolicy policy: CLGuard.guards) {
+			//
+			// We could have only one guard policy matching the id
+			//
+			if (policy.id.equals(id)) {
+				exist = true;
+				for (Constraint cons: constraints) {
+					if (!cons.isValid()) {
+						throw new BuilderException("Invalid guard constraint - some required fields are missing");
+					}
+					boolean removed = policy.limit_constraints.remove(cons);
+					if (!removed) {
+						throw new BuilderException("Unknown guard constraint: " + cons);
+					}
+				}
+				break;
+			}
+		}
+		if (exist == false) {
+			throw new BuilderException("No existing guard policy matching the id: " + id);
+		}
+		return this;
+	}
+
+	@Override
+	public ControlLoopGuardBuilder removeAllLimitConstraints(String id) throws BuilderException {
+		if (CLGuard.guards == null || CLGuard.guards.isEmpty()) {
+			throw new BuilderException("No guard policies exist");
+		} 
+		if (id == null) {
+			throw new BuilderException("The id of target guard policy must not be null");
+		}
+		boolean exist = false;
+		for (GuardPolicy policy: CLGuard.guards) {
+			if (policy.id.equals(id)) {
+				exist = true;
+				policy.limit_constraints.clear();
+			}
+		}
+		if (exist == false) {
+			throw new BuilderException("No existing guard policy matching the id: " + id);
+		}
+		return this;
+	}
+
+	
+	private class BuilderCompilerCallback implements ControlLoopCompilerCallback {
+
+		public ResultsImpl results = new ResultsImpl();
+		
+		@Override
+		public boolean onWarning(String message) {
+			results.addMessage(new MessageImpl(message, MessageLevel.WARNING));
+			return false;
+		}
+
+		@Override
+		public boolean onError(String message) {
+			results.addMessage(new MessageImpl(message, MessageLevel.ERROR));
+			return false;
+		}
+	}
+	
+	@Override
+	public ControlLoopGuard getControlLoopGuard() {
+		ControlLoopGuard guard = new ControlLoopGuard(this.CLGuard);
+		return guard;
+	}	
+	
+	
+	@Override
+	public Results buildSpecification() {
+		//
+		// Dump the specification
+		//
+		DumperOptions options = new DumperOptions();
+		options.setDefaultFlowStyle(FlowStyle.BLOCK);
+		options.setPrettyFlow(true);
+		Yaml yaml = new Yaml(options);
+		String dumpedYaml = yaml.dump(CLGuard);
+		//
+		// This is our callback class for our compiler
+		//
+		BuilderCompilerCallback callback = new BuilderCompilerCallback();
+		//
+		// Compile it
+		//
+		try {
+			ControlLoopGuardCompiler.compile(CLGuard, callback);
+		} catch (CompilerException e) {
+			callback.results.addMessage(new MessageImpl(e.getMessage(), MessageLevel.EXCEPTION));
+		}
+		//
+		// Save the spec
+		//
+		callback.results.setSpecification(dumpedYaml);
+		return callback.results;
+	}
+
+}