Package org.yamcs.activities

Class ActivityService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.activities.ActivityService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class ActivityService
extends com.google.common.util.concurrent.AbstractService

Yamcs service for executing activities.

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACTIVITY_TYPE_MANUAL

Constructor Summary

Constructors

Constructor	Description
ActivityService()

Method Summary

Modifier and Type	Method	Description
void	addActivityListener(ActivityListener listener)
void	addActivityLogListener(ActivityLogListener listener)
Activity	cancelActivity(UUID id, User user)
Activity	completeManualActivity(UUID id, String failureReason, User user)
protected void	doStart()
protected void	doStop()
Activity	getActivity(UUID id)
ActivityDb	getActivityDb()
ActivityLogDb	getActivityLogDb()
ActivityExecutor	getExecutor(String activity)
Collection<ActivityExecutor>	getExecutors()
List<Activity>	getOngoingActivities()
Spec	getSpec()
String	getYamcsInstance()
void	init(String yamcsInstance, YConfiguration config)
boolean	isStopRequested(Activity activity)
void	logActivityError(Activity activity, String message)
void	logActivityInfo(Activity activity, String message)
void	logActivityWarning(Activity activity, String message)
void	logServiceError(Activity activity, String message)
void	logServiceInfo(Activity activity, String message)
void	logServiceWarning(Activity activity, String message)
Activity	prepareActivity(String type, Map<String,Object> args, User user, String comment)
void	removeActivityListener(ActivityListener listener)
void	removeActivityLogListener(ActivityLogListener listener)
void	startActivity(Activity activity, User user)

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

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Field Details

ACTIVITY_TYPE_MANUAL

public static final String ACTIVITY_TYPE_MANUAL

See Also:

• Constant Field Values

Constructor Details

ActivityService

public ActivityService()

Method Details

getSpec

public Spec getSpec()

init

public void init(String yamcsInstance,
 YConfiguration config)
          throws InitException

Throws:

InitException

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

getYamcsInstance

public String getYamcsInstance()

getExecutors

public Collection<ActivityExecutor> getExecutors()

getExecutor

public ActivityExecutor getExecutor(String activity)

addActivityListener

public void addActivityListener(ActivityListener listener)

removeActivityListener

public void removeActivityListener(ActivityListener listener)

addActivityLogListener

public void addActivityLogListener(ActivityLogListener listener)

removeActivityLogListener

public void removeActivityLogListener(ActivityLogListener listener)

prepareActivity

public Activity prepareActivity(String type,
 Map<String,Object> args,
 User user,
 String comment)

startActivity

public void startActivity(Activity activity,
 User user)

cancelActivity

public Activity cancelActivity(UUID id,
 User user)

completeManualActivity

public Activity completeManualActivity(UUID id,
 String failureReason,
 User user)

getActivity

public Activity getActivity(UUID id)

isStopRequested

public boolean isStopRequested(Activity activity)

getOngoingActivities

public List<Activity> getOngoingActivities()

logServiceInfo

public void logServiceInfo(Activity activity,
 String message)

logServiceWarning

public void logServiceWarning(Activity activity,
 String message)

logServiceError

public void logServiceError(Activity activity,
 String message)

logActivityInfo

public void logActivityInfo(Activity activity,
 String message)

logActivityWarning

public void logActivityWarning(Activity activity,
 String message)

logActivityError

public void logActivityError(Activity activity,
 String message)

getActivityDb

public ActivityDb getActivityDb()

getActivityLogDb

public ActivityLogDb getActivityLogDb()

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService