Add Test Case

[vfc/nfvo/driver/ems.git] / ems / boco / src / test / java / org / onap / vfc / nfvo / emsdriver / collector / TaskThreadServiceTest.java

diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadServiceTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadServiceTest.java
index 76569ff..b22b260 100644 (file)
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadServiceTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadServiceTest.java
@@ -36,13 +36,30 @@ public class TaskThreadServiceTest {
        @Test
        public void add() {
                taskThreadService.add(collectMsg);
+               taskThreadService.size();
+               new Thread(){
+                       public void run() { 
+                           try {
+                                       Thread.sleep(10);
+                                       taskThreadService.stopTask();
+                               } catch (InterruptedException e) {
+                                       // TODO Auto-generated catch block
+                                       e.printStackTrace();
+                               }
+                       }
+               }.start();
+               taskThreadService.run();
+               
        }
 
        @Test
        public void receive() {
                taskThreadService.add(collectMsg);
                CollectMsg collectMsg = taskThreadService.receive();
+               
                assertNotNull(collectMsg);
        }
        
+       
+       
 }