A B C D E F G H I J L M N O P Q R S T U V W

A

acceptContent - Variable in class com.si.celery.conf.Config

acksLate - Variable in class com.si.celery.conf.Config

Admin - Class in com.si.celery.conf

Administrator object

Admin(String, String) - Constructor for class com.si.celery.conf.Admin

Constructor

admins - Variable in class com.si.celery.conf.Config

alwaysEager - Variable in class com.si.celery.conf.Config

AMQPConnectionFactory - Class in com.si.celery.connection

Basic Connection using AMQP

AMQPConnectionFactory() - Constructor for class com.si.celery.connection.AMQPConnectionFactory

Constructor

applyAsync() - Method in class com.si.celery.task.Chain

applyAsync() - Method in class com.si.celery.task.Chord

applyAsync() - Method in class com.si.celery.task.Group

applyAsync(String, Long, Long, Long) - Method in class com.si.celery.task.Task

Apply a task asynchronously with some common options to be set

applyAsync(Long, Long, Long) - Method in class com.si.celery.task.Task

Apply a task asynchronously with some common options to be set

applyAsync() - Method in class com.si.celery.task.Task

Calls delay for best practices

applyAsync() - Method in interface com.si.celery.task.TaskOrganization

AsyncResult - Class in com.si.celery.task.result

A task result

AsyncResult() - Constructor for class com.si.celery.task.result.AsyncResult

B

Backend - Interface in com.si.celery.backend

Backend interface

BackendConnectionException - Exception in com.si.celery.backend.exception

Backend connection exception

BackendConnectionException(String) - Constructor for exception com.si.celery.backend.exception.BackendConnectionException

Constructor

backendType - Variable in class com.si.celery.conf.Config

BackendType - Enum in com.si.celery.enums

Enumeration for the backend type

basicConsume(String, Channel, Consumer) - Method in class com.si.celery.broker.consumer.BasicRabbitMQConsumer

Perform a basic consumption with a given consumer.

BasicRabbitMQConsumer - Class in com.si.celery.broker.consumer

Basic Rabbit MQ Consumer

BasicRabbitMQConsumer() - Constructor for class com.si.celery.broker.consumer.BasicRabbitMQConsumer

bindToQueue(String, String, String) - Method in class com.si.celery.queue.ClientQueueUtils

Bind to the specified queue

broadcastExchange - Variable in class com.si.celery.conf.Config

broadcastExchangeType - Variable in class com.si.celery.conf.Config

broadcastQueue - Variable in class com.si.celery.conf.Config

Broker - Interface in com.si.celery.broker

Broker interface

broker - Variable in class com.si.celery.conf.Config

BrokerCloseException - Exception in com.si.celery.broker.exception

Broker closing exception

BrokerCloseException(String) - Constructor for exception com.si.celery.broker.exception.BrokerCloseException

Constructor

BrokerConnectionException - Exception in com.si.celery.broker.exception

Broker Connection Exception

BrokerConnectionException(String) - Constructor for exception com.si.celery.broker.exception.BrokerConnectionException

Constructor

brokerConnectionMaxRetries - Variable in class com.si.celery.conf.Config

brokerConnectionRetry - Variable in class com.si.celery.conf.Config

brokerConnectionTimeout - Variable in class com.si.celery.conf.Config

BrokerSendTaskException - Exception in com.si.celery.broker.exception

Send task exception

BrokerSendTaskException(String) - Constructor for exception com.si.celery.broker.exception.BrokerSendTaskException

Constructor

brokerType - Variable in class com.si.celery.conf.Config

BrokerType - Enum in com.si.celery.enums

build() - Method in class com.si.celery.connection.AMQPConnectionFactory

Build the AMQP Connection

build() - Method in interface com.si.celery.connection.ConnectionBuilder

ByteConverter - Class in com.si.celery.broker.bytes

Byte converter

ByteConverter() - Constructor for class com.si.celery.broker.bytes.ByteConverter

C

Celery - Class in com.si.celery

The celery client for submitting and receiving tasks

Celery() - Constructor for class com.si.celery.Celery

celerybeatLogFile - Variable in class com.si.celery.conf.Config

celerybeatLogLevel - Variable in class com.si.celery.conf.Config

celerybeatMaxLoopInterval - Variable in class com.si.celery.conf.Config

celerybeatScheduleFilename - Variable in class com.si.celery.conf.Config

celeryCacheBackend - Variable in class com.si.celery.conf.Config

CeleryLogger - Class in com.si.celery.logging

CeleryLogger() - Constructor for class com.si.celery.logging.CeleryLogger

celerymonLogFile - Variable in class com.si.celery.conf.Config

celerymonLogLevel - Variable in class com.si.celery.conf.Config

celerySendTaskErrorEmails - Variable in class com.si.celery.conf.Config

Chain - Class in com.si.celery.task

Chain object

Chain() - Constructor for class com.si.celery.task.Chain

Chord - Class in com.si.celery.task

Chord with tasks

Chord() - Constructor for class com.si.celery.task.Chord

Client - Class in com.si.celery.client

A client thread which sends a task.

Client(Config) - Constructor for class com.si.celery.client.Client

ClientQueueUtils - Class in com.si.celery.queue

Client Queue helper library.

ClientQueueUtils(ConnectionInf) - Constructor for class com.si.celery.queue.ClientQueueUtils

ClientQueueUtils(Connection, Channel) - Constructor for class com.si.celery.queue.ClientQueueUtils

Constructor with connection and channel

clone() - Method in class com.si.celery.conf.Config

close() - Method in class com.si.celery.backend.RedisBackend

Close objects that need to be closed.

close() - Method in class com.si.celery.broker.RabbitMQBroker

Close connections and other objects.

close() - Method in class com.si.celery.Celery

Closes the program and performs cleanup.

com.si.celery - package com.si.celery

com.si.celery.backend - package com.si.celery.backend

com.si.celery.backend.exception - package com.si.celery.backend.exception

com.si.celery.backend.rabbit - package com.si.celery.backend.rabbit

com.si.celery.broker - package com.si.celery.broker

com.si.celery.broker.bytes - package com.si.celery.broker.bytes

com.si.celery.broker.consumer - package com.si.celery.broker.consumer

com.si.celery.broker.exception - package com.si.celery.broker.exception

com.si.celery.broker.json - package com.si.celery.broker.json

com.si.celery.client - package com.si.celery.client

com.si.celery.conf - package com.si.celery.conf

com.si.celery.connection - package com.si.celery.connection

com.si.celery.enums - package com.si.celery.enums

com.si.celery.logging - package com.si.celery.logging

com.si.celery.message - package com.si.celery.message

com.si.celery.message.runtime - package com.si.celery.message.runtime

com.si.celery.queue - package com.si.celery.queue

com.si.celery.task - package com.si.celery.task

com.si.celery.task.result - package com.si.celery.task.result

com.si.celery.task.result.json - package com.si.celery.task.result.json

com.si.celery.task.subtask - package com.si.celery.task.subtask

com.si.celery.task.subtask.exception - package com.si.celery.task.subtask.exception

com.si.celery.worker - package com.si.celery.worker

completedCount() - Method in class com.si.celery.task.result.TaskSetResult

Count of completed tasks including subtasks

Config - Class in com.si.celery.conf

Configuration class attempting to mimic Python Celery as much as possible.

Config() - Constructor for class com.si.celery.conf.Config

connect() - Method in interface com.si.celery.backend.Backend

Connect to the backend

connect() - Method in class com.si.celery.backend.RedisBackend

Setup the client.

connect() - Method in class com.si.celery.backend.RPCBackend

Creates a connection if required

connect() - Method in interface com.si.celery.broker.Broker

connect() - Method in class com.si.celery.broker.RabbitMQBroker

Connect to the broker

ConnectionBuilder - Interface in com.si.celery.connection

ConnectionInf - Class in com.si.celery.connection

Information for the connection

ConnectionInf(Connection, Channel) - Constructor for class com.si.celery.connection.ConnectionInf

Constructor

convertArgsToString(Object[]) - Static method in class com.si.celery.broker.json.JSONUtils

Convert arguments to a String

convertArrayListToJson(Object) - Static method in class com.si.celery.broker.json.JSONUtils

Convert ArrayList to Json

convertArrayToJson(Object) - Static method in class com.si.celery.broker.json.JSONUtils

Convery array to json

convertBodyToString(Object) - Static method in class com.si.celery.broker.json.JSONUtils

Convert the body objects to a json string.

convertKwargsToString(Map<String, Object>) - Static method in class com.si.celery.broker.json.JSONUtils

Convert mapped arguments to a json string

convertMapToJson(Object) - Static method in class com.si.celery.broker.json.JSONUtils

Convert a map to a json object

convertObjectToBytes(Object) - Static method in class com.si.celery.broker.bytes.ByteConverter

Convert object to bytes

createResultQueue(String, boolean) - Method in class com.si.celery.queue.ClientQueueUtils

Create a queue

createRoutingQueue(String, boolean) - Method in class com.si.celery.queue.ClientQueueUtils

Create the routing queue

createTaskResultPayload(SubtaskRunner) - Static method in class com.si.celery.task.result.json.ResultJsonUtils

Create the json payload for a push

D

databaseEngineOptions - Variable in class com.si.celery.conf.Config

declareExchange(String, String) - Method in class com.si.celery.queue.ClientQueueUtils

Declare an exchange and exchange type.

defaultDeliveryMode - Variable in class com.si.celery.conf.Config

defaultExchangeType - Variable in class com.si.celery.conf.Config

defaultQueue - Variable in class com.si.celery.conf.Config

defaultRateLimit - Variable in class com.si.celery.conf.Config

defaultRoutingKey - Variable in class com.si.celery.conf.Config

delay() - Method in class com.si.celery.task.Task

Delay configured with defaults

delay(Long) - Method in class com.si.celery.task.Task

Run the task on a specified delay

destroy(String) - Method in class com.si.celery.queue.ClientQueueUtils

Attempt to destroy the queue

disableRateLimits - Variable in class com.si.celery.conf.Config

E

eagerPropogatesExceptions - Variable in class com.si.celery.conf.Config

eventExchange - Variable in class com.si.celery.conf.Config

eventExchangeType - Variable in class com.si.celery.conf.Config

eventQueue - Variable in class com.si.celery.conf.Config

eventRoutingKey - Variable in class com.si.celery.conf.Config

eventSerializer - Variable in class com.si.celery.conf.Config

executeChildren() - Method in class com.si.celery.task.Task

Execute the children

F

failed() - Method in class com.si.celery.task.result.TaskSetResult

Whether the task failed

G

get(String, Long) - Method in interface com.si.celery.backend.Backend

Get a message from the backend

get(String, Long) - Method in class com.si.celery.backend.RedisBackend

Obtain a message from the queue

get(String, Long) - Method in class com.si.celery.backend.RPCBackend

Get a result from a queue

get() - Method in class com.si.celery.task.subtask.SubtaskRunner

Get the asynchronous results.

get() - Method in class com.si.celery.task.Task

Bullds and calls get.

getchannel() - Method in class com.si.celery.connection.ConnectionInf

Obtain the channel

getConnection() - Method in class com.si.celery.connection.ConnectionInf

Return the connection

getEmail_address() - Method in class com.si.celery.conf.Admin

Get the admin email address

GetException - Exception in com.si.celery.backend.exception

A push exception

GetException(String) - Constructor for exception com.si.celery.backend.exception.GetException

Constructor

getName() - Method in class com.si.celery.conf.Admin

Get the name

Group - Class in com.si.celery.task

Group object

Group() - Constructor for class com.si.celery.task.Group

H

handleCancel(String) - Method in class com.si.celery.backend.rabbit.RabbitBackendConsumer

Handle a cancel event

handleDelivery(String, Envelope, AMQP.BasicProperties, byte[]) - Method in class com.si.celery.backend.rabbit.RabbitBackendConsumer

Handle the delivery of a message.

hasNext() - Method in class com.si.celery.task.result.TaskSetResult

I

ignoreResult - Variable in class com.si.celery.conf.Config

iterate() - Method in class com.si.celery.task.result.TaskSetResult

Iterate through the tasks

J

join() - Method in class com.si.celery.task.result.TaskSetResult

Wait for the tasks to complete

JSONUtils - Class in com.si.celery.broker.json

JSON utilities

JSONUtils() - Constructor for class com.si.celery.broker.json.JSONUtils

L

logError(String) - Static method in class com.si.celery.logging.CeleryLogger

logInf(String) - Static method in class com.si.celery.logging.CeleryLogger

logWarn(String) - Static method in class com.si.celery.logging.CeleryLogger

M

mailHost - Variable in class com.si.celery.conf.Config

mailHostPassword - Variable in class com.si.celery.conf.Config

mailHostUser - Variable in class com.si.celery.conf.Config

mailPort - Variable in class com.si.celery.conf.Config

maxCachedResults - Variable in class com.si.celery.conf.Config

N

next() - Method in class com.si.celery.task.result.TaskSetResult

numThreads - Variable in class com.si.celery.conf.Config

O

Options - Class in com.si.celery.task.subtask

Subclass options

Options() - Constructor for class com.si.celery.task.subtask.Options

P

parsePayloadJson() - Method in class com.si.celery.task.result.AsyncResult

Parse the payload

push(SubtaskRunner, AsyncResult) - Method in interface com.si.celery.backend.Backend

Push a message to the backend from a worker

push(SubtaskRunner, AsyncResult) - Method in class com.si.celery.backend.RedisBackend

Push to the queue.

push(SubtaskRunner, AsyncResult) - Method in class com.si.celery.backend.RPCBackend

Push to the queue

PushException - Exception in com.si.celery.backend.exception

Push Exception

PushException(String) - Constructor for exception com.si.celery.backend.exception.PushException

Constructor

Q

QueuePersistenceType - Enum in com.si.celery.enums

queues - Variable in class com.si.celery.conf.Config

R

RabbitBackendConsumer - Class in com.si.celery.backend.rabbit

Extension of the default consumer

RabbitBackendConsumer(Channel, SettableFuture<String>, String) - Constructor for class com.si.celery.backend.rabbit.RabbitBackendConsumer

Constructs a new instance and records its association to the passed-in channel.

RabbitMQBroker - Class in com.si.celery.broker

Rabbit MQ Broker

RabbitMQBroker(String, Config) - Constructor for class com.si.celery.broker.RabbitMQBroker

Constructor to use in coordination with connect

RabbitMQBroker(ConnectionInf, Config) - Constructor for class com.si.celery.broker.RabbitMQBroker

Constructor taking prebuilt connection information

ready() - Method in class com.si.celery.task.result.TaskSetResult

Whether the task is ready

RedisBackend - Class in com.si.celery.backend

Redis backend client

RedisBackend() - Constructor for class com.si.celery.backend.RedisBackend

registerTask(Object) - Method in class com.si.celery.Celery

Register a task object

registeTask(String) - Method in class com.si.celery.Celery

Add a task by string

resultBackend - Variable in class com.si.celery.conf.Config

resultExchange - Variable in class com.si.celery.conf.Config

ResultJsonUtils - Class in com.si.celery.task.result.json

ResultJsonUtils() - Constructor for class com.si.celery.task.result.json.ResultJsonUtils

ResultMessageV2 - Class in com.si.celery.message

Result message

ResultMessageV2() - Constructor for class com.si.celery.message.ResultMessageV2

resultPersistent - Variable in class com.si.celery.conf.Config

resultSerializer - Variable in class com.si.celery.conf.Config

revoke() - Method in class com.si.celery.task.result.TaskSetResult

Revoke the related tasks

RPCBackend - Class in com.si.celery.backend

RPC Backend

RPCBackend() - Constructor for class com.si.celery.backend.RPCBackend

run() - Method in class com.si.celery.client.Client

RuntimeConfig - Class in com.si.celery.message.runtime

Runtime configuration

RuntimeConfig() - Constructor for class com.si.celery.message.runtime.RuntimeConfig

S

sendEvents - Variable in class com.si.celery.conf.Config

sendTask(String, Object[], Map<String, Object>, String, String, Date, int, Long, Long, Date, int) - Method in interface com.si.celery.broker.Broker

sendTask(String, Object[], Map<String, Object>) - Method in interface com.si.celery.broker.Broker

sendTask(String, Object[], Map<String, Object>, String, String, Date, int, Long, Long, Date, int) - Method in class com.si.celery.broker.RabbitMQBroker

Send a task.

sendTask(String, Object[], Map<String, Object>, Long, Long, int) - Method in class com.si.celery.broker.RabbitMQBroker

Send a task with bare minimum requirements

sendTask(String, Object[], Map<String, Object>) - Method in class com.si.celery.broker.RabbitMQBroker

Send a task with bare minimum requirements

sendTask(String, Object[], Map<String, Object>, String, int, Task[], Options) - Method in class com.si.celery.Celery

Send a task

sendTask(String, Object[], Map<String, Object>, Task[]) - Method in class com.si.celery.Celery

Send a task and await the result by name.

sendTask(String, Object[], Map<String, Object>) - Method in class com.si.celery.Celery

Send a task and await the result by name.

sendTask(String, Object[], Map<String, Object>, Long, long) - Method in class com.si.celery.Celery

Send a task and await the result by name.

serverEmail - Variable in class com.si.celery.conf.Config

setClientProperties(Map<String, Object>) - Method in class com.si.celery.connection.AMQPConnectionFactory

Set the client properties

setClientProperties(Map<String, Object>) - Method in interface com.si.celery.connection.ConnectionBuilder

setConfig(Config) - Method in class com.si.celery.task.Task

Set the task configuration

setEmail_address(String) - Method in class com.si.celery.conf.Admin

Set the email address

setExecutor(ExecutorService) - Method in class com.si.celery.task.Task

Set the executor service for the task

setHost(String) - Method in class com.si.celery.connection.AMQPConnectionFactory

Set the host

setHost(String) - Method in interface com.si.celery.connection.ConnectionBuilder

setName(String) - Method in class com.si.celery.conf.Admin

Set the admin name

setOrigin(String) - Method in interface com.si.celery.broker.Broker

setOrigin(String) - Method in class com.si.celery.broker.RabbitMQBroker

Set the origin

setPassword(String) - Method in class com.si.celery.connection.AMQPConnectionFactory

Set the password

setPassword(String) - Method in interface com.si.celery.connection.ConnectionBuilder

setPort(int) - Method in class com.si.celery.connection.AMQPConnectionFactory

Set the port

setPort(int) - Method in interface com.si.celery.connection.ConnectionBuilder

setQueueName(String) - Method in class com.si.celery.broker.RabbitMQBroker

Allows the push queue to be set

setURI(String) - Method in class com.si.celery.connection.AMQPConnectionFactory

Set the entire URI at once

setURI(String) - Method in interface com.si.celery.connection.ConnectionBuilder

setUsername(String) - Method in class com.si.celery.connection.AMQPConnectionFactory

The username

setUsername(String) - Method in interface com.si.celery.connection.ConnectionBuilder

setVirtualHost(String) - Method in class com.si.celery.connection.AMQPConnectionFactory

Set the virtual host

setVirtualHost(String) - Method in interface com.si.celery.connection.ConnectionBuilder

storeErrorsEvenIfIgnored - Variable in class com.si.celery.conf.Config

submit() - Method in class com.si.celery.Celery

Submit a task using the class

SubtaskException - Exception in com.si.celery.task.subtask.exception

Subtask exception

SubtaskException(String) - Constructor for exception com.si.celery.task.subtask.exception.SubtaskException

Constructor

SubtaskRunner - Class in com.si.celery.task.subtask

Subtask builder

SubtaskRunner() - Constructor for class com.si.celery.task.subtask.SubtaskRunner

succesful() - Method in class com.si.celery.task.result.TaskSetResult

Whether the task was successful

T

Task - Class in com.si.celery.task

Interface for a task

Task(String, Task[], Object[], Map<String, Object>) - Constructor for class com.si.celery.task.Task

Task(String, Object[], Map<String, Object>) - Constructor for class com.si.celery.task.Task

Task(String, Task[], Object[], Map<String, Object>, String, ConnectionInf, Config, BackendType, ExecutorService, String, TaskMessageV2, Options, int) - Constructor for class com.si.celery.task.Task

TaskMessageV2 - Class in com.si.celery.message

Task Message for Celery protocol 2.0

TaskMessageV2() - Constructor for class com.si.celery.message.TaskMessageV2

taskName - Variable in class com.si.celery.task.Task

TaskOrganization - Interface in com.si.celery.task

Task Organization interface

taskResultExpires - Variable in class com.si.celery.conf.Config

taskResultPayloadToString(SubtaskRunner) - Static method in class com.si.celery.task.result.json.ResultJsonUtils

Convert a payload result to a string

TaskSetResult - Class in com.si.celery.task.result

TaskSetResult() - Constructor for class com.si.celery.task.result.TaskSetResult

threadpoolExecutor - Variable in class com.si.celery.conf.Config

ThreadPoolType - Enum in com.si.celery.enums

throwBrokerSendTaskException(Exception) - Method in class com.si.celery.broker.RabbitMQBroker

Throws a send task exception

trackStarted - Variable in class com.si.celery.conf.Config

U

useSSLProtocol() - Method in class com.si.celery.connection.AMQPConnectionFactory

Use the SSL protocol

useSSLProtocol() - Method in interface com.si.celery.connection.ConnectionBuilder

V

valueOf(String) - Static method in enum com.si.celery.enums.BackendType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.si.celery.enums.BrokerType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.si.celery.enums.QueuePersistenceType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.si.celery.enums.ThreadPoolType

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.si.celery.enums.BackendType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.si.celery.enums.BrokerType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.si.celery.enums.QueuePersistenceType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.si.celery.enums.ThreadPoolType

Returns an array containing the constants of this enum type, in the order they are declared.

W

waiting() - Method in class com.si.celery.task.result.TaskSetResult

Whether the task is waiting

Worker - Class in com.si.celery.worker

Celery Worker

Worker() - Constructor for class com.si.celery.worker.Worker

workerPrefetchMultiplier - Variable in class com.si.celery.conf.Config

A B C D E F G H I J L M N O P Q R S T U V W