org.ow2.sirocco.cloudmanager.connector.util.jobmanager.impl
Class JobManager

java.lang.Object
  org.ow2.sirocco.cloudmanager.connector.util.jobmanager.impl.JobManager

All Implemented Interfaces:

org.osgi.service.cm.ManagedService, IJobManager

public class JobManager
extends Object
implements IJobManager, org.osgi.service.cm.ManagedService

Field Summary

static long	DEFAULT_JOB_RETENTION_TIME_IN_SECONDS
static long	DEFAULT_JOB_WATCHER_PERIOD_IN_SECONDS
static String	JOB_RETENTION_TIME_PROP_NAME
static String	JOB_WATCHER_PERIOD_PROP_NAME

Method Summary

List<Job>	getAllJobs()
Job	getJobById(String id)
Job	newJob(CloudResource targetEntity, CloudResource affectedEntity, String action, com.google.common.util.concurrent.ListenableFuture<?> result)
static JobManager	newJobManager()
static void	rawEmitDelayedQueueMessage(Serializable payload, long delayMilli, String queueFactory, String queueName)
void	setNotificationOnJobCompletion(String jobId)
void	shutdown()
void	start()
void	updated(Dictionary properties)

Methods inherited from class java.lang.Object

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

Field Detail

JOB_WATCHER_PERIOD_PROP_NAME

public static String JOB_WATCHER_PERIOD_PROP_NAME

JOB_RETENTION_TIME_PROP_NAME

public static String JOB_RETENTION_TIME_PROP_NAME

DEFAULT_JOB_WATCHER_PERIOD_IN_SECONDS

public static long DEFAULT_JOB_WATCHER_PERIOD_IN_SECONDS

DEFAULT_JOB_RETENTION_TIME_IN_SECONDS

public static long DEFAULT_JOB_RETENTION_TIME_IN_SECONDS

Method Detail

updated

public void updated(Dictionary properties)
             throws org.osgi.service.cm.ConfigurationException

Specified by:

updated in interface org.osgi.service.cm.ManagedService

Throws:

org.osgi.service.cm.ConfigurationException

start

public void start()

shutdown

public void shutdown()

newJobManager

public static JobManager newJobManager()

newJob

public Job newJob(CloudResource targetEntity,
                  CloudResource affectedEntity,
                  String action,
                  com.google.common.util.concurrent.ListenableFuture<?> result)

Specified by:

newJob in interface IJobManager

setNotificationOnJobCompletion

public void setNotificationOnJobCompletion(String jobId)
                                    throws Exception

Specified by:

setNotificationOnJobCompletion in interface IJobManager

Throws:

Exception

getJobById

public Job getJobById(String id)

Specified by:

getJobById in interface IJobManager

getAllJobs

public List<Job> getAllJobs()

Specified by:

getAllJobs in interface IJobManager

rawEmitDelayedQueueMessage

public static void rawEmitDelayedQueueMessage(Serializable payload,
                                              long delayMilli,
                                              String queueFactory,
                                              String queueName)
                                       throws Exception

Throws:

Exception