Issue-ID: VFC-836
Change-Id: I515675d31f3f19c63c36fd5d592dc3d44e3652ba
Signed-off-by: yangyan <yangyanyj@chinamobile.com>
private AlarmTaskThread taskThread;
private AlarmSocketServer server;
private AlarmTaskThread taskThread;
private AlarmSocketServer server;
+ private Thread severThread;
@Before
public void setUp() throws IOException {
@Before
public void setUp() throws IOException {
+ severThread = new Thread(new Runnable(){
public void run() {
server = new AlarmSocketServer();
server.socketServer();
}
public void run() {
server = new AlarmSocketServer();
server.socketServer();
}
+ });
+ severThread.start();
CollectVo collectVo = new CollectVo();
collectVo.setIP("127.0.0.1");
collectVo.setPort("12345");
CollectVo collectVo = new CollectVo();
collectVo.setIP("127.0.0.1");
collectVo.setPort("12345");
@Test
public void runAlarmTaskThread() {
@Test
public void runAlarmTaskThread() {
- try {
- taskThread.run();
- Thread.sleep(10000);
- taskThread.setStop(true);
+ taskThread.start();
+ //Thread.sleep(3000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
+ severThread.stop();
+ taskThread.setStop(true);
+ taskThread.close();
Socket socket = new Socket("127.0.0.1",12345);
Msg msg = MessageUtil.putHeartBeatMsg(1);
HeartBeat heartBeat = new HeartBeat(socket,msg);
Socket socket = new Socket("127.0.0.1",12345);
Msg msg = MessageUtil.putHeartBeatMsg(1);
HeartBeat heartBeat = new HeartBeat(socket,msg);
Thread.sleep(10);
heartBeat.setStop(true);
server.stop();
Thread.sleep(10);
heartBeat.setStop(true);
server.stop();