summaryrefslogtreecommitdiffstats
path: root/controlloop/templates/template.demo.clc/src/main/resources
diff options
context:
space:
mode:
authorshaoqiu <tim.huang@est.tech>2019-04-02 12:33:04 +0000
committerPamela Dragosh <pdragosh@research.att.com>2019-04-08 13:47:01 -0400
commite55d256a9eeb411bb485919eb4c1d449cbae5d46 (patch)
tree6694558deac959fe295b4148ceb4438f09ad65f9 /controlloop/templates/template.demo.clc/src/main/resources
parent93206cf9624df06a518a8016b965b9104e687f14 (diff)
update dependency to policy/models
Update the dependency of model-impl from drools-applications to policy/models. Issue-ID: POLICY-1264 Change-Id: I07fcb29501499a97689d2d27c845bf8e411e7825 Signed-off-by: shaoqiu <tim.huang@est.tech> Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>
Diffstat (limited to 'controlloop/templates/template.demo.clc/src/main/resources')
-rw-r--r--controlloop/templates/template.demo.clc/src/main/resources/__closedLoopControlName__.drl27
1 files changed, 23 insertions, 4 deletions
diff --git a/controlloop/templates/template.demo.clc/src/main/resources/__closedLoopControlName__.drl b/controlloop/templates/template.demo.clc/src/main/resources/__closedLoopControlName__.drl
index f2584c063..1d8e6c511 100644
--- a/controlloop/templates/template.demo.clc/src/main/resources/__closedLoopControlName__.drl
+++ b/controlloop/templates/template.demo.clc/src/main/resources/__closedLoopControlName__.drl
@@ -45,6 +45,7 @@ import org.onap.policy.appclcm.LcmCommonHeader;
import org.onap.policy.vfc.VfcRequest;
import org.onap.policy.vfc.VfcResponse;
import org.onap.policy.vfc.VfcManager;
+import org.onap.policy.so.SoManager;
import org.onap.policy.so.SoRequest;
import org.onap.policy.so.SoResponseWrapper;
import org.onap.policy.guard.PolicyGuard;
@@ -584,14 +585,32 @@ rule "${policyName}.EVENT.MANAGER.OPERATION.LOCKED.GUARD_PERMITTED"
if(request instanceof SoRequest) {
// Call SO. The response will be inserted into memory once it's received
- SoActorServiceProvider.sendRequest($event.getRequestId().toString(), drools.getWorkingMemory(),
- request);
- }
+ class mySoCallback implements SoManager.SoCallback {
+ public void onSoResponseWrapper(SoResponseWrapper wrapper) {
+ drools.getWorkingMemory().insert(wrapper);
+ }
+ }
+ SoActorServiceProvider.sendRequest($event.getRequestId().toString(),
+ new mySoCallback(),
+ request,
+ PolicyEngine.manager.getEnvironmentProperty("so.url"),
+ PolicyEngine.manager.getEnvironmentProperty("so.username"),
+ PolicyEngine.manager.getEnvironmentProperty("so.password")); }
break;
case "VFC":
if (request instanceof VfcRequest) {
// Start VFC thread
- Thread t = new Thread(new VfcManager(drools.getWorkingMemory(), (VfcRequest)request));
+ class myVfcCallback implements VfcManager.VfcCallback {
+ public void onResponse(VfcResponse responseError) {
+ drools.getWorkingMemory().insert(responseError);
+ }
+ };
+ // Start VFC thread
+ Thread t = new Thread(new VfcManager(new myVfcCallback(),
+ (VfcRequest)request,
+ PolicyEngine.manager.getEnvironmentProperty("vfc.url"),
+ PolicyEngine.manager.getEnvironmentProperty("vfc.username"),
+ PolicyEngine.manager.getEnvironmentProperty("vfc.password")));
t.start();
}
break;