WorkerClient

package worker;


 import java.io.IOException;

 import org.gearman.Gearman;
 import org.gearman.GearmanFunction;
 import org.gearman.GearmanServer;
 import org.gearman.GearmanWorker;
 import org.gearman.impl.GearmanImpl;


 public class WorkerClient {

    private GearmanWorker gearmanWorker;
    private Gearman gearman;
    private GearmanImpl gearmanImpl;
    

    public WorkerClient(String host, int port, String functionName, GearmanFunction function) throws IOException {
    	
    	if (host==null || functionName==null || function==null)
            throw new IllegalArgumentException("parameter is null");

    	// Create a GearmanWorker
    	//gearmanImpl = new GearmanImpl(); 
    	gearman = GearmanImpl.createGearman();
    	gearmanWorker = gearman.createGearmanWorker();
    	//gearmanWorker = gearmanImpl.createGearmanWorker();
        
        //add remote gearman server
        GearmanServer gearmanServer = gearman.createGearmanServer(host, port);
        gearmanWorker.addServer(gearmanServer);
        
        // Register function to start working on gearman calls
        gearmanWorker.addFunction(functionName, function);
       

    }
    
    public void shutdown() {
        this.gearman.shutdown();
    }

	public String testPayload(String payload) {
		System.out.println("run payload now");
		return "payload returned";
	}

    

 }