smgpreader.java

来自「华为CNGP.CMPP.SGIP.CMPP源代码。」· Java 代码 · 共 66 行

// Decompiled by Jad v1.5.8f. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://www.kpdus.com/jad.html
// Decompiler options: packimports(3) 
// Source File Name:   SMGPReader.java

package com.huawei.insa2.comm.smgp;

import com.huawei.insa2.comm.PMessage;
import com.huawei.insa2.comm.PReader;
import com.huawei.insa2.comm.smgp.message.SMGPActiveTestMessage;
import com.huawei.insa2.comm.smgp.message.SMGPActiveTestRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPDeliverMessage;
import com.huawei.insa2.comm.smgp.message.SMGPExitMessage;
import com.huawei.insa2.comm.smgp.message.SMGPExitRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPForwardRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPLoginRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPMoRouteUpdateRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPMtRouteUpdateRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPQueryRespMessage;
import com.huawei.insa2.comm.smgp.message.SMGPSubmitRespMessage;
import java.io.*;

public class SMGPReader extends PReader
{

    public SMGPReader(InputStream is)
    {
        in = new DataInputStream(is);
    }

    public PMessage read()
        throws IOException
    {
        int total_Length = in.readInt();
        int command_Id = in.readInt();
        byte buf[] = new byte[total_Length - 8];
        in.readFully(buf);
        if(command_Id == 0x80000001)
            return new SMGPLoginRespMessage(buf);
        if(command_Id == 3)
            return new SMGPDeliverMessage(buf);
        if(command_Id == 0x80000002)
            return new SMGPSubmitRespMessage(buf);
        if(command_Id == 0x80000005)
            return new SMGPForwardRespMessage(buf);
        if(command_Id == 0x80000007)
            return new SMGPQueryRespMessage(buf);
        if(command_Id == 0x80000004)
            return new SMGPActiveTestRespMessage(buf);
        if(command_Id == 4)
            return new SMGPActiveTestMessage(buf);
        if(command_Id == 6)
            return new SMGPExitMessage(buf);
        if(command_Id == 0x80000006)
            return new SMGPExitRespMessage(buf);
        if(command_Id == 0x80000008)
            return new SMGPMtRouteUpdateRespMessage(buf);
        if(command_Id == 0x80000009)
            return new SMGPMoRouteUpdateRespMessage(buf);
        else
            return null;
    }

    protected DataInputStream in;
}