<artifactId>jersey-server</artifactId>
<version>${jersey.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.glassfish.jersey.ext</groupId>
+ <artifactId>jersey-entity-filtering</artifactId>
+ <version>${jersey.version}</version>
+ </dependency>
<dependency>
<groupId>org.glassfish.jersey.containers</groupId>
<artifactId>jersey-container-servlet-core</artifactId>
import org.onap.holmes.common.dmaap.entity.PolicyMsg;
import org.onap.holmes.common.dmaap.DmaapService;
import org.onap.holmes.common.utils.DroolsLog;
-import org.onap.holmes.common.dropwizard.ioc.utils.ServiceLocatorHolder;
+import org.onap.holmes.common.utils.SpringContextUtil;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
+import com.google.gson.JsonObject;
import java.util.List;
import java.util.Map;
function Map<String, Object> getAdditionalResourceInfo(String networkId, String pnfName, String ifName, String status) {
AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
- JSONObject instance = aai.getServiceInstance(networkId, pnfName, ifName, status);
+ JsonObject instance = aai.getServiceInstance(networkId, pnfName, ifName, status);
Map<String, Object> ret = new HashMap<String, Object>();
- ret.put("service-instance.service-instance-id", instance.getString("service-instance-id"));
+ ret.put("service-instance.service-instance-id", instance.get("service-instance-id").getAsString());
ret.put("vserver.vserver-name", "TBD");
- ret.put("globalSubscriberId", instance.getString("globalSubscriberId"));
- ret.put("serviceType", instance.getString("serviceType"));
+ ret.put("globalSubscriberId", instance.get("globalSubscriberId").getAsString());
+ ret.put("serviceType", instance.get("serviceType").getAsString());
ret.put("network-information.network-id", networkId);
return ret;
// If any of the alarms have been marked as root, a policy message has ever been created and sent. Do NOT send it again.
if ($a.getRootFlag() != 1 && $b.getRootFlag() != 1) {
PolicyMsg msg = createPolicyMsg($a);
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);
dmaapService.publishPolicyMsg(msg, "dcae_cl_out");
updateAaiLinkStatus(getLogicLink($a), status);
}
import org.onap.holmes.common.dmaap.entity.PolicyMsg;
import org.onap.holmes.common.dmaap.DmaapService;
import org.onap.holmes.common.utils.DroolsLog;
- import org.onap.holmes.common.dropwizard.ioc.utils.ServiceLocatorHolder;
+ import org.onap.holmes.common.utils.SpringContextUtil;
- import com.alibaba.fastjson.JSONArray;
- import com.alibaba.fastjson.JSONObject;
+ import com.google.gson.JsonObject;
import java.util.List;
import java.util.Map;
function Map<String, Object> getAdditionalResourceInfo(VesAlarm a, String bandwidth) {
AaiQuery4Ccvpn2 aai = AaiQuery4Ccvpn2.newInstance();
- JSONObject instance = aai.getServiceInstance(getAdditionalField(a, "siteService"));
+ JsonObject instance = aai.getServiceInstance(getAdditionalField(a, "siteService"));
Map<String, Object> ret = new HashMap<String, Object>();
- ret.put("service-instance.service-instance-id", instance.getString("service-instance-id"));
+ ret.put("service-instance.service-instance-id", instance.get("service-instance-id").getAsString());
ret.put("vserver.vserver-name", "TBD");
- ret.put("globalSubscriberId", instance.getString("globalSubscriberId"));
- ret.put("serviceType", instance.getString("serviceType"));
+ ret.put("globalSubscriberId", instance.get("globalSubscriberId").getAsString());
+ ret.put("serviceType", instance.get("serviceType").getAsString());
ret.put("vserver.is-closed-loop-disabled", "false");
ret.put("vserver.prov-status", "ACTIVE");
ret.put("bandwidth", bandwidth);
ret.put("bandwidth-change-time", getAdditionalField(a, "timestamp"));
- ret.put("vnfId", instance.getString("vnfId"));
+ ret.put("vnfId", instance.get("vnfId").getAsString());
return ret;
}
bandwidth = "10000";
}
PolicyMsg msg = createPolicyMsg($a, bandwidth);
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);
dmaapService.publishPolicyMsg(msg, "dcae_cl_out");
$a.setRootFlag(1);
end
import org.onap.holmes.common.dmaap.entity.PolicyMsg;\r
import org.onap.holmes.common.dmaap.DmaapService;\r
import org.onap.holmes.common.utils.DroolsLog;\r
-import org.onap.holmes.common.dropwizard.ioc.utils.ServiceLocatorHolder;\r
+import org.onap.holmes.common.utils.SpringContextUtil;\r
import org.onap.holmes.common.dmaap.store.UniqueRequestIdCache;\r
\r
\r
m.setTarget("vserver.vserver-name");\r
m.setAai(getAaiObjectPolicy(serviceName, serviceInstanceId));\r
\r
- ServiceLocatorHolder.getLocator().getService(UniqueRequestIdCache.class).put(alarm.getEventId(), m.getRequestID());\r
+ SpringContextUtil.getBean(UniqueRequestIdCache.class).put(alarm.getEventId(), m.getRequestID());\r
return m;\r
}\r
\r
Map<String, String> map = processAlarm($a.getSourceId() + "-XPDR1");\r
for(Map.Entry<String,String> entry : map.entrySet()){\r
PolicyMsg msg = createPolicyMsg($a, entry.getKey(), entry.getValue());\r
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);\r
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);\r
dmaapService.publishPolicyMsg(msg, "dcae_cl_out");\r
DroolsLog.printInfo("Published to policy=" + msg.toString());\r
\r
Map<String, String> map = processAlarm($a.getEventId());\r
for(Map.Entry<String,String> entry : map.entrySet()){\r
PolicyMsg msg = createPolicyMsg($a, entry.getKey(), entry.getValue());\r
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);\r
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);\r
dmaapService.publishPolicyMsg(msg, "dcae_cl_out");\r
DroolsLog.printInfo("Published to policy=" + msg.toString());\r
\r
import org.onap.holmes.common.api.stat.VesAlarm;
import org.onap.holmes.common.aai.CorrelationUtil;
import org.onap.holmes.common.dmaap.entity.PolicyMsg;
-import org.onap.holmes.common.dropwizard.ioc.utils.ServiceLocatorHolder;
+import org.onap.holmes.common.utils.SpringContextUtil;
import org.onap.holmes.common.utils.DroolsLog;
$child : VesAlarm(eventId != $eventId, parentId == $eventId)
then
DroolsLog.printInfo("Root alarm: ID=" + $root.getEventId() + ", Event Name=" + $root.getEventName());
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);
PolicyMsg policyMsg = dmaapService.getPolicyMsg($root, $child, "org.onap.holmes.droolsRule");
dmaapService.publishPolicyMsg(policyMsg, "dcae_cl_out");
$root.setRootFlag(1);
eventName in ("Fault_MultiCloud_VMFailure"))
then
DroolsLog.printInfo("New alarm: ID=" + $root.getEventId() + ", Event Name=" + $root.getEventName());
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);
PolicyMsg policyMsg = dmaapService.getPolicyMsg($root, null, "org.onap.holmes.droolsRule");
dmaapService.publishPolicyMsg(policyMsg, "dcae_cl_out");
$root.setRootFlag(1);
$root : VesAlarm(alarmIsCleared == 1, rootFlag == 1)
then
DroolsLog.printInfo("Alarm cleared: ID=" + $root.getEventId() + ", Event Name=" + $root.getEventName());
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
+ DmaapService dmaapService = SpringContextUtil.getBean(DmaapService.class);
PolicyMsg policyMsg = dmaapService.getPolicyMsg($root, null, "org.onap.holmes.droolsRule");
dmaapService.publishPolicyMsg(policyMsg, "dcae_cl_out");
retract($root);