public interface Backend
| 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
|
void connect()
throws BackendConnectionException
BackendConnectionException - thrown on failurevoid push(SubtaskRunner task, AsyncResult result) throws PushException
task - The task pushing to the queueresult - Async resultPushException - Thrown on failure to pushjava.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
queueName - Queue to get fromhardTimeLimit - Absolute time limitGetException - Thrown on failure to getjava.io.IOException - Exception outside of getjava.util.concurrent.ExecutionException - Exception outside of getjava.lang.InterruptedException - Exception outside of getjava.util.concurrent.TimeoutException - Exception outside of get