com.si.celery.backend

Class RPCBackend

java.lang.Object

com.si.celery.backend.RPCBackend

All Implemented Interfaces:

Backend

public class RPCBackend
extends java.lang.Object
implements Backend

RPC Backend

Constructor Summary

Constructors

Constructor and Description
RPCBackend()

Method Summary

Modifier and Type	Method and Description
void	connect() Creates a connection if required
java.lang.String	get(java.lang.String queueName, java.lang.Long hardTimeLimit) Get a result from a 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

RPCBackend

public RPCBackend()

Method Detail

connect

public void connect()
             throws BackendConnectionException

Creates a connection if required

Specified by:

connect in interface Backend

Throws:

BackendConnectionException

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 to push

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

Get a result from a queue

Specified by:

get in interface Backend

Parameters:

queueName - Queue to get from

hardTimeLimit - Absolute time limit

Returns:

The resulting message

Throws:

GetException - Thrown on get

java.io.IOException - Thrown outside get

java.util.concurrent.ExecutionException - Thrown outside get

java.lang.InterruptedException - Thrown outside get

java.util.concurrent.TimeoutException - Thrown outside get