~elambert/gearmanij/gearman_java_library

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

Committer: Eric Lambert
Date: 2009-07-07 02:18:15 UTC
mfrom: (57.1.65 gearmanij-trunk)
Revision ID: eric.d.lambert@gmail.com-20090707021815-0xbupi72ubyoa62a

merge from trunk. ReverseWorkerTest has been ignored, it was failing claiming that certain ops were not supported, since there is duplication in the worker code, for the time being will just ignore this issue, will resolve once the worker code has been straightened out

files added:
src/org

src/org/gearman/TextConnection.java

src/org/gearman/client

src/org/gearman/client/GearmanClient.java

src/org/gearman/client/GearmanJob.java

src/org/gearman/client/GearmanJobEventListener.java

src/org/gearman/client/GearmanJobResult.java

src/org/gearman/client/GearmanJobStatus.java

src/org/gearman/client/JobResponse.java

src/org/gearman/common

src/org/gearman/common/GearmanJobServerConnection.java

src/org/gearman/common/GearmanNIOJobServerConnection.java

src/org/gearman/common/GearmanPacket.java

src/org/gearman/common/GearmanServerResponseHandler.java

src/org/gearman/common/Packet.java

src/org/gearman/common/PacketHeader.java

src/org/gearman/common/PacketMagic.java

src/org/gearman/common/PacketType.java

src/org/gearman/worker

src/org/gearman/worker/GearmanFunction.java

src/org/gearman/worker/GearmanFunctionFactory.java

src/org/gearman/worker/GearmanWorker.java

src/org/gearman/worker/ObjectFunction.java

test/org

test/org/gearman/client

test/org/gearman/common

test/org/gearman/worker

files removed:
eclipse_gearmanij_formatter.xml

src/gearmanij/Packet.java

src/gearmanij/client

src/gearmanij/client/GearmanServerResponseHandler.java

src/gearmanij/common

src/gearmanij/common/GearmanNIOJobServerConnection.java

src/org

src/org/gearman

src/org/gearman/GearmanClient.java

src/org/gearman/GearmanFunction.java

src/org/gearman/GearmanFunctionFactory.java

src/org/gearman/GearmanJob.java

src/org/gearman/GearmanJobEventListener.java

src/org/gearman/GearmanJobResult.java

src/org/gearman/GearmanJobServerConnection.java

src/org/gearman/GearmanJobStatus.java

src/org/gearman/GearmanPacket.java

src/org/gearman/GearmanWorker.java

src/org/gearman/PacketHeader.java

src/org/gearman/PacketMagic.java

src/org/gearman/PacketType.java

src/org/gearman/worker

src/org/gearman/worker/ObjectFunction.java

test/gearmanij/client

files renamed:
src/gearmanij/ => src/org/gearman/

src/gearmanij/Connection.java => src/org/gearman/PacketConnection.java

src/gearmanij/ClientRequest.java => src/org/gearman/client/ClientRequest.java

src/gearmanij/client/GearmanClientImpl.java => src/org/gearman/client/GearmanClientImpl.java

src/gearmanij/client/GearmanEchoResponseHandler.java => src/org/gearman/client/GearmanEchoResponseHandler.java

src/gearmanij/client/GearmanJobImpl.java => src/org/gearman/client/GearmanJobImpl.java

src/gearmanij/client/GearmanJobResultImpl.java => src/org/gearman/client/GearmanJobResultImpl.java

src/gearmanij/client/GearmanJobStatusImpl.java => src/org/gearman/client/GearmanJobStatusImpl.java

src/gearmanij/Status.java => src/org/gearman/client/Status.java

src/gearmanij/SubmitJob.java => src/org/gearman/client/SubmitJob.java

src/gearmanij/ConnectionAdminClient.java => src/org/gearman/common/ConnectionAdminClient.java

src/gearmanij/client/GearmanJobServerSession.java => src/org/gearman/common/GearmanJobServerSession.java

src/gearmanij/client/GearmanServerRequest.java => src/org/gearman/common/GearmanServerRequest.java

src/gearmanij/SocketConnection.java => src/org/gearman/common/SocketConnection.java

src/gearmanij/client/AbstractGearmanFunction.java => src/org/gearman/worker/AbstractGearmanFunction.java

src/gearmanij/ClassJobFunctionFactory.java => src/org/gearman/worker/ClassJobFunctionFactory.java

src/gearmanij/client/GearmanWorkerImpl.java => src/org/gearman/worker/GearmanWorkerImpl.java

src/gearmanij/client/GearmanWorkerJobServerSession.java => src/org/gearman/worker/GearmanWorkerJobServerSession.java

src/gearmanij/InstanceJobFunctionFactory.java => src/org/gearman/worker/InstanceJobFunctionFactory.java

src/gearmanij/StandardWorker.java => src/org/gearman/worker/StandardWorker.java

src/gearmanij/WorkerJob.java => src/org/gearman/worker/WorkerJob.java

test/gearmanij/ => test/org/gearman/

test/gearmanij/client/GearmanClientIOTest.java => test/org/gearman/client/GearmanClientIOTest.java

test/gearmanij/client/GearmanClientJobExecTest.java => test/org/gearman/client/GearmanClientJobExecTest.java

test/gearmanij/client/GearmanClientTest.java => test/org/gearman/client/GearmanClientTest.java

test/gearmanij/client/GearmanJobTest.java => test/org/gearman/client/GearmanJobTest.java

test/gearmanij/StatusCheckAcceptanceTest.java => test/org/gearman/client/StatusCheckAcceptanceTest.java

test/gearmanij/ConnectionAdminClientTest.java => test/org/gearman/common/ConnectionAdminClientTest.java

test/gearmanij/client/GearmanJobServerSessionTest.java => test/org/gearman/common/GearmanJobServerSessionTest.java

test/gearmanij/client/GearmanServerRequestTest.java => test/org/gearman/common/GearmanServerRequestTest.java

test/gearmanij/MockConnection.java => test/org/gearman/common/MockConnection.java

test/gearmanij/PacketMagicTest.java => test/org/gearman/common/PacketMagicTest.java

test/gearmanij/PacketTest.java => test/org/gearman/common/PacketTest.java

test/gearmanij/SocketConnectionTest.java => test/org/gearman/common/SocketConnectionTest.java

test/gearmanij/ThrowingConnection.java => test/org/gearman/common/ThrowingConnection.java

test/gearmanij/ReverseAcceptanceTest.java => test/org/gearman/example/ReverseAcceptanceTest.java

test/gearmanij/util/ExeptionsTest.java => test/org/gearman/util/ExceptionsTest.java

test/gearmanij/NotImplementedException.java => test/org/gearman/util/NotImplementedException.java

test/gearmanij/client/GearmanWorkerImplTest.java => test/org/gearman/worker/GearmanWorkerImplTest.java

test/gearmanij/client/GearmanWorkerJobServerSessionTest.java => test/org/gearman/worker/GearmanWorkerJobServerSessionTest.java

test/gearmanij/JobFunctionFactoryTest.java => test/org/gearman/worker/JobFunctionFactoryTest.java

test/gearmanij/ReverseWorkerTest.java => test/org/gearman/worker/ReverseWorkerTest.java

test/gearmanij/StandardWorkerTest.java => test/org/gearman/worker/StandardWorkerTest.java

files modified:
build.xml

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/Worker.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/util/ByteArrayBuffer.java

src/org/gearman/util/ByteUtils.java

src/org/gearman/util/Exceptions.java

src/org/gearman/util/IORuntimeException.java

src/org/gearman/util/IOUtil.java

test/org/gearman/example/DigestClientTest.java

test/org/gearman/util/ByteArrayBufferTest.java

test/org/gearman/util/ByteUtilsTest.java

test/org/gearman/util/IOUtilTest.java

test/org/gearman/util/SocketServer.java

test/org/gearman/util/TestUtil.java

Show diffs side-by-side

added added

removed removed

src/org/gearman/worker/AbstractGearmanFunction.java

* To change this template, choose Tools | Templates

* and open the template in the editor.

package gearmanij.client;

import gearmanij.Packet;

import gearmanij.util.ByteUtils;

import org.gearman.PacketType;

package org.gearman.worker;

import org.gearman.common.PacketType;

import java.util.HashSet;

import java.util.Set;

import org.gearman.GearmanFunction;

import org.gearman.GearmanPacket;

import org.gearman.GearmanJobEventListener;

import org.gearman.GearmanJobResult;

import org.gearman.PacketMagic;

import org.gearman.worker.GearmanFunction;

import org.gearman.common.GearmanPacket;

import org.gearman.client.GearmanJobEventListener;

import org.gearman.client.GearmanJobResult;

import org.gearman.common.Packet;

import org.gearman.common.PacketMagic;

import org.gearman.util.ByteUtils;

/**

Older »