cngpeventadapter.java

移动CMPP的网关,JAVA又一实现,非常完整的代码.

package com.grail.smproxy;

import com.grail.comm.cngp.CNGPConnection;
import com.grail.comm.cngp.CNGPTransaction;
import com.grail.comm.cngp.message.CNGPActiveTestMessage;
import com.grail.comm.cngp.message.CNGPDeliverMessage;
import com.grail.comm.cngp.message.CNGPExitRespMessage;
import com.grail.comm.cngp.message.CNGPMessage;
import com.grail.comm.core.PEventAdapter;
import com.grail.comm.core.PException;
import com.grail.comm.core.PLayer;

/**
 * <p>
 * Title: 短信 项目
 * </p>
 * <p>
 * Description:
 * </p>
 * <p>
 * Copyright: Copyright (c) 2004 合力阳光
 * </p>
 * <p>
 * Company: 合力阳光
 * </p>
 * 
 * @author ray/刘有为
 * @version 1.0
 */
class CNGPEventAdapter extends PEventAdapter {

  private CNGPSMProxy smProxy;
  private CNGPConnection conn;

  public CNGPEventAdapter(CNGPSMProxy smProxy) {
    this.smProxy = null;
    conn = null;
    this.smProxy = smProxy;
    conn = smProxy.getConn();
  }

  public void childCreated(PLayer child) {
    CNGPTransaction t = (CNGPTransaction) child;
    CNGPMessage msg = t.getResponse();
    CNGPMessage resmsg = null;
    if (msg.getRequestId() == 6) {
      resmsg = new CNGPExitRespMessage();
      smProxy.onTerminate();
    } else if (msg.getRequestId() == 3) {
      CNGPDeliverMessage tmpmes = (CNGPDeliverMessage) msg;
      resmsg = smProxy.onDeliver(tmpmes);
    } else if (msg.getRequestId() == 4) {
      System.out.println(" &&&&&&&&&&& 处理 CNGPActiveTestMessage &&&&&&&&&&");
      CNGPActiveTestMessage active=(CNGPActiveTestMessage)msg;
      resmsg=active;
    } else {
      t.close();
    }
    if (resmsg != null) {
      try {
        t.send(resmsg);
      } catch (PException e) {
        e.printStackTrace();
      }
      t.close();
    }
  }
}