resolverservicetest.java

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

import net.jxta.document.Document;
import net.jxta.document.MimeMediaType;
import net.jxta.exception.PeerGroupException;
import net.jxta.impl.protocol.ResolverQuery;
import net.jxta.peergroup.PeerGroup;

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
import net.jxta.peergroup.PeerGroupFactory;
import net.jxta.protocol.ResolverQueryMsg;
import net.jxta.protocol.ResolverResponseMsg;
import net.jxta.resolver.ResolverService;
/**
 *
 * @author mr.nguyentuandung
 */
public class Resolverservicetest {
    PeerGroup netPeerGroup;
    private boolean START_NETGROUP= true;

    public static String ResolverResponseTag = "Example:ExampleResponse";
    public static String ResolverQueryTag = "Example:ExampleQuery";
    private boolean removeHandler = false;
    private String name = ExampleHandler.ExampleHandlerTag;
    
    
    private double base = 2;
    private double power = 5;
    
    private ResolverService resolver;
   
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        // TODO code application logic here
        Resolverservicetest resolvertest = new Resolverservicetest();
        try{
            resolvertest.initial();
            resolvertest.send();
        }catch(Exception e){
            System.out.println("error at main: "+e.toString());
        }
    }


    private void initial () throws PeerGroupException{
        netPeerGroup = PeerGroupFactory.newNetPeerGroup();

        // This will cause the JXTA Shell to start if enabled.
        if (START_NETGROUP) {
            netPeerGroup.startApp(new String[0]);
        }
        resolver = netPeerGroup.getResolverService();
        manageHandler(resolver);
        new TestFrame().setVisible(true);
    }
    
    private void send(){
        
            ExampleQueryMsg queryMsg = new ExampleQueryMsg(base,power);
            String localPeerID = netPeerGroup.getPeerID().toString();
            ResolverQuery resolverQuery = new ResolverQuery(name,null,localPeerID,queryMsg.toString(),0);
            trace("sending query");
            resolver.sendQuery(localPeerID, resolverQuery);
            trace("send Query succeed");
        
    }
    
  
    
    private void manageHandler(ResolverService resolver){
        if(removeHandler){
            //unregister the Handler from resolverService
            ExampleHandler handler  =  (ExampleHandler)resolver.unregisterHandler(name);
            
        }else{
            trace("registerHandler with name:"+name);
            ExampleHandler handler = new ExampleHandler(resolver);
            resolver.registerHandler(name, handler);
        }
    }
    
    private void trace(String str){
        System.out.println("Resolverservicetest:    "+str);
    }
}