← Back to branch summary

~elambert/gearmanij/gearman_java_library

« back to all changes in this revision

Viewing changes to src/org/gearman/example/ReverseWorker.java

  • Committer: Eric Lambert
  • Date: 2009-07-10 03:56:00 UTC
  • Revision ID: eric.d.lambert@gmail.com-20090710035600-fy5ghxevm51b5lvm
started refactoring unused classes and tests

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/org/gearman/example/ReverseWorker.java
8
8
 
9
9
import java.io.PrintStream;
10
10
 
11
 
import org.gearman.common.PacketConnection;
 
11
import org.gearman.common.GearmanJobServerConnection;
12
12
import org.gearman.common.Constants;
13
 
import org.gearman.worker.Worker;
14
 
import org.gearman.common.SocketConnection;
15
 
import org.gearman.worker.StandardWorker;
 
13
import org.gearman.common.GearmanNIOJobServerConnection;
 
14
import org.gearman.worker.GearmanWorker;
 
15
import org.gearman.worker.GearmanWorkerImpl;
16
16
 
17
17
public class ReverseWorker {
18
18
 
19
 
    private PacketConnection connection;
20
 
    private Worker reverse;
 
19
    private GearmanJobServerConnection connection;
 
20
    private GearmanWorker worker;
21
21
 
22
22
    public ReverseWorker(String host, int port) {
23
 
        this(new SocketConnection(host, port));
 
23
        this(new GearmanNIOJobServerConnection(host, port));
24
24
    }
25
25
 
26
 
    public ReverseWorker(PacketConnection connection) {
 
26
    public ReverseWorker(GearmanJobServerConnection connection) {
27
27
        this.connection = connection;
28
28
    }
29
29
 
30
30
    public void start() {
31
 
        reverse = new StandardWorker();
32
 
        reverse.addServer(connection);
33
 
        reverse.registerFunction(ReverseFunction.class);
34
 
        reverse.work();
 
31
        worker = new GearmanWorkerImpl();
 
32
        worker.addServer(connection);
 
33
        worker.registerFunction(ReverseFunction.class);
 
34
        worker.work();
35
35
    }
36
36
 
37
37
    public void shutdown() {
38
 
        reverse.stop();
 
38
        worker.stop();
39
39
    }
40
40
 
41
41
    public static void main(String[] args) {