org.opentripplanner.analyst.broker

Class Job

java.lang.Object

org.opentripplanner.analyst.broker.Job

public class Job
extends Object

FIXME delivered tasks map is oblivious to multiple tasks having the same ID. In fact we just generate numeric queue task IDs. Origin point IDs will be handled at the application layer.

Field Summary

Fields

Modifier and Type	Field and Description
String	jobId

Constructor Summary

Constructors

Constructor and Description
Job(String jobId)

Method Summary

Modifier and Type	Method and Description
void	addTask(AnalystClusterRequest task) Adds a task to this Job, assigning it a task ID number.
boolean	containsTask(int taskId)
int	getCompletedTaskCount()
int	getTotalTaskCount()
boolean	isComplete()
void	markTaskCompleted(int taskId)
void	markTasksDelivered(List<AnalystClusterRequest> tasks)
int	redeliver() Find all tasks that are currently invisible but have passed their invisibility timeout without being marked completed, and make all these tasks visible again for delivery.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

jobId

public final String jobId

Constructor Detail

Job

public Job(String jobId)

Method Detail

addTask

public void addTask(AnalystClusterRequest task)

Adds a task to this Job, assigning it a task ID number.

markTasksDelivered

public void markTasksDelivered(List<AnalystClusterRequest> tasks)

redeliver

public int redeliver()

Find all tasks that are currently invisible but have passed their invisibility timeout without being marked completed, and make all these tasks visible again for delivery. TODO maybe this should only be triggered when the awaiting delivery queue is empty to reduce double-delivery.

markTaskCompleted

public void markTaskCompleted(int taskId)

getTotalTaskCount

public int getTotalTaskCount()

getCompletedTaskCount

public int getCompletedTaskCount()

isComplete

public boolean isComplete()

containsTask

public boolean containsTask(int taskId)