reportresptimeindexcreator.java

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

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

import org.apache.log4j.Logger;
import org.apache.mina.common.ByteBuffer;

import com.pub.berkeleydb.DefaultIndexKeyCreator;
import com.sleepycat.je.DatabaseEntry;
import com.sleepycat.je.DatabaseException;
import com.sleepycat.je.SecondaryDatabase;
import com.sms.protocol.standard12.Standard_Inner_Response;

public class ReportRespTimeIndexCreator extends DefaultIndexKeyCreator {

    private static Logger log = Logger.getLogger(ReportRespTimeIndexCreator.class);

    public boolean createSecondaryKey(SecondaryDatabase secDb,
                                      DatabaseEntry keyEntry,
                                      DatabaseEntry dataEntry,
                                      DatabaseEntry resultEntry) throws
            DatabaseException {

        if (dataEntry == null || keyEntry == null) {
            return false;
        }

        try {
            resultEntry.setData(dataEntry.getData(), 36, 8);
        } catch (Exception ioe) {
            log.error(null, ioe);
        }
        return true;
    }

    public void toIndexKey(ByteBuffer out, Object r) {
    	Standard_Inner_Response sr = (Standard_Inner_Response) r;
        out.putLong(sr.getSendTime());
    }

}