sendthread.java

中国电信ISMP管理平台SMS订购关系同步接口

package com.wireless.sms.ismp.global;

import java.util.Timer;
import java.util.TimerTask;

import com.wireless.sms.ismp.InitHandler;
import com.wireless.sms.pub.entity.MO;
import com.wireless.sms.pub.entity.Monitor;
import com.wireless.sms.pub.net.MOClientSocket;
import com.wireless.sms.pub.net.MonitorClientSocket;

public class SendThread {

	private static SendThread _instance = new SendThread();

	private Timer timer = null;

	public MOClientSocket moClientSocket = null;

	public static SendThread getInstance() {
		return _instance;
	}

	private SendThread() {
	}

	public void start() {
		if (timer == null) {
			LoggerConstant.mo_log.info("Start mo sender !");
			moClientSocket = new MOClientSocket(InitHandler.ROUTERHOST,
					InitHandler.ROUTERPORTS);
			timer = new Timer();
			timer.schedule(new TimerTask() {
				public void run() {
					MO mo = (MO) InitHandler.MOQUEUE.removeNoWait();
					if (mo != null) {
						boolean sendFlag = moClientSocket.sendMO(mo);

						if (sendFlag) {
							LoggerConstant.mo_log.info("发送 MO 成功 !");
						} else {
							InitHandler.MOQUEUE.add(mo);
							sendmonitor("R000101");
						}
					}
				}
			}, 5000, 500);
		}
	}

	public void stop() {
		if (timer != null) {
			timer.cancel();
			timer = null;
			LoggerConstant.mo_log.info("Stop mo sender !");
		}
	}

	public void sendmonitor(String code) {
		Monitor monitor = new Monitor();
		monitor.setErrorCode(code);
		monitor.setIp(InitHandler.PROCESSHOST);
		monitor.setPeriod("");
		monitor.setProcessName(InitHandler.switch_name);
		MonitorClientSocket errorsocket = new MonitorClientSocket(
				InitHandler.MONITORHOST, InitHandler.MONITORPORT);
		errorsocket.sendMonitor(monitor);
	}

}