activetaskdaemon2.java

利用Java Socket写的一段通讯协议

package com.ict.netcom2.kernel;

import java.io.Serializable;

import com.ict.netcom2.message.GetResultAck;
import com.ict.netcom2.message.TaskStatusNotify;
import com.ict.netcom2.net.Communicator2;
import com.ict.netcom2.result.ResultManager2;
import com.ict.netcom2.task.Task;
import com.ict.netcom2.task.TaskManager;

public class ActiveTaskDaemon2 {

	TaskManager tm;
	Communicator2 comm;
	ResultManager2 rm;
	
	public ActiveTaskDaemon2(TaskManager tm, Communicator2 comm, ResultManager2 rm) {
		this.tm = tm;
		this.comm = comm;
		this.rm = rm;
	}
	
	public void storeActiveTaskResult(String ip, TaskStatusNotify ntf) {
		Task task = tm.getTask(ntf.taskId);
		GetResultAck ack = comm.getResult(task);
		rm.storeResult(ack);
	}

}