com.google.appengine.api.taskqueue.dev
Class LocalTaskQueue

java.lang.Object
  AbstractLocalRpcService
      com.google.appengine.api.taskqueue.dev.LocalTaskQueue

@ServiceProvider(value=)
public final class LocalTaskQueue
extends AbstractLocalRpcService

A local implementation of the Task Queue service interface backed by Quartz (http://www.opensymphony.com/quartz). This class is responsible for managing the lifecycle of the Quartz Scheduler but otherwise delegates to DevQueue for all the scheduling intelligence.

Field Summary

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 Summary

LocalTaskQueue()

Method Summary

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.
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()

Methods inherited from class java.lang.Object

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

Field Detail

PACKAGE

public static final java.lang.String PACKAGE

The package name for this service.

See Also:

Constant Field Values

DISABLE_AUTO_TASK_EXEC_PROP

public static final java.lang.String DISABLE_AUTO_TASK_EXEC_PROP

The name of a property that disables automatic task execution. If this property exists and is set to true in the properties argument to init(LocalServiceContext, java.util.Map) then the schedule will not automatically run any tasks. Manual task execution will still work as normal.

See Also:

Constant Field Values

QUEUE_XML_PATH_PROP

public static final java.lang.String QUEUE_XML_PATH_PROP

Overrides the path of queue.xml. Must be a full path, e.g. /usr/local/dev/myapp/tests/queue.xml

See Also:

Constant Field Values

CALLBACK_CLASS_PROP

public static final java.lang.String CALLBACK_CLASS_PROP

Overrides the 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.

See Also:

Constant Field Values

Constructor Detail

LocalTaskQueue

public LocalTaskQueue()

Method Detail

init

public void init(LocalServiceContext context,
                 java.util.Map<java.lang.String,java.lang.String> properties)

start

public void start()

stop

public void stop()

getPackage

public java.lang.String getPackage()

add

public TaskQueueAddResponse add(Status status,
                                TaskQueueAddRequest addRequest)

purgeQueue

public TaskQueuePurgeQueueResponse purgeQueue(Status status,
                                              TaskQueuePurgeQueueRequest purgeQueueRequest)

PurgeQueue RPC implementation.

bulkAdd

public TaskQueueBulkAddResponse bulkAdd(Status status,
                                        TaskQueueBulkAddRequest bulkAddRequest)

BulkAdd RPC implementation.

delete

public TaskQueueDeleteResponse delete(Status status,
                                      TaskQueueDeleteRequest request)

Delete RPC implementation.

queryAndOwnTasks

public TaskQueueQueryAndOwnTasksResponse queryAndOwnTasks(Status status,
                                                          TaskQueueQueryAndOwnTasksRequest request)

modifyTaskLease

public TaskQueueModifyTaskLeaseResponse modifyTaskLease(Status status,
                                                        TaskQueueModifyTaskLeaseRequest request)

getQueueStateInfo

public java.util.Map<java.lang.String,QueueStateInfo> getQueueStateInfo()

Returns a map of QueueStateInfo objects keyed by queue name.

This is not part of the public interface. It is used by the dev server admin console Task Queue Viewer function.

flushQueue

public void flushQueue(java.lang.String queueName)

Remove all entries from a queue.

deleteTask

public boolean deleteTask(java.lang.String queueName,
                          java.lang.String taskName)

Delete a task by name.

Returns:

False if the task name was not found.

runTask

public boolean runTask(java.lang.String queueName,
                       java.lang.String taskName)

Run a task by name.

Returns:

False if the task name was not found.

getMaximumDeadline

public java.lang.Double getMaximumDeadline(boolean isOfflineRequest)