import fang.device.DeviceMsgQueue;

import fang.device.DeviceRepo;

import fang.device.DeviceService;

public class Test {

public static void main(String[] args) throws InterruptedException {

//test DeviceMsg Decode function

// DeviceMsg deviceMsg = new DeviceMsg();

// String msg = "hdu12345&pm25:100,temperature:14,humidity:24";

// if(!deviceMsg.decode(msg))

// System.out.println("failed decode");

// System.out.println("decode success");

// deviceMsg.toString();

DeviceService.getInstance().startService();

while(true){

Thread.sleep(2000);

System.out.println("MsgQ:"+DeviceMsgQueue.getInstance().size());

System.out.println("Repo:"+DeviceRepo.getInstance().size());

}

}

}