From: yangyan <yangyanyj@chinamobile.com>
Date: Thu, 22 Mar 2018 09:45:01 +0000 (+0800)
Subject: solve test code bug
X-Git-Tag: v1.1.0~13^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=1b7527b26b653d95f53d7b033b58aca3444dde9e;p=vfc%2Fnfvo%2Fdriver%2Fems.git

solve test code bug

Issue-ID: VFC-836
Change-Id: I515675d31f3f19c63c36fd5d592dc3d44e3652ba
Signed-off-by: yangyan <yangyanyj@chinamobile.com>
---

diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java
index 6b2b6c8..1031ff9 100644
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java
@@ -27,15 +27,17 @@ public class AlarmTaskThreadTest {
 
 	private AlarmTaskThread taskThread;
 	private AlarmSocketServer server;
+	private Thread severThread;
 
 	@Before
 	public void setUp() throws IOException {
-		new Thread() {
+		severThread = new Thread(new Runnable(){
 			public void run() {
 				server = new AlarmSocketServer();
 				server.socketServer();
 			}
-		}.start();
+		});
+		severThread.start();
 		CollectVo collectVo = new CollectVo();
 		collectVo.setIP("127.0.0.1");
 		collectVo.setPort("12345");
@@ -73,16 +75,12 @@ public class AlarmTaskThreadTest {
 
 	@Test
 	public void runAlarmTaskThread() {
-		try {
-			taskThread.run();
-			Thread.sleep(10000);
-			taskThread.setStop(true);
+			taskThread.start();
+			//Thread.sleep(3000);
 			server.stop();
-		} catch (InterruptedException e) {
-			// TODO Auto-generated catch block
-			e.printStackTrace();
-		}
-
+			severThread.stop();
+			taskThread.setStop(true);
+			taskThread.close();
 	}
 
 }
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/HeartBeatTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/HeartBeatTest.java
index 2ffb589..d93f51f 100644
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/HeartBeatTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/HeartBeatTest.java
@@ -43,7 +43,7 @@ public class HeartBeatTest {
 			Socket socket = new Socket("127.0.0.1",12345);
 			Msg msg = MessageUtil.putHeartBeatMsg(1);
 			HeartBeat heartBeat = new HeartBeat(socket,msg);
-			heartBeat.run();
+			heartBeat.start();
 			Thread.sleep(10);
 			heartBeat.setStop(true);
 			server.stop();