eventadapter.java

短信发送

/**
 * Created at Nov 10, 2008
 */
package com.jdev.net.event;

import com.jdev.net.queue.Request;
import com.jdev.net.queue.Response;
import com.jdev.util.Debug;

/**
 * <p>Title: EventAdapter</p>
 * <p>Description: 事件适配器</p>
 * @author Lawrence
 * @version 1.0
 */
public abstract class EventAdapter implements ServerListener {
	/* (non-Javadoc)
	 * @see com.jdev.net.event.ServerListener#onStatus(java.lang.String, int)
	 */
	public void onStatus(String key, int status) {
		Debug.logVerbose("-->onStatus["+key+"] status=" + status);						
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.ServerListener#onDebug(java.lang.String)
	 */
	public void onDebug(String msg) {
		Debug.logVerbose("-->onDebug["+msg+"]");				
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.ServerListener#onConnected()
	 */
	public void onConnected() throws Exception {
		Debug.logVerbose("-->onConnected");		
	}

	public EventAdapter() {
	}

	public void onError(String error) {
		Debug.logVerbose("-->Error:"+error);
	}

	public void onAccept() throws Exception {
		Debug.logVerbose("-->onAccept");
	}

	public void onAccepted(Request request) throws Exception {
		Debug.logVerbose("-->onAccepted:"+request.getAddress()+ " port=" + request.getPort());
	}

	public void onRead(Request request) throws Exception {
		if(request.getDataInput()!=null && request.getDataInput().length>0)
			Debug.logVerbose("-->onRead:"+ new String(request.getDataInput()));
		else
			Debug.logVerbose("-->onAccepted:"+request.getAddress()+ " port=" + request.getPort());
	}

	public void onWrite(Request request, Response response) throws Exception {
		if(response.getDataInput()!=null && response.getDataInput().length>0)
			Debug.logVerbose("-->onWrite:"+ new String(response.getDataInput()));
		else
			Debug.logVerbose("-->onWrite:"+request.getAddress()+ " port=" + request.getPort());
	}

	public void onClosed(Request request) throws Exception {
		Debug.logVerbose("-->onClosed:"+request.getAddress()+ " port=" + request.getPort());
	}
}