org.ow2.proactive.scheduler.common

Class UniversalSchedulerListener

java.lang.Object

org.ow2.proactive.scheduler.common.UniversalSchedulerListener

All Implemented Interfaces:

Serializable, SchedulerEventListener

public class UniversalSchedulerListener
extends Object
implements SchedulerEventListener, Serializable

Wrapper class for Scheduler Event Listener. The goal of this class is to overcome the classloading problem (i.e. the user defined scheduler listener stub have to be loaded on Scheduler core side).

Since:

ProActive Scheduling 2.1

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UniversalSchedulerListener()
UniversalSchedulerListener(SchedulerEventListener internalListener) Create a wrapper for user defined listener.

Method Summary

Modifier and Type	Method and Description
void	jobStateUpdatedEvent(NotificationData<JobInfo> notification) Invoked each time the state of a job has changed. If you want to maintain an up to date list of jobs, just use the JobState.update(org.ow2.proactive.scheduler.common.job.JobInfo) method to update the content of your job.
void	jobSubmittedEvent(JobState job) Invoked each time a new job has been submitted to the Scheduler and validated.
void	jobUpdatedFullDataEvent(JobState job) Invoked each time the state of a job has changed and each time a scheduler event occurs.
void	schedulerStateUpdatedEvent(SchedulerEvent eventType) Invoked each time a scheduler event occurs. Scheduler events are stopped,started, paused, frozen, etc.
void	taskStateUpdatedEvent(NotificationData<TaskInfo> notification) Invoked each time the state of a task has changed. In this case you can use the JobState.update(org.ow2.proactive.scheduler.common.task.TaskInfo) method to update the content of the designated task inside your job.
void	usersUpdatedEvent(NotificationData<UserIdentification> notification) Invoked each time something change about users.

Methods inherited from class java.lang.Object

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

Constructor Detail

UniversalSchedulerListener

public UniversalSchedulerListener(SchedulerEventListener internalListener)

Create a wrapper for user defined listener.

Parameters:

internalListener - the wrapped listener.

UniversalSchedulerListener

public UniversalSchedulerListener()

Method Detail

jobStateUpdatedEvent

public void jobStateUpdatedEvent(NotificationData<JobInfo> notification)

Description copied from interface: SchedulerEventListener

Invoked each time the state of a job has changed.
If you want to maintain an up to date list of jobs, just use the JobState.update(org.ow2.proactive.scheduler.common.job.JobInfo) method to update the content of your job.

Specified by:

jobStateUpdatedEvent in interface SchedulerEventListener

Parameters:

notification - the data composed of the type of the event and the information that have change in the job.

jobUpdatedFullDataEvent

public void jobUpdatedFullDataEvent(JobState job)

Description copied from interface: SchedulerEventListener

Invoked each time the state of a job has changed and each time a scheduler event occurs.

Specified by:

jobUpdatedFullDataEvent in interface SchedulerEventListener

Parameters:

job - the updated job.

jobSubmittedEvent

public void jobSubmittedEvent(JobState job)

Description copied from interface: SchedulerEventListener

Invoked each time a new job has been submitted to the Scheduler and validated.

Specified by:

jobSubmittedEvent in interface SchedulerEventListener

Parameters:

job - the newly submitted job.

schedulerStateUpdatedEvent

public void schedulerStateUpdatedEvent(SchedulerEvent eventType)

Description copied from interface: SchedulerEventListener

Invoked each time a scheduler event occurs.
Scheduler events are stopped,started, paused, frozen, etc.

Specified by:

schedulerStateUpdatedEvent in interface SchedulerEventListener

Parameters:

eventType - the type of the event received.

taskStateUpdatedEvent

public void taskStateUpdatedEvent(NotificationData<TaskInfo> notification)

Description copied from interface: SchedulerEventListener

Invoked each time the state of a task has changed.
In this case you can use the JobState.update(org.ow2.proactive.scheduler.common.task.TaskInfo) method to update the content of the designated task inside your job.

Specified by:

taskStateUpdatedEvent in interface SchedulerEventListener

Parameters:

notification - the data composed of the type of the event and the information that have change in the task.

usersUpdatedEvent

public void usersUpdatedEvent(NotificationData<UserIdentification> notification)

Description copied from interface: SchedulerEventListener

Invoked each time something change about users.

Specified by:

usersUpdatedEvent in interface SchedulerEventListener

Parameters:

notification - the data composed of the type of the event and the data linked to the change.