com.atlassian.mywork.client.reliability
Class DefaultReliabilityService

java.lang.Object
  com.atlassian.mywork.client.reliability.DefaultReliabilityService

All Implemented Interfaces:

ReliabilityService

public class DefaultReliabilityService
extends java.lang.Object
implements ReliabilityService

An implementation of ReliabilityService.

This class is safe for use from multiple threads.

Constructor Summary

DefaultReliabilityService(Scheduler scheduler)

Method Summary

void	addWorker(UnreliableWorker worker) Register a UnreliableWorker, so that it may be called upon to perform tasks.
void	removeWorker(UnreliableWorker worker) Deregister a UnreliableWorker, so that it may be called upon to perform tasks.
java.util.concurrent.Future<java.lang.String>	submit(UnreliableTask task) Submit an UnreliableTask for reliable execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultReliabilityService

public DefaultReliabilityService(Scheduler scheduler)

Method Detail

addWorker

public void addWorker(UnreliableWorker worker)

Description copied from interface: ReliabilityService

Register a UnreliableWorker, so that it may be called upon to perform tasks.

Specified by:

addWorker in interface ReliabilityService

Parameters:

worker - the UnreliableWorker to register

removeWorker

public void removeWorker(UnreliableWorker worker)

Description copied from interface: ReliabilityService

Deregister a UnreliableWorker, so that it may be called upon to perform tasks.

Specified by:

removeWorker in interface ReliabilityService

Parameters:

worker - the UnreliableWorker to deregister

submit

public java.util.concurrent.Future<java.lang.String> submit(UnreliableTask task)

Description copied from interface: ReliabilityService

Submit an UnreliableTask for reliable execution.

Specified by:

submit in interface ReliabilityService

Parameters:

task - the UnreliableTask being submitted

Returns:

the Future containing the JSON String result of the task