examplehandler.java

JXTA&#8482 is a set of open, generalized peer-to-peer (P2P) protocols that allow any networked devi

import java.io.ByteArrayInputStream;
import java.io.IOException;
import net.jxta.impl.protocol.ResolverResponse;
import net.jxta.protocol.ResolverQueryMsg;
import net.jxta.protocol.ResolverResponseMsg;
import net.jxta.resolver.QueryHandler;

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
import net.jxta.resolver.ResolverService;

/**
 *
 * @author mr.nguyentuandung
 */
public class ExampleHandler implements QueryHandler {

    public static String ExampleHandlerTag = "ExampleHandler";
    ResolverService resolver;
    
    public ExampleHandler(ResolverService service){
        resolver = service;
    }
    public int processQuery(ResolverQueryMsg query) {
        ResolverResponse response;
        ExampleQueryMsg queryMsg;
        double answer = 0.0;
        trace("Processing query...");
        try {
            queryMsg = new ExampleQueryMsg(new ByteArrayInputStream(query.getQuery().getBytes()));
            answer = Math.pow(queryMsg.getBase(), queryMsg.getPower());
            trace("answer="+answer);
            ExampleResponseMsg responseMsg = new ExampleResponseMsg(queryMsg.getBase(),queryMsg.getPower(),answer);
            trace("generating resposneMesg");
            response = new ResolverResponse(ExampleHandlerTag,null,query.getQueryId(),responseMsg.toString());
            //response = (ResolverResponse) query.makeResponse();
            System.out.println("sourcePeerID:"+query.getSrc());
            //response.setResponse(responseMsg.toString());
            resolver.sendResponse(query.getSrcPeer().toString(), response);
            trace("response success");
        } catch (IOException ex) {
            trace(ex.toString());
        }
        return 0;
        //response = new ResolverResponse(ExampleHandlerTag,"JXTACRED",query.getQueryId(),responseMsg.toString());
        
        
    }

    public void processResponse(ResolverResponseMsg response) {
        ExampleResponseMsg responseMsg;
        trace("Process response...");
        try{
            responseMsg = new ExampleResponseMsg(new ByteArrayInputStream(
                    response.getResponse().getBytes()));
            trace("The value of "+responseMsg.getBase()+" raise to "+responseMsg.getPower()+" is: "+responseMsg.getAnswer());
            
        }catch(IOException e){
            trace(e.toString());
        }
    }

    private void trace(String str){
        System.out.println("ExampleHandler:     "+str);
    }
}