org.opendaylight.genius.datastoreutils

Class JobEntry

java.lang.Object

org.opendaylight.genius.datastoreutils.JobEntry

public class JobEntry
extends Object

JobEntry is the entity built per job submitted by the application and enqueued to the book-keeping data structure.

Constructor Summary

Constructors

Constructor and Description
JobEntry(String key, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker, RollbackCallable rollbackWorker, int maxRetries)

Method Summary

Modifier and Type	Method and Description
int	decrementRetryCountAndGet()
List<com.google.common.util.concurrent.ListenableFuture<Void>>	getFutures()
String	getKey() Get the key provided by the application that segregates the callables that can be run parallely.
Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>>	getMainWorker()
int	getRetryCount()
RollbackCallable	getRollbackWorker()
void	setFutures(List<com.google.common.util.concurrent.ListenableFuture<Void>> futures)
void	setMainWorker(Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobEntry

public JobEntry(String key,
                Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker,
                RollbackCallable rollbackWorker,
                int maxRetries)

Method Detail

getKey

public String getKey()

Get the key provided by the application that segregates the callables that can be run parallely. NOTE: Currently, this is a string. Can be converted to Object where Object implementation should provide the hashcode and equals methods.

getMainWorker

public Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> getMainWorker()

setMainWorker

public void setMainWorker(Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker)

getRollbackWorker

public RollbackCallable getRollbackWorker()

getRetryCount

public int getRetryCount()

decrementRetryCountAndGet

public int decrementRetryCountAndGet()

getFutures

public List<com.google.common.util.concurrent.ListenableFuture<Void>> getFutures()

setFutures

public void setFutures(List<com.google.common.util.concurrent.ListenableFuture<Void>> futures)

toString

public String toString()

Overrides:

toString in class Object