com.si.celery.backend

Interface Backend

All Known Implementing Classes:

RedisBackend, RPCBackend

public interface Backend

Backend interface

Method Summary

Modifier and Type	Method and Description
void	connect() Connect to the backend
java.lang.String	get(java.lang.String queueName, java.lang.Long hardTimeLimit) Get a message from the backend
void	push(SubtaskRunner task, AsyncResult result) Push a message to the backend from a worker

Method Detail

connect

void connect()
      throws BackendConnectionException

Connect to the backend

Throws:

BackendConnectionException - thrown on failure

push

void push(SubtaskRunner task,
          AsyncResult result)
   throws PushException

Push a message to the backend from a worker

Parameters:

task - The task pushing to the queue

result - Async result

Throws:

PushException - Thrown on failure to push

get

java.lang.String get(java.lang.String queueName,
                     java.lang.Long hardTimeLimit)
              throws GetException,
                     java.io.IOException,
                     java.util.concurrent.ExecutionException,
                     java.lang.InterruptedException,
                     java.util.concurrent.TimeoutException

Get a message from the backend

Parameters:

queueName - Queue to get from

hardTimeLimit - Absolute time limit

Returns:

Message string

Throws:

GetException - Thrown on failure to get

java.io.IOException - Exception outside of get

java.util.concurrent.ExecutionException - Exception outside of get

java.lang.InterruptedException - Exception outside of get

java.util.concurrent.TimeoutException - Exception outside of get