summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorwangguirong <wangguirong@boco.com.cn>2017-10-31 15:08:11 +0800
committerwangguirong <wangguirong@boco.com.cn>2017-10-31 15:08:59 +0800
commit6d450e3957a62551fb52fa970b89251d6dde9982 (patch)
tree90334e0c416bb4c06dc178000128df4e7d62505c
parente83131c6c88c0faed86c3e6e0e8f653c01163b7b (diff)
Delete temp file
Change-Id: I0dcc6f771ae75f88de578762dcad5dde1fa531ed Issue-Id: VFC-548 Signed-off-by: wangguirong <wangguirong@boco.com.cn>
-rw-r--r--ems/boco/.classpath31
-rw-r--r--ems/boco/pom.xml5
-rw-r--r--ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java3
-rw-r--r--ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java9
-rw-r--r--ems/microservice-standalone/src/main/assembly/conf/emsdriver.yml9
5 files changed, 52 insertions, 5 deletions
diff --git a/ems/boco/.classpath b/ems/boco/.classpath
new file mode 100644
index 0000000..68d3e86
--- /dev/null
+++ b/ems/boco/.classpath
@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+ <classpathentry kind="src" output="target/classes" path="src/main/java">
+ <attributes>
+ <attribute name="optional" value="true"/>
+ <attribute name="maven.pomderived" value="true"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources">
+ <attributes>
+ <attribute name="maven.pomderived" value="true"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="src" output="target/test-classes" path="src/test/java">
+ <attributes>
+ <attribute name="optional" value="true"/>
+ <attribute name="maven.pomderived" value="true"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+ <attributes>
+ <attribute name="maven.pomderived" value="true"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/jdk1.8.0_144">
+ <attributes>
+ <attribute name="maven.pomderived" value="true"/>
+ </attributes>
+ </classpathentry>
+ <classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/ems/boco/pom.xml b/ems/boco/pom.xml
index a311d85..5d2b3a4 100644
--- a/ems/boco/pom.xml
+++ b/ems/boco/pom.xml
@@ -225,5 +225,10 @@
<artifactId>javax.json</artifactId>
<version>1.0.4</version>
</dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>1.7.5</version>
+ </dependency>
</dependencies>
</project>
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java
index b4cec85..d250378 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java
@@ -142,6 +142,7 @@ public class TaskThread implements Runnable{
if (parseResult){
log.info("parser "+tempfile+" sucess");
+ tempfile.delete();
}else {
log.info("parser "+tempfile+" fail");
}
@@ -811,6 +812,7 @@ public class TaskThread implements Runnable{
try {
File decompressFile = deGz(fileName);
filelist.add(decompressFile);
+ new File(fileName).delete();
} catch (IOException e) {
log.error("decompressed is fail "+StringUtil.getStackTrace(e));
}
@@ -818,6 +820,7 @@ public class TaskThread implements Runnable{
{
try {
File[] files = deZip(new File(fileName));
+ new File(fileName).delete();
for(File temp :files){
filelist.add(temp);
}
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java
index 9c8802f..4a3ec75 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java
@@ -31,6 +31,7 @@ import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannelFactory;
import com.alibaba.fastjson.JSONObject;
import evel_javalibrary.att.com.AgentMain;
+import evel_javalibrary.att.com.AgentMain.EVEL_ERR_CODES;
import evel_javalibrary.att.com.EvelFault;
import evel_javalibrary.att.com.EvelFault.EVEL_SEVERITIES;
import evel_javalibrary.att.com.EvelFault.EVEL_SOURCE_TYPES;
@@ -71,12 +72,12 @@ public class NorthMessageMgr extends DriverThread{
log.info("AgentMain.evel_initialize start event_api_url=["+event_api_url+"]port=["+port+"]path=["+path+"]"
+ "topic=["+topic+"]username=["+username+"]password=["+password+"]level=["+level+"]");
try{
- AgentMain.evel_initialize(event_api_url, Integer.parseInt(port),
+ EVEL_ERR_CODES evecode = AgentMain.evel_initialize(event_api_url, Integer.parseInt(port),
path,topic,
username,
password,
level);
- log.info("AgentMain.evel_initialize sucess ");
+ log.info("AgentMain.evel_initialize sucess EVEL_ERR_CODES="+evecode);
} catch( Exception e ){
log.error("AgentMain.evel_initialize fail ",e);
}catch( Error e1 ){
@@ -94,7 +95,7 @@ public class NorthMessageMgr extends DriverThread{
new CollectMessageRecv().start();
- log.error("NorthMessageMgr start sucess ");
+ log.info("NorthMessageMgr start sucess ");
}
@@ -309,7 +310,7 @@ public class NorthMessageMgr extends DriverThread{
private EvelScalingMeasurement resultEvelScalingMeasurement(Map<String,String> reMap) {
String evname = "Mfvs_"+reMap.get("ElementType")+reMap.get("ObjectType");
- String evid = reMap.get("startTime")+reMap.get("ObjectType")+reMap.get("rmUID");
+ String evid = reMap.get("StartTime")+reMap.get("ObjectType")+reMap.get("rmUID");
int Period = Integer.parseInt(reMap.get("Period")!=null?reMap.get("Period"):"15");
EvelScalingMeasurement sm = new EvelScalingMeasurement(Period,evname, evid);
diff --git a/ems/microservice-standalone/src/main/assembly/conf/emsdriver.yml b/ems/microservice-standalone/src/main/assembly/conf/emsdriver.yml
index 5b82754..5660fcd 100644
--- a/ems/microservice-standalone/src/main/assembly/conf/emsdriver.yml
+++ b/ems/microservice-standalone/src/main/assembly/conf/emsdriver.yml
@@ -1,5 +1,5 @@
-# Copyright 2017 CMCC Technologies Co., Ltd
+# Copyright 2017 CMCC Technologies Co. Ltd
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
@@ -53,6 +53,13 @@ logging:
archivedLogFilenamePattern: ./logs/emsdriver-%d{yyyyMMdd}-%d{HHmm}-%d{ssSSS}.log.gz
archivedFileCount: 7
timeZone: PRC
+ - type: file
+ threshold: ERROR
+ logFormat: "%-4level [%d{yyyy-MM-dd HH:mm:ss.SSS}] [%thread] %logger{5} - %X{code} %msg %n"
+ currentLogFilename: ./logs/error.log
+ archivedLogFilenamePattern: ./logs/error-%d{yyyyMMdd}-%d{HHmm}-%d{ssSSS}.log.gz
+ archivedFileCount: 7
+ timeZone: PRC