cmpp30transaction.java

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

/*
 * Created on Mar 17, 2005
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package com.grail.comm.cmpp;

import com.grail.comm.cmpp.message.CMPPMessage;
import com.grail.comm.core.PException;
import com.grail.comm.core.PLayer;
import com.grail.comm.core.PMessage;
import com.grail.util.Debug;

/**
 * @author eclipse
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class CMPP30Transaction extends PLayer
{

    private CMPPMessage receive;
    private int sequenceId;

    public CMPP30Transaction(PLayer connection)
    {
        super(connection);
        sequenceId = id;
    }

    public synchronized void onReceive(PMessage msg)
    {
        receive = (CMPPMessage)msg;
        sequenceId = receive.getSequenceId();
        if(CMPPConstant.debug)
            Debug.dump(receive.toString());
        notifyAll();
    }

    public void send(PMessage message)
        throws PException
    {
        CMPPMessage mes = (CMPPMessage)message;
        mes.setSequenceId(sequenceId);
        parent.send(message);
        if(CMPPConstant.debug)
            Debug.dump(mes.toString());
    }

    public CMPPMessage getResponse()
    {
        return receive;
    }

    public synchronized void waitResponse()
    {
        if(receive == null)
            try
            {
                wait(((CMPP30Connection)parent).getTransactionTimeout());
            }
            catch(InterruptedException interruptedexception) { }
    }
}