com.atlassian.confluence.test.rpc

Class FuncTestJobControlListenerForAtlassianScheduler

java.lang.Object

com.atlassian.confluence.test.rpc.FuncTestJobControlListenerForAtlassianScheduler

All Implemented Interfaces:

com.atlassian.plugin.StateAware

public class FuncTestJobControlListenerForAtlassianScheduler
extends Object
implements com.atlassian.plugin.StateAware

Listens to job control events published by the FuncTestRpcHandlerImpl.

This allows the job control to be handled across all cluster nodes.

Since:

5.10

Constructor Summary

Constructors

Constructor and Description
FuncTestJobControlListenerForAtlassianScheduler()

Method Summary

Modifier and Type	Method and Description
void	disabled()
void	enabled()
void	onClusterEvent(ClusterEventWrapper clusterEventWrapper)
void	pauseAllJobs(PauseAllJobsEvent event)
void	pauseJob(PauseJobEvent event)
void	pauseJobGroup(PauseJobGroupEvent event)
void	resumeJob(ResumeJobEvent event)
void	setEventPublisher(com.atlassian.event.api.EventPublisher eventPublisher)
void	setHibernateSessionManager(HibernateSessionManager sessionManager)
void	setSchedulerService(com.atlassian.scheduler.SchedulerService schedulerService)
void	triggerJob(TriggerJobEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

FuncTestJobControlListenerForAtlassianScheduler

public FuncTestJobControlListenerForAtlassianScheduler()

Method Detail

setEventPublisher

public void setEventPublisher(com.atlassian.event.api.EventPublisher eventPublisher)

setSchedulerService

public void setSchedulerService(com.atlassian.scheduler.SchedulerService schedulerService)

setHibernateSessionManager

public void setHibernateSessionManager(HibernateSessionManager sessionManager)

enabled

public void enabled()

Specified by:

enabled in interface com.atlassian.plugin.StateAware

disabled

public void disabled()

Specified by:

disabled in interface com.atlassian.plugin.StateAware

onClusterEvent

@EventListener
public void onClusterEvent(ClusterEventWrapper clusterEventWrapper)
                                   throws com.atlassian.scheduler.SchedulerServiceException

Throws:

com.atlassian.scheduler.SchedulerServiceException

pauseJobGroup

@EventListener
public void pauseJobGroup(PauseJobGroupEvent event)

pauseJob

@EventListener
public void pauseJob(PauseJobEvent event)

resumeJob

@EventListener
public void resumeJob(ResumeJobEvent event)
                              throws com.atlassian.scheduler.SchedulerServiceException

Throws:

com.atlassian.scheduler.SchedulerServiceException

pauseAllJobs

@EventListener
public void pauseAllJobs(PauseAllJobsEvent event)

triggerJob

@EventListener
public void triggerJob(TriggerJobEvent event)
                               throws com.atlassian.scheduler.SchedulerServiceException,
                                      RemoteException,
                                      InterruptedException

Throws:

com.atlassian.scheduler.SchedulerServiceException

RemoteException

InterruptedException