com.si.celery.backend

Class RedisBackend

java.lang.Object

com.si.celery.backend.RedisBackend

All Implemented Interfaces:

Backend, java.lang.AutoCloseable

public class RedisBackend
extends java.lang.Object
implements Backend, java.lang.AutoCloseable

Redis backend client

Constructor Summary

Constructors

Constructor and Description
RedisBackend()

Method Summary

Modifier and Type	Method and Description
void	close() Close objects that need to be closed.
void	connect() Setup the client.
java.lang.String	get(java.lang.String queueName, java.lang.Long hardTimeLimit) Obtain a message from the queue
void	push(SubtaskRunner task, AsyncResult result) Push to the queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisBackend

public RedisBackend()

Method Detail

connect

public void connect()
             throws BackendConnectionException

Setup the client. No connection just complies with interface.

Specified by:

connect in interface Backend

Throws:

BackendConnectionException - thrown on failure

push

public void push(SubtaskRunner task,
                 AsyncResult result)
          throws PushException

Push to the queue.

Specified by:

push in interface Backend

Parameters:

task - The task pushing to the queue

result - Async result

Throws:

PushException - Thrown on failure

get

public 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

Obtain a message from the queue

Specified by:

get in interface Backend

Parameters:

queueName - Queue to get from

hardTimeLimit - Absolute time limit

Returns:

The message as a string

Throws:

GetException - Thrown on get

java.io.IOException - Thrown outside of get

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

java.lang.InterruptedException - Thrown outside of get

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

close

public void close()

Close objects that need to be closed. Autocloseable

Specified by:

close in interface java.lang.AutoCloseable