Package org.yamcs.timeline

Class ActivityScheduler

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.timeline.ActivityScheduler

All Implemented Interfaces:

com.google.common.util.concurrent.Service, ActivityListener, ItemListener

public class ActivityScheduler
extends com.google.common.util.concurrent.AbstractExecutionThreadService
implements ItemListener, ActivityListener

Schedules activities in the timeline

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor	Description
ActivityScheduler()

Method Summary

Modifier and Type	Method	Description
Spec	getSpec()
void	init(TimelineService timelineService, YConfiguration config)
void	onActivityUpdated(Activity activity)	An activity is created or updated
void	onItemCreated(TimelineItem item)	An item was created
void	onItemDeleted(TimelineItem item)	An item was deleted
void	onItemUpdated(TimelineItem item)	An item was updated
protected void	run()
protected void	startUp()
protected void	triggerShutdown()

Methods inherited from class com.google.common.util.concurrent.AbstractExecutionThreadService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Constructor Details

ActivityScheduler

public ActivityScheduler()

Method Details

getSpec

public Spec getSpec()

init

public void init(TimelineService timelineService,
 YConfiguration config)

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

Exception

run

protected void run()
            throws Exception

Specified by:

run in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

Exception

triggerShutdown

protected void triggerShutdown()

Overrides:

triggerShutdown in class com.google.common.util.concurrent.AbstractExecutionThreadService

onItemCreated

public void onItemCreated(TimelineItem item)

Description copied from interface: ItemListener

An item was created

Specified by:

onItemCreated in interface ItemListener

onItemUpdated

public void onItemUpdated(TimelineItem item)

Description copied from interface: ItemListener

An item was updated

Specified by:

onItemUpdated in interface ItemListener

onItemDeleted

public void onItemDeleted(TimelineItem item)

Description copied from interface: ItemListener

An item was deleted

Specified by:

onItemDeleted in interface ItemListener

onActivityUpdated

public void onActivityUpdated(Activity activity)

Description copied from interface: ActivityListener

An activity is created or updated

Specified by:

onActivityUpdated in interface ActivityListener