public final class LocalTaskQueue
extends AbstractLocalRpcService
Scheduler
but otherwise
delegates to DevQueue
for all the scheduling intelligence.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CALLBACK_CLASS_PROP
Overrides the
LocalTaskQueueCallback class that is used to service
async task execution. |
static java.lang.String |
DISABLE_AUTO_TASK_EXEC_PROP
The name of a property that disables automatic task execution.
|
static java.lang.String |
PACKAGE
The package name for this service.
|
static java.lang.String |
QUEUE_XML_PATH_PROP
Overrides the path of queue.xml.
|
Constructor and Description |
---|
LocalTaskQueue() |
Modifier and Type | Method and Description |
---|---|
TaskQueueAddResponse |
add(Status status,
TaskQueueAddRequest addRequest) |
TaskQueueBulkAddResponse |
bulkAdd(Status status,
TaskQueueBulkAddRequest bulkAddRequest)
BulkAdd RPC implementation.
|
TaskQueueDeleteResponse |
delete(Status status,
TaskQueueDeleteRequest request)
Delete RPC implementation.
|
boolean |
deleteTask(java.lang.String queueName,
java.lang.String taskName)
Delete a task by name.
|
TaskQueueFetchQueueStatsResponse |
fetchQueueStats(Status status,
TaskQueueFetchQueueStatsRequest fetchQueueStatsRequest)
FetchQueueStats RPC implementation.
|
void |
flushQueue(java.lang.String queueName)
Remove all entries from a queue.
|
java.lang.Double |
getMaximumDeadline(boolean isOfflineRequest) |
java.lang.String |
getPackage() |
java.util.Map<java.lang.String,QueueStateInfo> |
getQueueStateInfo()
Returns a map of QueueStateInfo objects keyed by queue name.
|
void |
init(LocalServiceContext context,
java.util.Map<java.lang.String,java.lang.String> properties) |
TaskQueueModifyTaskLeaseResponse |
modifyTaskLease(Status status,
TaskQueueModifyTaskLeaseRequest request) |
TaskQueuePurgeQueueResponse |
purgeQueue(Status status,
TaskQueuePurgeQueueRequest purgeQueueRequest)
PurgeQueue RPC implementation.
|
TaskQueueQueryAndOwnTasksResponse |
queryAndOwnTasks(Status status,
TaskQueueQueryAndOwnTasksRequest request) |
boolean |
runTask(java.lang.String queueName,
java.lang.String taskName)
Run a task by name.
|
void |
start() |
void |
stop() |
public static final java.lang.String PACKAGE
public static final java.lang.String DISABLE_AUTO_TASK_EXEC_PROP
properties
argument to init(LocalServiceContext, java.util.Map<java.lang.String, java.lang.String>)
then the schedule will not automatically run
any tasks. Manual task execution will still work as normal.public static final java.lang.String QUEUE_XML_PATH_PROP
public static final java.lang.String CALLBACK_CLASS_PROP
LocalTaskQueueCallback
class that is used to service
async task execution. The value of this property must be the
fully-qualified name of a class with a public, no-arg constructor that
implements the LocalTaskQueueCallback
interface.public void init(LocalServiceContext context, java.util.Map<java.lang.String,java.lang.String> properties)
public void start()
public void stop()
public java.lang.String getPackage()
public TaskQueueAddResponse add(Status status, TaskQueueAddRequest addRequest)
public TaskQueueFetchQueueStatsResponse fetchQueueStats(Status status, TaskQueueFetchQueueStatsRequest fetchQueueStatsRequest)
public TaskQueuePurgeQueueResponse purgeQueue(Status status, TaskQueuePurgeQueueRequest purgeQueueRequest)
public TaskQueueBulkAddResponse bulkAdd(Status status, TaskQueueBulkAddRequest bulkAddRequest)
public TaskQueueDeleteResponse delete(Status status, TaskQueueDeleteRequest request)
public TaskQueueQueryAndOwnTasksResponse queryAndOwnTasks(Status status, TaskQueueQueryAndOwnTasksRequest request)
public TaskQueueModifyTaskLeaseResponse modifyTaskLease(Status status, TaskQueueModifyTaskLeaseRequest request)
public java.util.Map<java.lang.String,QueueStateInfo> getQueueStateInfo()
This is not part of the public interface. It is used by the dev server admin console Task Queue Viewer function.
public void flushQueue(java.lang.String queueName)
public boolean deleteTask(java.lang.String queueName, java.lang.String taskName)
public boolean runTask(java.lang.String queueName, java.lang.String taskName)
public java.lang.Double getMaximumDeadline(boolean isOfflineRequest)