Uses of Class
net.greghaines.jesque.Job

Packages that use Job

Package	Description
net.greghaines.jesque
net.greghaines.jesque.admin
net.greghaines.jesque.client
net.greghaines.jesque.meta
net.greghaines.jesque.meta.dao.impl
net.greghaines.jesque.utils
net.greghaines.jesque.worker

Uses of Job in net.greghaines.jesque

Methods in net.greghaines.jesque that return Job

Modifier and Type	Method and Description
Job	JobFailure.getPayload()
Job	WorkerStatus.getPayload()

Methods in net.greghaines.jesque with parameters of type Job

Modifier and Type	Method and Description
void	JobFailure.setPayload(Job payload) Set the job.
void	WorkerStatus.setPayload(Job payload) Set the job.

Constructors in net.greghaines.jesque with parameters of type Job

Constructor and Description
Job(Job origJob) Cloning constructor.

Uses of Job in net.greghaines.jesque.admin

Methods in net.greghaines.jesque.admin with parameters of type Job

Modifier and Type	Method and Description
protected Object	AdminImpl.execute(Job job, String curQueue, Object instance) Executes the given job.
void	AdminClient.publish(Job job) Publishes a job on the ResqueConstants.ADMIN_CHANNEL channel.
void	AbstractAdminClient.publish(Job job) Publishes a job on the ResqueConstants.ADMIN_CHANNEL channel.
void	AdminClient.publish(String channel, Job job) Publishes a job on the given channel.
void	AbstractAdminClient.publish(String channel, Job job) Publishes a job on the given channel.

Uses of Job in net.greghaines.jesque.client

Methods in net.greghaines.jesque.client with parameters of type Job

Modifier and Type	Method and Description
void	Client.delayedEnqueue(String queue, Job job, long future) Queues a job in a given queue to be run in the future.
void	AbstractClient.delayedEnqueue(String queue, Job job, long future) Queues a job in a given queue to be run in the future.
void	Client.enqueue(String queue, Job job) Queues a job in a given queue to be run.
void	AbstractClient.enqueue(String queue, Job job) Queues a job in a given queue to be run.
void	Client.priorityEnqueue(String queue, Job job) Queues a job with high priority in a given queue to be run.
void	AbstractClient.priorityEnqueue(String queue, Job job) Queues a job with high priority in a given queue to be run.
void	Client.removeDelayedEnqueue(String queue, Job job) Removes a queued future job.
void	AbstractClient.removeDelayedEnqueue(String queue, Job job) Removes a queued future job.

Uses of Job in net.greghaines.jesque.meta

Methods in net.greghaines.jesque.meta that return types with arguments of type Job

Modifier and Type	Method and Description
List<Job>	QueueInfo.getJobs()

Method parameters in net.greghaines.jesque.meta with type arguments of type Job

Modifier and Type	Method and Description
void	QueueInfo.setJobs(List<Job> jobs)

Uses of Job in net.greghaines.jesque.meta.dao.impl

Methods in net.greghaines.jesque.meta.dao.impl with parameters of type Job

Modifier and Type	Method and Description
protected void	FailureDAORedisImpl.enqueue(redis.clients.jedis.Jedis jedis, String queue, Job job)

Uses of Job in net.greghaines.jesque.utils

Methods in net.greghaines.jesque.utils with parameters of type Job

Modifier and Type	Method and Description
static Object	JesqueUtils.materializeJob(Job job) Materializes a job by assuming the getClassName() is a fully-qualified Java type.
static Object	JesqueUtils.materializeJob(Job job, Map<String,Class<?>> jobTypes) Materializes a job by looking up getClassName() in the provided map of job types.

Uses of Job in net.greghaines.jesque.worker

Methods in net.greghaines.jesque.worker with parameters of type Job

Modifier and Type	Method and Description
protected Object	WorkerImpl.execute(Job job, String curQueue, Object instance) Executes the given job.
protected String	WorkerImpl.failMsg(Throwable t, String queue, Job job) Create and serialize a JobFailure.
protected void	WorkerImpl.failure(Throwable t, Job job, String curQueue) Update the status in Redis on failure
void	WorkerListenerDelegate.fireEvent(WorkerEvent event, Worker worker, String queue, Job job, Object runner, Object result, Throwable t) Notify all WorkerListeners currently registered for the given WorkerEvent.
Object	ReflectiveJobFactory.materializeJob(Job job) Materializes a job.
Object	JobFactory.materializeJob(Job job) Materializes a job.
Object	MapBasedJobFactory.materializeJob(Job job) Materializes a job.
void	WorkerListener.onEvent(WorkerEvent event, Worker worker, String queue, Job job, Object runner, Object result, Throwable t) This method is called by the Worker upon the occurence of a registered WorkerEvent.
void	LoggingWorkerListener.onEvent(WorkerEvent event, Worker worker, String queue, Job job, Object runner, Object result, Throwable t) If there is a Throwable, it is logged as an error, otherwise it is logged as a debug message.
protected void	WorkerImpl.process(Job job, String curQueue) Materializes and executes the given job.
protected String	WorkerImpl.statusMsg(String queue, Job job) Create and serialize a WorkerStatus.
protected void	WorkerImpl.success(Job job, Object runner, Object result, String curQueue) Update the status in Redis on success.