cmppactivetest.java

短信平台CMPP30 的JAVA程序,(含SQL数据库)

// Decompiled by Jad v1.5.7g. Copyright 2000 Pavel Kouznetsov.
// Jad home page: http://www.geocities.com/SiliconValley/Bridge/8617/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi 
// Source File Name:   CMPPActiveTest.java

package com.cmpp3_0.process;

import com.cmpp3_0.body.Header;
import com.cmpp3_0.util.*;
import java.io.*;
import java.net.SocketException;

// Referenced classes of package com.cmpp3_0.process:
//            CMPPSocket, CMPPAPIs

public class CMPPActiveTest
{

    private byte headBytes[];
    private Header headContent;
    private CMPPSocket socket;

    public CMPPActiveTest(CMPPSocket socket)
    {
        headContent = new Header(12, 8, 0);
        this.socket = socket;
        headBytes = new byte[12];
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(headContent.getTotalLength()), headBytes, 0, 4, 0);
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(headContent.getCommandId()), headBytes, 0, 4, 4);
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(headContent.getSeqId()), headBytes, 0, 4, 8);
    }

    public int getSequenceId()
    {
        return headContent.getSeqId();
    }

    public int getTotalLength()
    {
        return headContent.getTotalLength();
    }

    public int sendActiveTest()
    {
        int result = 0;
        socket.out.write(headBytes);
        socket.out.flush();
        break MISSING_BLOCK_LABEL_80;
        SocketException se;
        se;
        Logger.writeLog(-2, "ACTIVETEST FAILURE: SOCKET_EXCEPTION!--可能是TCP/IP连接出现错误--链路将被断开-- 发送链路检测包失败!", "cmpp");
        result = -507;
        return result;
        IOException ie;
        ie;
        Logger.writeLog(-2, "ACTIVETEST FAILURE: IO_EXCEPTION! -- 发送链路检测包失败!", "cmpp");
        result = -116;
        return result;
        Exception e;
        e;
        Logger.writeLog(-2, "ACTIVETEST FAILURE: EXCEPTION! -- 发送链路检测包失败!", "cmpp");
        result = -118;
        return result;
        if(CMPPAPIs.isDebugMode())
            System.out.println(CTime.getStringDate() + " --发送了链路检测包!");
        return result;
    }

    public void setSequenceId(int seqId)
    {
        headContent.setSeqId(seqId);
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(seqId), headBytes, 0, 4, 8);
    }
}