A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- AbstractGearmanFunction - Class in org.gearman.worker
- AbstractGearmanFunction() - Constructor for class org.gearman.worker.AbstractGearmanFunction
- AbstractGearmanFunction(String) - Constructor for class org.gearman.worker.AbstractGearmanFunction
- addJobResult(GearmanJobResultImpl) - Method in class org.gearman.client.GearmanJobResultImpl
- addJobServer(String, int) - Method in class org.gearman.client.GearmanClientImpl
- addJobServer(String, int, boolean) - Method in class org.gearman.client.GearmanClientImpl
- addJobServer(GearmanJobServerConnection) - Method in interface org.gearman.client.GearmanClient
-
Register a new Gearman Job Server with the client.
- addJobServer(GearmanJobServerConnection) - Method in class org.gearman.client.GearmanClientImpl
- addJobServer(GearmanJobServerConnection, boolean) - Method in class org.gearman.client.GearmanClientImpl
- addServer(String, int) - Method in class org.gearman.worker.GearmanWorkerImpl
- addServer(GearmanJobServerConnection) - Method in interface org.gearman.worker.GearmanWorker
-
Register a new Gearman Job Server with the worker.
- addServer(GearmanJobServerConnection) - Method in class org.gearman.worker.GearmanWorkerImpl
- ALL_YOURS - org.gearman.common.GearmanPacketType
- append(byte) - Method in class org.gearman.util.ByteArrayBuffer
- append(byte[]) - Method in class org.gearman.util.ByteArrayBuffer
- append(byte[], int, int) - Method in class org.gearman.util.ByteArrayBuffer
- append(InputStream) - Method in class org.gearman.util.ByteArrayBuffer
- awaitTermination(long, TimeUnit) - Method in class org.gearman.client.GearmanClientImpl
B
- ByteArrayBuffer - Class in org.gearman.util
- ByteArrayBuffer() - Constructor for class org.gearman.util.ByteArrayBuffer
- ByteArrayBuffer(byte[]) - Constructor for class org.gearman.util.ByteArrayBuffer
- ByteArrayBuffer(byte[], int) - Constructor for class org.gearman.util.ByteArrayBuffer
- ByteUtils - Class in org.gearman.util
C
- call() - Method in class org.gearman.client.GearmanJobImpl
- call() - Method in class org.gearman.worker.AbstractGearmanFunction
- CAN_DO - org.gearman.common.GearmanPacketType
- CAN_DO_TIMEOUT - org.gearman.common.GearmanPacketType
- cancel(boolean) - Method in class org.gearman.client.GearmanJobImpl
- canRead() - Method in interface org.gearman.common.GearmanJobServerConnection
-
Can a read operation be executed at this time.
- canRead() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- CANT_DO - org.gearman.common.GearmanPacketType
- canWrite() - Method in interface org.gearman.common.GearmanJobServerConnection
-
Can a write operation be executed at this time.
- canWrite() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- CHARSET_ASCII - Static variable in class org.gearman.util.ByteUtils
- CHARSET_UTF_8 - Static variable in class org.gearman.util.ByteUtils
- CLIENT_ID - org.gearman.common.GearmanPacket.DataComponentName
- close() - Method in interface org.gearman.common.GearmanJobServerConnection
-
Closes a connection to the Gearman Job Server.
- close() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- closeSession() - Method in class org.gearman.common.GearmanJobServerSession
- Constants - Interface in org.gearman.common
- copy() - Method in class org.gearman.client.GearmanJobResultImpl
- copy(byte[]) - Static method in class org.gearman.util.ByteUtils
-
null-safe byte[] copy
- createBackgroundJob(String, byte[], String) - Static method in class org.gearman.client.GearmanJobImpl
- createBackgroundJob(String, byte[], GearmanJob.JobPriority, String) - Static method in class org.gearman.client.GearmanJobImpl
- createConnection(String, int) - Method in interface org.gearman.common.GearmanJobServerIpConnectionFactory
-
Creates a new connection handle for a specific Gearman Job Server
- createConnection(String, int) - Method in class org.gearman.common.GearmanNIOJobServerConnectionFactory
- createJob(String, byte[], String) - Static method in class org.gearman.client.GearmanJobImpl
- createJob(String, byte[], GearmanJob.JobPriority, String) - Static method in class org.gearman.client.GearmanJobImpl
D
- data - Variable in class org.gearman.worker.AbstractGearmanFunction
- DATA - org.gearman.common.GearmanPacket.DataComponentName
- DAY_OF_MONTH - org.gearman.common.GearmanPacket.DataComponentName
- DAY_OF_WEEK - org.gearman.common.GearmanPacket.DataComponentName
- DefaultGearmanFunctionFactory - Class in org.gearman.worker
- DefaultGearmanFunctionFactory(String) - Constructor for class org.gearman.worker.DefaultGearmanFunctionFactory
- DefaultGearmanFunctionFactory(String, String) - Constructor for class org.gearman.worker.DefaultGearmanFunctionFactory
- DENOMINATOR - org.gearman.common.GearmanPacket.DataComponentName
- digest(byte[]) - Method in class org.gearman.example.DigestClient
- DigestClient - Class in org.gearman.example
- DigestClient(String, int) - Constructor for class org.gearman.example.DigestClient
- DigestClient(GearmanJobServerConnection) - Constructor for class org.gearman.example.DigestClient
- DigestFunction - Class in org.gearman.example
-
The data passed to DigestFunction should contain two parameters separated by a null byte.
- DigestFunction() - Constructor for class org.gearman.example.DigestFunction
- driveSessionIO() - Method in class org.gearman.common.GearmanJobServerSession
E
- echo(byte[]) - Method in class org.gearman.client.GearmanClientImpl
- echo(String) - Method in class org.gearman.example.EchoClient
- echo(String, GearmanJobServerConnection) - Method in interface org.gearman.worker.GearmanWorker
-
Send an echo request to the specified
GearmanJobServerConnection
, the Gearman Job Server should echo the contents of the echo request back to the Worker. - echo(String, GearmanJobServerConnection) - Method in class org.gearman.worker.GearmanWorkerImpl
- ECHO_REQ - org.gearman.common.GearmanPacketType
- ECHO_RES - org.gearman.common.GearmanPacketType
- EchoClient - Class in org.gearman.example
- EchoClient(String, int) - Constructor for class org.gearman.example.EchoClient
- EMPTY - Static variable in class org.gearman.util.ByteUtils
- EPOCH - org.gearman.common.GearmanPacket.DataComponentName
- equals(Object) - Method in class org.gearman.common.GearmanJobServerSession
- equals(Object) - Method in class org.gearman.common.GearmanNIOJobServerConnection
- ERROR - org.gearman.common.GearmanPacketType
- ERROR_CODE - org.gearman.common.GearmanPacket.DataComponentName
- ERROR_TEXT - org.gearman.common.GearmanPacket.DataComponentName
- EXCEPTION - org.gearman.common.GearmanTask.State
- execute(Runnable) - Method in class org.gearman.client.GearmanClientImpl
- executeFunction() - Method in class org.gearman.example.DigestFunction
- executeFunction() - Method in class org.gearman.example.ReverseFunction
- executeFunction() - Method in class org.gearman.worker.AbstractGearmanFunction
F
- FINISHED - org.gearman.common.GearmanTask.State
- fireEvent(GearmanPacket) - Method in class org.gearman.worker.AbstractGearmanFunction
- fireEvent(GearmanPacket) - Method in interface org.gearman.worker.GearmanFunction
-
Allows all
GearmanIOEventListener
registered with this function to handle the specified event. - flush(Flushable) - Static method in class org.gearman.util.IOUtil
- fromAsciiBytes(byte[]) - Static method in class org.gearman.util.ByteUtils
- fromBigEndian(byte[]) - Static method in class org.gearman.util.ByteUtils
- fromBytes(byte[]) - Static method in enum org.gearman.common.GearmanPacketMagic
-
"\0REQ" == [ 00 52 45 51 ] == 5391697 "\0RES" == [ 00 52 45 53 ] == 5391699
- fromBytes(byte[], String) - Static method in class org.gearman.util.ByteUtils
- fromHex(String) - Static method in class org.gearman.util.ByteUtils
- fromUTF8Bytes(byte[]) - Static method in class org.gearman.util.ByteUtils
- FUNCTION_NAME - org.gearman.common.GearmanPacket.DataComponentName
G
- GEARMAN_ARGS_BUFFER_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_CLIENT_LOGGER_NAME - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_BACKLOG - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_MAX_QUEUE_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_SOCKET_RECV_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_SOCKET_SEND_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_SOCKET_TIMEOUT - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_TCP_HOST - Static variable in interface org.gearman.common.Constants
- GEARMAN_DEFAULT_TCP_PORT - Static variable in interface org.gearman.common.Constants
- GEARMAN_JOB_HANDLE_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_JOB_HASH_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_JOB_LOGGER_NAME - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_COMMAND_ARGS - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_ERROR_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_FREE_SERVER_CLIENT - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_FREE_SERVER_CON - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_FREE_SERVER_JOB - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_FREE_SERVER_PACKET - Static variable in interface org.gearman.common.Constants
- GEARMAN_MAX_FREE_SERVER_WORKER - Static variable in interface org.gearman.common.Constants
- GEARMAN_OPTION_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_PACKET_HEADER_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_PIPE_BUFFER_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_RECV_BUFFER_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_SEND_BUFFER_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_SERVER_CON_ID_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_SESSION_LOGGER_NAME - Static variable in interface org.gearman.common.Constants
- GEARMAN_TEXT_RESPONSE_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_UNIQUE_SIZE - Static variable in interface org.gearman.common.Constants
- GEARMAN_WORKER_LOGGER_NAME - Static variable in interface org.gearman.common.Constants
- GEARMAN_WORKER_WAIT_TIMEOUT - Static variable in interface org.gearman.common.Constants
- GearmanClient - Interface in org.gearman.client
-
This interface through which users of the Gearman Java Libaray will use to submit jobs for execution by the Gearman System and to track the progess of those jobs.
- GearmanClientImpl - Class in org.gearman.client
- GearmanClientImpl() - Constructor for class org.gearman.client.GearmanClientImpl
-
Create a new GearmanClient instance.
- GearmanClientImpl(long) - Constructor for class org.gearman.client.GearmanClientImpl
- GearmanEchoResponseHandler - Class in org.gearman.client
- GearmanEchoResponseHandler() - Constructor for class org.gearman.client.GearmanEchoResponseHandler
- GearmanException - Exception in org.gearman.common
- GearmanException() - Constructor for exception org.gearman.common.GearmanException
- GearmanException(String) - Constructor for exception org.gearman.common.GearmanException
- GearmanFunction - Interface in org.gearman.worker
-
A Gearman Function represents the work to be accomplished by a
GearmanJob
. - GearmanFunctionFactory - Interface in org.gearman.worker
-
Factory for producing
GearmanFunction
objects. - GearmanIOEventListener - Interface in org.gearman.client
-
A GearmanIOEventListener receives notifications as events are sent from the Gearman Job Server to a particular
GearmanJob
. - GearmanJob - Interface in org.gearman.client
-
The Gearman Job is a basic undivisible unit of work to be executed by a Gearman system.
- GearmanJob.JobPriority - Enum in org.gearman.client
- GearmanJobImpl - Class in org.gearman.client
- GearmanJobResult - Interface in org.gearman.client
- GearmanJobResultImpl - Class in org.gearman.client
- GearmanJobResultImpl(byte[]) - Constructor for class org.gearman.client.GearmanJobResultImpl
- GearmanJobResultImpl(byte[], boolean, byte[], byte[], byte[], long, long) - Constructor for class org.gearman.client.GearmanJobResultImpl
- GearmanJobServerConnection - Interface in org.gearman.common
-
This interface exposes the API that classes representing connections to a Gearman Job Server must implement.
- GearmanJobServerIpConnection - Interface in org.gearman.common
-
This interface exposes the API that classes representing IP connections to a Gearman Job Server must implement.
- GearmanJobServerIpConnectionFactory - Interface in org.gearman.common
-
Factory used to create connections to a target Gearman Job Server
- GearmanJobServerSession - Class in org.gearman.common
- GearmanJobServerSession(GearmanJobServerConnection) - Constructor for class org.gearman.common.GearmanJobServerSession
- GearmanJobStatus - Interface in org.gearman.client
-
A GearmanJobStatus represents the state of a particular
GearmanJob
, as known by Gearman Job Server that it was submitted to, at a specific point in time. - GearmanJobStatusImpl - Class in org.gearman.client
- GearmanNIOJobServerConnection - Class in org.gearman.common
- GearmanNIOJobServerConnection(String) - Constructor for class org.gearman.common.GearmanNIOJobServerConnection
- GearmanNIOJobServerConnection(String, int) - Constructor for class org.gearman.common.GearmanNIOJobServerConnection
- GearmanNIOJobServerConnection(InetSocketAddress) - Constructor for class org.gearman.common.GearmanNIOJobServerConnection
- GearmanNIOJobServerConnectionFactory - Class in org.gearman.common
- GearmanNIOJobServerConnectionFactory() - Constructor for class org.gearman.common.GearmanNIOJobServerConnectionFactory
- GearmanPacket - Interface in org.gearman.common
-
A GearmanPacket represents an indvidual message that can either be sent to a Gearman Job Server or received from a Gearman Job Server.
- GearmanPacket.DataComponentName - Enum in org.gearman.common
- GearmanPacketHeader - Class in org.gearman.common
- GearmanPacketHeader(byte[]) - Constructor for class org.gearman.common.GearmanPacketHeader
- GearmanPacketHeader(GearmanPacketMagic, GearmanPacketType, int) - Constructor for class org.gearman.common.GearmanPacketHeader
- GearmanPacketImpl - Class in org.gearman.common
-
Requests and responses sent between workers or clients and job servers are contained in binary packets.
- GearmanPacketImpl(InputStream) - Constructor for class org.gearman.common.GearmanPacketImpl
- GearmanPacketImpl(GearmanPacketMagic, GearmanPacketType, byte[]) - Constructor for class org.gearman.common.GearmanPacketImpl
- GearmanPacketMagic - Enum in org.gearman.common
-
Enum for the different magic codes that can appear at the beginning of a packet header.
- GearmanPacketMagic.BadMagicException - Exception in org.gearman.common
- GearmanPacketType - Enum in org.gearman.common
- GearmanServerResponseHandler - Interface in org.gearman.common
- GearmanSessionEvent - Class in org.gearman.common
- GearmanSessionEvent(GearmanPacket, GearmanJobServerSession) - Constructor for class org.gearman.common.GearmanSessionEvent
- GearmanSessionEventHandler - Interface in org.gearman.common
- GearmanTask - Class in org.gearman.common
- GearmanTask(GearmanPacket) - Constructor for class org.gearman.common.GearmanTask
- GearmanTask(GearmanServerResponseHandler, GearmanPacket) - Constructor for class org.gearman.common.GearmanTask
- GearmanTask.State - Enum in org.gearman.common
- GearmanWorker - Interface in org.gearman.worker
-
A Gearman Worker is responsible for executing jobs it receives from the Job Server.
- GearmanWorkerImpl - Class in org.gearman.worker
- GearmanWorkerImpl() - Constructor for class org.gearman.worker.GearmanWorkerImpl
- GearmanWorkerImpl(ExecutorService) - Constructor for class org.gearman.worker.GearmanWorkerImpl
- GearmanWorkerImpl.State - Enum in org.gearman.worker
- generatePacketData(byte[]...) - Static method in class org.gearman.common.GearmanPacketImpl
- get() - Method in class org.gearman.client.GearmanJobImpl
- get(int) - Static method in enum org.gearman.common.GearmanPacketType
-
Returns the PacketType for the specified
ordinal
. - get(long, TimeUnit) - Method in class org.gearman.client.GearmanJobImpl
- GET_STATUS - org.gearman.common.GearmanPacketType
- getBytes() - Method in class org.gearman.util.ByteArrayBuffer
- getCause() - Method in exception org.gearman.util.IORuntimeException
- getConnection() - Method in class org.gearman.common.GearmanJobServerSession
- getData() - Method in interface org.gearman.client.GearmanJob
-
Retrieve the data against which the job is executed.
- getData() - Method in class org.gearman.client.GearmanJobImpl
- getData() - Method in interface org.gearman.common.GearmanPacket
-
Retrieves the payload, if any, associated with this packet.
- getData() - Method in class org.gearman.common.GearmanPacketImpl
- getDataComponentValue(GearmanPacket.DataComponentName) - Method in interface org.gearman.common.GearmanPacket
-
The data or payload of a packet can contain different set of components depending on the type of packet.
- getDataComponentValue(GearmanPacket.DataComponentName) - Method in class org.gearman.common.GearmanPacketImpl
- getDataLength() - Method in class org.gearman.common.GearmanPacketHeader
- getDataSize() - Method in class org.gearman.common.GearmanPacketImpl
- getDenominator() - Method in interface org.gearman.client.GearmanJobResult
-
Retrieves the denominator value as generated by the
GearmanJob
- getDenominator() - Method in class org.gearman.client.GearmanJobResultImpl
- getDenominator() - Method in interface org.gearman.client.GearmanJobStatus
-
Retrieves the denominator value of the
GearmanJob
at the time the GearmanJobStatus was generated. - getDenominator() - Method in class org.gearman.client.GearmanJobStatusImpl
- getExceptions() - Method in interface org.gearman.client.GearmanJobResult
-
Retrieve the exceptions generated by the
GearmanJob
which generated this GearmanJobResult - getExceptions() - Method in class org.gearman.client.GearmanJobResultImpl
- getFunction() - Method in class org.gearman.worker.DefaultGearmanFunctionFactory
- getFunction() - Method in interface org.gearman.worker.GearmanFunctionFactory
-
Factory method for generating a
GearmanFunction
object. - getFunctionName() - Method in interface org.gearman.client.GearmanJob
-
Retrieve the name of the
GearmanFunction
registered with this job. - getFunctionName() - Method in class org.gearman.client.GearmanJobImpl
- getFunctionName() - Method in class org.gearman.worker.DefaultGearmanFunctionFactory
- getFunctionName() - Method in interface org.gearman.worker.GearmanFunctionFactory
-
Returns the name of the function for which this factory creates
GearmanFunction
objects. - getHandle() - Method in interface org.gearman.client.GearmanJob
-
Retrieves the handle used by the Gearman Job Server to which this job was submitted to as a means to identify this job.
- getHandle() - Method in class org.gearman.client.GearmanJobImpl
- getHandler() - Method in class org.gearman.common.GearmanTask
- getHost() - Method in interface org.gearman.common.GearmanJobServerIpConnection
- getHost() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- getID() - Method in interface org.gearman.client.GearmanJob
-
Retrieves a unique ID used to identify this job.
- getID() - Method in class org.gearman.client.GearmanJobImpl
- getJobHandle() - Method in interface org.gearman.client.GearmanJobResult
-
Retrieves the job handle for the job which generated this GearmanJobResult.
- getJobHandle() - Method in class org.gearman.client.GearmanJobResultImpl
- getJobHandle() - Method in class org.gearman.worker.AbstractGearmanFunction
- getJobHandle() - Method in interface org.gearman.worker.GearmanFunction
-
Retrieves the handle for the job that is executing this function.
- getJobStatus(GearmanJob) - Method in interface org.gearman.client.GearmanClient
-
Sends a WORK_STATUS request to the Gearman Job Server running the
GearmanJob
and then returnsGearmanJobStatus
representing the current status of the job. - getJobStatus(GearmanJob) - Method in class org.gearman.client.GearmanClientImpl
- getMagic() - Method in interface org.gearman.common.GearmanPacket
-
Retrieves the magic type for this packet.
- getMagic() - Method in class org.gearman.common.GearmanPacketHeader
- getMagic() - Method in class org.gearman.common.GearmanPacketImpl
- getName() - Method in class org.gearman.worker.AbstractGearmanFunction
- getName() - Method in interface org.gearman.worker.GearmanFunction
-
Retrieves the name of the funcion to be executed by the job.
- getNumberofActiveJobs() - Method in class org.gearman.client.GearmanClientImpl
- getNumberOfActiveTasks() - Method in class org.gearman.common.GearmanJobServerSession
- getNumerator() - Method in interface org.gearman.client.GearmanJobResult
-
Retrieves the numerator value as generated by the
GearmanJob
- getNumerator() - Method in class org.gearman.client.GearmanJobResultImpl
- getNumerator() - Method in interface org.gearman.client.GearmanJobStatus
-
Retrieves the numerator value of the
GearmanJob
at the time the GearmanJobStatus was generated. - getNumerator() - Method in class org.gearman.client.GearmanJobStatusImpl
- getPacket() - Method in class org.gearman.common.GearmanSessionEvent
- getPacketType() - Method in interface org.gearman.common.GearmanPacket
-
Retrieves the event type for this packet.
- getPacketType() - Method in class org.gearman.common.GearmanPacketImpl
- getPort() - Method in interface org.gearman.common.GearmanJobServerIpConnection
- getPort() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- getPriority() - Method in interface org.gearman.client.GearmanJob
-
Retrieve the priority associated with this job.
- getPriority() - Method in class org.gearman.client.GearmanJobImpl
- getRegisteredFunctions() - Method in interface org.gearman.worker.GearmanWorker
-
Retrieve the names of all functions that have been registered with this worker.
- getRegisteredFunctions() - Method in class org.gearman.worker.GearmanWorkerImpl
- getRequestPacket() - Method in class org.gearman.common.GearmanTask
- getResults() - Method in interface org.gearman.client.GearmanJobResult
-
Retrieve the results generated by the
GearmanJob
which generated this GearmanJobResult - getResults() - Method in class org.gearman.client.GearmanJobResultImpl
- getSelectionKey() - Method in class org.gearman.common.GearmanJobServerSession
- getSelector() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- getSession() - Method in class org.gearman.common.GearmanSessionEvent
- getSetOfJobServers() - Method in interface org.gearman.client.GearmanClient
-
Retrieve the list of Gearman Job Servers connections that have been registered with this client.
- getSetOfJobServers() - Method in class org.gearman.client.GearmanClientImpl
- getState() - Method in class org.gearman.common.GearmanTask
- getType() - Method in class org.gearman.common.GearmanPacketHeader
- getType() - Method in class org.gearman.common.GearmanPacketImpl
- getUniqueId() - Method in class org.gearman.worker.AbstractGearmanFunction
- getUniqueId() - Method in interface org.gearman.worker.GearmanFunction
-
Returns the Unique ID given to this job by the client
- getWarnings() - Method in interface org.gearman.client.GearmanJobResult
-
Retrieve the warnings generated by the
GearmanJob
which generated this GearmanJobResult - getWarnings() - Method in class org.gearman.client.GearmanJobResultImpl
- getWorkerID() - Method in interface org.gearman.worker.GearmanWorker
-
Retrieves the ID used by this worker instance.
- getWorkerID() - Method in class org.gearman.worker.GearmanWorkerImpl
- getWorkerID(GearmanJobServerConnection) - Method in interface org.gearman.worker.GearmanWorker
-
Retrieves the ID this worker uses to identify itself with a specific connection.
- getWorkerID(GearmanJobServerConnection) - Method in class org.gearman.worker.GearmanWorkerImpl
- GRAB_JOB - org.gearman.common.GearmanPacketType
- GRAB_JOB_UNIQ - org.gearman.common.GearmanPacketType
H
- handleEvent(GearmanPacket) - Method in class org.gearman.client.GearmanEchoResponseHandler
- handleEvent(GearmanPacket) - Method in class org.gearman.client.GearmanJobImpl
- handleEvent(GearmanPacket) - Method in class org.gearman.client.GearmanJobStatusImpl
- handleEvent(GearmanPacket) - Method in interface org.gearman.common.GearmanServerResponseHandler
- handleGearmanIOEvent(GearmanPacket) - Method in interface org.gearman.client.GearmanIOEventListener
-
The method to be called when an event has occurred.
- handleGearmanIOEvent(GearmanPacket) - Method in class org.gearman.common.GearmanJobServerSession
- handleGearmanIOEvent(GearmanPacket) - Method in class org.gearman.common.GearmanTask
- handleSessionEvent(GearmanSessionEvent) - Method in class org.gearman.client.GearmanClientImpl
- handleSessionEvent(GearmanSessionEvent) - Method in class org.gearman.common.GearmanJobServerSession
- handleSessionEvent(GearmanSessionEvent) - Method in interface org.gearman.common.GearmanSessionEventHandler
- handleSessionEvent(GearmanSessionEvent) - Method in class org.gearman.worker.GearmanWorkerImpl
- hasBufferedWriteData() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- hasConnection(GearmanJobServerConnection) - Method in class org.gearman.client.GearmanClientImpl
- hashCode() - Method in class org.gearman.common.GearmanJobServerSession
- hashCode() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- hasServer(GearmanJobServerConnection) - Method in interface org.gearman.worker.GearmanWorker
-
Has a connection to the specified Gearman Job Server been registered with this worker.
- hasServer(GearmanJobServerConnection) - Method in class org.gearman.worker.GearmanWorkerImpl
- HEADER_LENGTH - Static variable in class org.gearman.common.GearmanPacketHeader
- HIGH - org.gearman.client.GearmanJob.JobPriority
- HOUR - org.gearman.common.GearmanPacket.DataComponentName
I
- IDLE - org.gearman.worker.GearmanWorkerImpl.State
- indexOf(byte) - Method in class org.gearman.util.ByteArrayBuffer
- indexOf(byte, int) - Method in class org.gearman.util.ByteArrayBuffer
- initSession(Selector, GearmanSessionEventHandler) - Method in class org.gearman.common.GearmanJobServerSession
- invokeAll(Collection) - Method in class org.gearman.client.GearmanClientImpl
- invokeAll(Collection, long, TimeUnit) - Method in class org.gearman.client.GearmanClientImpl
- invokeAny(Collection) - Method in class org.gearman.client.GearmanClientImpl
- invokeAny(Collection, long, TimeUnit) - Method in class org.gearman.client.GearmanClientImpl
- IORuntimeException - Exception in org.gearman.util
- IORuntimeException(IOException) - Constructor for exception org.gearman.util.IORuntimeException
- IOUtil - Class in org.gearman.util
- isBackgroundJob() - Method in interface org.gearman.client.GearmanJob
-
Determines if this job is a background job.
- isBackgroundJob() - Method in class org.gearman.client.GearmanJobImpl
- isCancelled() - Method in class org.gearman.client.GearmanJobImpl
- isDone() - Method in class org.gearman.client.GearmanEchoResponseHandler
- isDone() - Method in class org.gearman.client.GearmanJobImpl
- isDone() - Method in class org.gearman.client.GearmanJobStatusImpl
- isDone() - Method in interface org.gearman.common.GearmanServerResponseHandler
- isInitialized() - Method in class org.gearman.common.GearmanJobServerSession
- isJobSubmission(GearmanPacketType) - Static method in enum org.gearman.common.GearmanPacketType
- isJobUniqueIdRequired() - Method in interface org.gearman.worker.GearmanWorker
-
Does worker only ask for jobs which contain a Unique Id.
- isJobUniqueIdRequired() - Method in class org.gearman.worker.GearmanWorkerImpl
- isKnown() - Method in interface org.gearman.client.GearmanJobStatus
-
Determine if the job is currently known by the Gearman Job Server to which the
GearmanJob
was submitted. - isKnown() - Method in class org.gearman.client.GearmanJobStatusImpl
- isOpen() - Method in interface org.gearman.common.GearmanJobServerConnection
-
Is the connection open.
- isOpen() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- isRunning() - Method in interface org.gearman.client.GearmanJobStatus
-
Determine if the job is currently running on a worker.
- isRunning() - Method in class org.gearman.client.GearmanJobStatusImpl
- isRunning() - Method in interface org.gearman.worker.GearmanWorker
-
Determine if the worker is currently executing the work loop.
- isRunning() - Method in class org.gearman.worker.GearmanWorkerImpl
- isShutdown() - Method in class org.gearman.client.GearmanClientImpl
- isTerminated() - Method in class org.gearman.client.GearmanClientImpl
J
- JOB_ASSIGN - org.gearman.common.GearmanPacketType
- JOB_ASSIGN_UNIQ - org.gearman.common.GearmanPacketType
- JOB_CREATED - org.gearman.common.GearmanPacketType
- JOB_HANDLE - org.gearman.common.GearmanPacket.DataComponentName
- jobHandle - Variable in class org.gearman.worker.AbstractGearmanFunction
- jobSucceeded() - Method in interface org.gearman.client.GearmanJobResult
-
Determine with the job completed with out encountering exceptions or problems.
- jobSucceeded() - Method in class org.gearman.client.GearmanJobResultImpl
K
- KNOWN_STATUS - org.gearman.common.GearmanPacket.DataComponentName
L
- lastIndexOf(byte) - Method in class org.gearman.util.ByteArrayBuffer
- lastIndexOf(byte, int) - Method in class org.gearman.util.ByteArrayBuffer
- length() - Method in class org.gearman.util.ByteArrayBuffer
- listeners - Variable in class org.gearman.worker.AbstractGearmanFunction
- LOW - org.gearman.client.GearmanJob.JobPriority
M
- main(String[]) - Static method in class org.gearman.example.DigestClient
- main(String[]) - Static method in class org.gearman.example.EchoClient
- main(String[]) - Static method in class org.gearman.example.ReverseClient
- main(String[]) - Static method in class org.gearman.example.WorkerRunner
- MINUTE - org.gearman.common.GearmanPacket.DataComponentName
- MONTH - org.gearman.common.GearmanPacket.DataComponentName
N
- name - Variable in class org.gearman.worker.AbstractGearmanFunction
- NEW - org.gearman.common.GearmanTask.State
- NO_JOB - org.gearman.common.GearmanPacketType
- NOOP - org.gearman.common.GearmanPacketType
- NORMAL - org.gearman.client.GearmanJob.JobPriority
- NULL - org.gearman.common.GearmanPacketType
- NULL - Static variable in class org.gearman.util.ByteUtils
- NUMERATOR - org.gearman.common.GearmanPacket.DataComponentName
O
- open() - Method in interface org.gearman.common.GearmanJobServerConnection
-
Open the connection to the Gearman Job Server.
- open() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- OPTION - org.gearman.common.GearmanPacket.DataComponentName
- OPTION_REQ - org.gearman.common.GearmanPacketType
- OPTION_RES - org.gearman.common.GearmanPacketType
- org.gearman.client - package org.gearman.client
- org.gearman.common - package org.gearman.common
- org.gearman.example - package org.gearman.example
- org.gearman.util - package org.gearman.util
- org.gearman.worker - package org.gearman.worker
P
- PRE_SLEEP - org.gearman.common.GearmanPacketType
R
- read() - Method in interface org.gearman.common.GearmanJobServerConnection
-
Reads a
GearmanPacket
from the connection with the Gearman Job Server. - read() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- read(InputStream, byte[]) - Static method in class org.gearman.util.IOUtil
- readFully(InputStream, byte[]) - Static method in class org.gearman.util.IOUtil
-
Similar to
DataInputStream.readFully()
with more informative error message. - registerEventListener(GearmanIOEventListener) - Method in interface org.gearman.client.GearmanJob
-
As a GearmanJob progress through its' lifecycle, it will receives a series of events notifications from the Gearman Job Server.
- registerEventListener(GearmanIOEventListener) - Method in class org.gearman.client.GearmanJobImpl
- registerEventListener(GearmanIOEventListener) - Method in class org.gearman.worker.AbstractGearmanFunction
- registerEventListener(GearmanIOEventListener) - Method in interface org.gearman.worker.GearmanFunction
-
As a function executes, it can generate a series of I/O Events -- in the form of a
GearmanPacket
-- that can be handled by a series of listeners. - registerFunction(Class<? extends GearmanFunction>) - Method in interface org.gearman.worker.GearmanWorker
-
Registers a particular
GearmanFunction
with the worker. - registerFunction(Class<? extends GearmanFunction>) - Method in class org.gearman.worker.GearmanWorkerImpl
- registerFunction(Class<? extends GearmanFunction>, long) - Method in interface org.gearman.worker.GearmanWorker
-
Registers a particular
GearmanFunction
with the worker. - registerFunction(Class<? extends GearmanFunction>, long) - Method in class org.gearman.worker.GearmanWorkerImpl
- registerFunction(String) - Method in class org.gearman.worker.GearmanWorkerImpl
- registerFunction(String, long) - Method in class org.gearman.worker.GearmanWorkerImpl
- registerFunction(Callable<GearmanJobResult>) - Method in interface org.gearman.client.GearmanJob
-
Registers a particular
GearmanFunction
with this job. - registerFunction(Callable<GearmanJobResult>) - Method in class org.gearman.client.GearmanJobImpl
- registerFunctionFactory(GearmanFunctionFactory) - Method in interface org.gearman.worker.GearmanWorker
-
Registers a
GearmanFunctionFactory
with the worker. - registerFunctionFactory(GearmanFunctionFactory) - Method in class org.gearman.worker.GearmanWorkerImpl
- registerFunctionFactory(GearmanFunctionFactory, long) - Method in interface org.gearman.worker.GearmanWorker
-
Registers a
GearmanFunctionFactory
with the worker and specifies the timeout associated with any functions generated by this factory. - registerFunctionFactory(GearmanFunctionFactory, long) - Method in class org.gearman.worker.GearmanWorkerImpl
- registerSelector(Selector, int) - Method in class org.gearman.common.GearmanNIOJobServerConnection
- removeEventListener(GearmanIOEventListener) - Method in interface org.gearman.client.GearmanJob
-
removes a
GearmanIOEventListener
from recieving event notifications. - removeEventListener(GearmanIOEventListener) - Method in class org.gearman.client.GearmanJobImpl
- removeJobServer(GearmanJobServerConnection) - Method in interface org.gearman.client.GearmanClient
-
Unregisters a Gearman Job Server Connection from use by this client.
- removeJobServer(GearmanJobServerConnection) - Method in class org.gearman.client.GearmanClientImpl
- REQ - org.gearman.common.GearmanPacketMagic
- requiresResponse() - Method in interface org.gearman.common.GearmanPacket
-
Determine if the packet represents a request message that requires a responses from the server.
- requiresResponse() - Method in class org.gearman.common.GearmanPacketImpl
- RES - org.gearman.common.GearmanPacketMagic
- RESET_ABILITIES - org.gearman.common.GearmanPacketType
- reverse(String) - Method in class org.gearman.example.ReverseClient
- ReverseClient - Class in org.gearman.example
- ReverseClient(String, int) - Constructor for class org.gearman.example.ReverseClient
- ReverseClient(GearmanJobServerConnection) - Constructor for class org.gearman.example.ReverseClient
- ReverseFunction - Class in org.gearman.example
- ReverseFunction() - Constructor for class org.gearman.example.ReverseFunction
- RUNNING - org.gearman.common.GearmanTask.State
- RUNNING - org.gearman.worker.GearmanWorkerImpl.State
- RUNNING_STATUS - org.gearman.common.GearmanPacket.DataComponentName
S
- selectByte(int, int) - Static method in class org.gearman.util.ByteUtils
- sendData(byte[]) - Method in class org.gearman.worker.AbstractGearmanFunction
- sendException(byte[]) - Method in class org.gearman.worker.AbstractGearmanFunction
- sendStatus(int, int) - Method in class org.gearman.worker.AbstractGearmanFunction
- sendWarning(byte[]) - Method in class org.gearman.worker.AbstractGearmanFunction
- serialVersionUID - Static variable in exception org.gearman.common.GearmanException
- sessionHasDataToWrite() - Method in class org.gearman.common.GearmanJobServerSession
- SET_CLIENT_ID - org.gearman.common.GearmanPacketType
- setData(Object) - Method in class org.gearman.worker.AbstractGearmanFunction
- setData(Object) - Method in interface org.gearman.worker.GearmanFunction
-
Some functions require a dataset upon which to operate.
- setDataLength(int) - Method in class org.gearman.common.GearmanPacketHeader
- setJobHandle(byte[]) - Method in class org.gearman.worker.AbstractGearmanFunction
- setJobHandle(byte[]) - Method in interface org.gearman.worker.GearmanFunction
-
Set the handle of the job for which this function is executing.
- setJobServerSession(GearmanJobServerSession) - Method in class org.gearman.client.GearmanJobImpl
- setJobUniqueIdRequired(boolean) - Method in interface org.gearman.worker.GearmanWorker
-
Should worker only ask for jobs which contain a Unique Id.
- setJobUniqueIdRequired(boolean) - Method in class org.gearman.worker.GearmanWorkerImpl
- setMagic(GearmanPacketMagic) - Method in class org.gearman.common.GearmanPacketHeader
- setType(GearmanPacketType) - Method in class org.gearman.common.GearmanPacketHeader
- setUniqueId(byte[]) - Method in class org.gearman.worker.AbstractGearmanFunction
- setUniqueId(byte[]) - Method in interface org.gearman.worker.GearmanFunction
-
Set the Unique ID given to this job by the client
- setWorkerID(String) - Method in interface org.gearman.worker.GearmanWorker
-
Set the ID for a particular worker instance.
- setWorkerID(String) - Method in class org.gearman.worker.GearmanWorkerImpl
- setWorkerID(String, GearmanJobServerConnection) - Method in interface org.gearman.worker.GearmanWorker
-
Set the ID used by a particular Gearman Job Server to identify a particular Worker.
- setWorkerID(String, GearmanJobServerConnection) - Method in class org.gearman.worker.GearmanWorkerImpl
- shutdown() - Method in class org.gearman.client.GearmanClientImpl
- shutdown() - Method in class org.gearman.example.DigestClient
- shutdown() - Method in class org.gearman.example.EchoClient
- shutdown() - Method in class org.gearman.example.ReverseClient
- shutdown() - Method in interface org.gearman.worker.GearmanWorker
-
Stops the work loop and closes all open connections.
- shutdown() - Method in class org.gearman.worker.GearmanWorkerImpl
- shutdownNow() - Method in class org.gearman.client.GearmanClientImpl
- SHUTTINGDOWN - org.gearman.worker.GearmanWorkerImpl.State
- split(byte[]) - Method in class org.gearman.util.ByteArrayBuffer
- split(byte[], int) - Method in class org.gearman.util.ByteArrayBuffer
- start() - Method in class org.gearman.example.WorkerRunner
- STATUS_RES - org.gearman.common.GearmanPacketType
- stop() - Method in interface org.gearman.worker.GearmanWorker
-
Stops the work loop and requests a shutdown.
- stop() - Method in class org.gearman.worker.GearmanWorkerImpl
- subArray(int, int) - Method in class org.gearman.util.ByteArrayBuffer
-
The intest of this method is to be similar to
String.substring(int, int)
Returns a new byte[] that is a sub-array of this array. - submit(Runnable) - Method in class org.gearman.client.GearmanClientImpl
- submit(Runnable, T) - Method in class org.gearman.client.GearmanClientImpl
- submit(Callable<T>) - Method in class org.gearman.client.GearmanClientImpl
- SUBMIT_JOB - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_BG - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_EPOCH - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_HIGH - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_HIGH_BG - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_LOW - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_LOW_BG - org.gearman.common.GearmanPacketType
- SUBMIT_JOB_SCHED - org.gearman.common.GearmanPacketType
- submitTask(GearmanTask) - Method in class org.gearman.common.GearmanJobServerSession
- SUBMITTED - org.gearman.common.GearmanTask.State
T
- TIME_OUT - org.gearman.common.GearmanPacket.DataComponentName
- toAsciiBytes(String) - Static method in class org.gearman.util.ByteUtils
- toBigEndian(int) - Static method in class org.gearman.util.ByteUtils
- toBytes() - Method in interface org.gearman.common.GearmanPacket
-
Retrieves the Packet as a series of bytes.
- toBytes() - Method in class org.gearman.common.GearmanPacketImpl
- toBytes() - Method in enum org.gearman.common.GearmanPacketMagic
- toBytes() - Method in enum org.gearman.common.GearmanPacketType
- toBytes(String, String) - Static method in class org.gearman.util.ByteUtils
- toHex() - Method in class org.gearman.util.ByteArrayBuffer
- toHex(byte[]) - Static method in class org.gearman.util.ByteUtils
- toInt(int, byte) - Static method in class org.gearman.util.ByteUtils
- toString() - Method in class org.gearman.client.GearmanClientImpl
- toString() - Method in class org.gearman.client.GearmanEchoResponseHandler
- toString() - Method in class org.gearman.client.GearmanJobImpl
- toString() - Method in class org.gearman.client.GearmanJobStatusImpl
- toString() - Method in class org.gearman.common.GearmanJobServerSession
- toString() - Method in class org.gearman.common.GearmanNIOJobServerConnection
- toString() - Method in class org.gearman.common.GearmanPacketImpl
- toString() - Method in class org.gearman.common.GearmanTask
- toString() - Method in class org.gearman.util.ByteArrayBuffer
- toString() - Method in class org.gearman.worker.GearmanWorkerImpl
- toUTF8Bytes(String) - Static method in class org.gearman.util.ByteUtils
U
- UNIQUE_ID - org.gearman.common.GearmanPacket.DataComponentName
- uniqueId - Variable in class org.gearman.worker.AbstractGearmanFunction
- unregisterAll() - Method in interface org.gearman.worker.GearmanWorker
-
Unregisters all
GearmanFunction
from the worker. - unregisterAll() - Method in class org.gearman.worker.GearmanWorkerImpl
- unregisterFunction(String) - Method in interface org.gearman.worker.GearmanWorker
-
Unregisters a particular
GearmanFunction
from the worker. - unregisterFunction(String) - Method in class org.gearman.worker.GearmanWorkerImpl
- unused_5 - org.gearman.common.GearmanPacketType
- usage() - Static method in class org.gearman.example.DigestClient
- usage() - Static method in class org.gearman.example.EchoClient
- usage() - Static method in class org.gearman.example.ReverseClient
- usage(PrintStream) - Static method in class org.gearman.example.WorkerRunner
V
- valueOf(String) - Static method in enum org.gearman.client.GearmanJob.JobPriority
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.gearman.common.GearmanPacket.DataComponentName
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.gearman.common.GearmanPacketMagic
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.gearman.common.GearmanPacketType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.gearman.common.GearmanTask.State
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.gearman.worker.GearmanWorkerImpl.State
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.gearman.client.GearmanJob.JobPriority
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.gearman.common.GearmanPacket.DataComponentName
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.gearman.common.GearmanPacketMagic
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.gearman.common.GearmanPacketType
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.gearman.common.GearmanTask.State
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.gearman.worker.GearmanWorkerImpl.State
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- waitForTasksToComplete() - Method in class org.gearman.common.GearmanJobServerSession
- waitForTasksToComplete(long, TimeUnit) - Method in class org.gearman.common.GearmanJobServerSession
- work() - Method in interface org.gearman.worker.GearmanWorker
-
This method is executed once the worker is ready to accept jobs from the Gearman Job Server.
- work() - Method in class org.gearman.worker.GearmanWorkerImpl
- WORK_COMPLETE - org.gearman.common.GearmanPacketType
- WORK_DATA - org.gearman.common.GearmanPacketType
- WORK_EXCEPTION - org.gearman.common.GearmanPacketType
- WORK_FAIL - org.gearman.common.GearmanPacketType
- WORK_STATUS - org.gearman.common.GearmanPacketType
- WORK_WARNING - org.gearman.common.GearmanPacketType
- WorkerRunner - Class in org.gearman.example
- WorkerRunner(String, int, List<Class<GearmanFunction>>) - Constructor for class org.gearman.example.WorkerRunner
- write(OutputStream) - Method in class org.gearman.common.GearmanPacketHeader
- write(OutputStream) - Method in class org.gearman.common.GearmanPacketImpl
-
Writes the complete packet to the specified OutputStream.
- write(OutputStream, byte[]) - Static method in class org.gearman.util.IOUtil
- write(GearmanPacket) - Method in interface org.gearman.common.GearmanJobServerConnection
-
Writes a
GearmanPacket
into the connection with the Gearman Job Server. - write(GearmanPacket) - Method in class org.gearman.common.GearmanNIOJobServerConnection
All Classes All Packages