| Constructor and Description |
|---|
RPCBackend() |
| 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
|
public void connect()
throws BackendConnectionException
connect in interface BackendBackendConnectionExceptionpublic void push(SubtaskRunner task, AsyncResult result) throws PushException
push in interface Backendtask - The task pushing to the queueresult - Async resultPushException - Thrown on failure to pushpublic 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 in interface BackendqueueName - Queue to get fromhardTimeLimit - Absolute time limitGetException - Thrown on getjava.io.IOException - Thrown outside getjava.util.concurrent.ExecutionException - Thrown outside getjava.lang.InterruptedException - Thrown outside getjava.util.concurrent.TimeoutException - Thrown outside get