org.axonframework.axonserver.connector.processor.schedule

Class ScheduledEventProcessorInfoSource

java.lang.Object

org.axonframework.axonserver.connector.processor.schedule.ScheduledEventProcessorInfoSource

All Implemented Interfaces:

EventProcessorInfoSource

public class ScheduledEventProcessorInfoSource
extends Object
implements EventProcessorInfoSource

Implementation of EventProcessorInfoSource that schedule the notification of EventProcessors status.

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
ScheduledEventProcessorInfoSource(int initialDelay, int schedulingPeriod, EventProcessorInfoSource delegate) Initialize the ScheduledEventProcessorInfoSource using the given initialDelay and schedulingPeriod, as milliseconds, to schedule a notification through the delegate at a fixed rate.

Method Summary

Modifier and Type	Method and Description
void	notifyInformation()
void	shutdown() Shuts down the Executor started through the start() method.
void	start() Start an Executor using the given initialDelay and schedulingPeriod as milliseconds to notify event processor information.

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledEventProcessorInfoSource

public ScheduledEventProcessorInfoSource(int initialDelay,
                                         int schedulingPeriod,
                                         EventProcessorInfoSource delegate)

Initialize the ScheduledEventProcessorInfoSource using the given initialDelay and schedulingPeriod, as milliseconds, to schedule a notification through the delegate at a fixed rate.

Parameters:

initialDelay - the initial delay in milliseconds used to notify at a fixed rate

schedulingPeriod - the period in milliseconds after which another notification will be scheduled

delegate - an EventProcessorInfoSource used to notify the information at the specific interval

Method Detail

start

@StartHandler(phase=1073741833)
public void start()

Start an Executor using the given initialDelay and schedulingPeriod as milliseconds to notify event processor information. Will be started in phase Phase.INSTRUCTION_COMPONENTS, to ensure the event processors this source shares information about have been started.

notifyInformation

public void notifyInformation()

Specified by:

notifyInformation in interface EventProcessorInfoSource

shutdown

@ShutdownHandler(phase=1073741833)
public void shutdown()

Shuts down the Executor started through the start() method. Will be invoked in phase Phase.INSTRUCTION_COMPONENTS .