~elambert/gearmanij/gearman_java_library

« back to all changes in this revision

Viewing changes to src/org/gearman/worker/StandardWorker.java

Committer: Eric Lambert
Date: 2009-07-07 05:45:30 UTC
Revision ID: eric.d.lambert@gmail.com-20090707054530-2963dq28telt30yj

I fubar-ed rev142, so undoing it

files added:
src/org/gearman/AdminClient.java

src/org/gearman/Constants.java

src/org/gearman/GearmanException.java

src/org/gearman/GearmanReturnCodes.java

src/org/gearman/Job.java

src/org/gearman/JobFunction.java

src/org/gearman/JobFunctionFactory.java

src/org/gearman/PacketConnection.java

src/org/gearman/TextConnection.java

src/org/gearman/Worker.java

files modified:
src/org/gearman/client/ClientRequest.java

src/org/gearman/client/GearmanClient.java

src/org/gearman/client/GearmanClientImpl.java

src/org/gearman/client/GearmanEchoResponseHandler.java

src/org/gearman/client/GearmanJobImpl.java

src/org/gearman/client/GearmanJobStatusImpl.java

src/org/gearman/client/Status.java

src/org/gearman/common/ConnectionAdminClient.java

src/org/gearman/common/GearmanJobServerSession.java

src/org/gearman/common/GearmanNIOJobServerConnection.java

src/org/gearman/common/GearmanServerRequest.java

src/org/gearman/common/GearmanServerResponseHandler.java

src/org/gearman/common/SocketConnection.java

src/org/gearman/example/DigestClient.java

src/org/gearman/example/DigestFunction.java

src/org/gearman/example/EchoClient.java

src/org/gearman/example/ReverseClient.java

src/org/gearman/example/ReverseFunction.java

src/org/gearman/example/ReverseWorker.java

src/org/gearman/worker/ClassJobFunctionFactory.java

src/org/gearman/worker/GearmanWorkerImpl.java

src/org/gearman/worker/GearmanWorkerJobServerSession.java

src/org/gearman/worker/InstanceJobFunctionFactory.java

src/org/gearman/worker/ObjectFunction.java

src/org/gearman/worker/StandardWorker.java

src/org/gearman/worker/WorkerJob.java

test/org/gearman/client/GearmanClientIOTest.java

test/org/gearman/client/GearmanClientJobExecTest.java

test/org/gearman/client/GearmanClientTest.java

test/org/gearman/client/GearmanJobTest.java

test/org/gearman/client/StatusCheckAcceptanceTest.java

test/org/gearman/common/ConnectionAdminClientTest.java

test/org/gearman/common/GearmanJobServerSessionTest.java

test/org/gearman/common/GearmanServerRequestTest.java

test/org/gearman/common/ThrowingConnection.java

test/org/gearman/example/DigestClientTest.java

test/org/gearman/example/ReverseAcceptanceTest.java

test/org/gearman/util/TestUtil.java

test/org/gearman/worker/GearmanWorkerImplTest.java

test/org/gearman/worker/GearmanWorkerJobServerSessionTest.java

test/org/gearman/worker/JobFunctionFactoryTest.java

test/org/gearman/worker/ReverseWorkerTest.java

test/org/gearman/worker/StandardWorkerTest.java

Show diffs side-by-side

added added

removed removed

src/org/gearman/worker/StandardWorker.java

import java.util.List;

import java.util.Map;

import org.gearman.common.PacketConnection;

import org.gearman.client.Job;

import org.gearman.PacketConnection;

import org.gearman.Job;

import org.gearman.JobFunction;

import org.gearman.JobFunctionFactory;

import org.gearman.common.GearmanPacket;

import org.gearman.common.Packet;

import org.gearman.common.PacketMagic;

import org.gearman.common.PacketType;

import org.gearman.Worker;

import org.gearman.util.ByteArrayBuffer;

import org.gearman.util.ByteUtils;

import org.gearman.util.IORuntimeException;

Older »