reportrespcreator.java

短信开发用于文件交换处理转发的类模块

package com.sms.platform.switchcenter.inner.reportrespqueue;

import org.apache.mina.common.ByteBuffer;

import com.pub.berkeleydb.DefaultRecordCreator;
import com.sms.protocol.standard12.Standard_Inner_Response;

/**
 * 完成DatabaseEntry与ByteBuffer的相互转化
 * <p>Title: SmsSystem</p>
 *
 * <p>Description: SmsSystem</p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: Raywirless</p>
 *
 * @author Swan
 * @version 1.0
 */

public class ReportRespCreator extends DefaultRecordCreator {
	
//	public ReportRespCreator(){
//		super(32,128);
//	}

    public void toKey(ByteBuffer out, Object r) throws Exception {
        Standard_Inner_Response sr = (Standard_Inner_Response) r;
//        out.putString(sr.getMessageID(), 24, Message.charset.newEncoder());
        str2bytebuffer(out, sr.getMessageID(), 24);
        out.putInt(sr.getSrcClientID());
//        out.putLong(sr.getSequenceId());
    }

    public void fromKey(ByteBuffer in, Object r) throws Exception {
        Standard_Inner_Response sr = (Standard_Inner_Response) r;
//        sr.setMessageID(in.getString(24, Message.charset.newDecoder()));
        sr.setMessageID(bytebuffer2str(in,24));
        sr.setSrcClientID(in.getInt());
//        sr.setSequenceId(in.getLong());
    }

    public void toValue(ByteBuffer out, Object r) throws Exception {
        Standard_Inner_Response sr = (Standard_Inner_Response) r;
        sr.writePackage(out);
    }

    public void fromValue(ByteBuffer in, Object r) throws Exception {
        Standard_Inner_Response sr = (Standard_Inner_Response) r;
        sr.readPackage(in);
    }

}