Package | Description |
---|---|
org.opentripplanner.analyst.broker | |
org.opentripplanner.analyst.cluster |
Modifier and Type | Method and Description |
---|---|
void |
Job.addTask(AnalystClusterRequest task)
Adds a task to this Job, assigning it a task ID number.
|
void |
Broker.enqueuePriorityTask(AnalystClusterRequest task,
org.glassfish.grizzly.http.server.Response response)
Enqueue a task for execution ASAP, planning to return the response over the same HTTP connection.
|
Job |
Broker.findJob(AnalystClusterRequest task)
find the job for a task, creating it if it does not exist
|
Modifier and Type | Method and Description |
---|---|
void |
Broker.enqueueTasks(List<AnalystClusterRequest> tasks)
Enqueue some tasks for queued execution possibly much later.
|
void |
Job.markTasksDelivered(List<AnalystClusterRequest> tasks) |
Modifier and Type | Method and Description |
---|---|
List<AnalystClusterRequest> |
AnalystWorker.getSomeWork(AnalystWorker.WorkType type) |
Modifier and Type | Method and Description |
---|---|
void |
AnalystWorker.deleteRequest(AnalystClusterRequest clusterRequest)
Tell the broker that the given message has been successfully processed by a worker (HTTP DELETE).
|
void |
AnalystWorker.finishPriorityTask(AnalystClusterRequest clusterRequest,
Object result)
Signal the broker that the given high-priority task is completed, providing a result.
|
Copyright © 2018. All rights reserved.