akka.persistence.multidc.testkit

Class SimulatedTimerScheduler

java.lang.Object

akka.actor.TimerScheduler

akka.persistence.multidc.testkit.SimulatedTimerScheduler

public class SimulatedTimerScheduler
extends akka.actor.TimerScheduler

Constructor Summary

Constructors

Constructor and Description
SimulatedTimerScheduler()

Method Summary

Modifier and Type	Method and Description
void	cancel(java.lang.Object key)
void	cancelAll()
boolean	isTimerActive(java.lang.Object key)
void	startPeriodicTimer(java.lang.Object key, java.lang.Object msg, scala.concurrent.duration.FiniteDuration interval)
void	startSingleTimer(java.lang.Object key, java.lang.Object msg, scala.concurrent.duration.FiniteDuration timeout)
void	startTimerAtFixedRate(java.lang.Object key, java.lang.Object msg, scala.concurrent.duration.FiniteDuration interval)
void	startTimerWithFixedDelay(java.lang.Object key, java.lang.Object msg, scala.concurrent.duration.FiniteDuration interval)
java.lang.Object	triggered(java.lang.Object key)

Methods inherited from class akka.actor.TimerScheduler

startPeriodicTimer, startSingleTimer

Methods inherited from class java.lang.Object

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

Constructor Detail

SimulatedTimerScheduler

public SimulatedTimerScheduler()

Method Detail

cancel

public void cancel(java.lang.Object key)

Specified by:

cancel in class akka.actor.TimerScheduler

cancelAll

public void cancelAll()

Specified by:

cancelAll in class akka.actor.TimerScheduler

isTimerActive

public boolean isTimerActive(java.lang.Object key)

Specified by:

isTimerActive in class akka.actor.TimerScheduler

startPeriodicTimer

public void startPeriodicTimer(java.lang.Object key,
                               java.lang.Object msg,
                               scala.concurrent.duration.FiniteDuration interval)

Specified by:

startPeriodicTimer in class akka.actor.TimerScheduler

startSingleTimer

public void startSingleTimer(java.lang.Object key,
                             java.lang.Object msg,
                             scala.concurrent.duration.FiniteDuration timeout)

Specified by:

startSingleTimer in class akka.actor.TimerScheduler

startTimerAtFixedRate

public void startTimerAtFixedRate(java.lang.Object key,
                                  java.lang.Object msg,
                                  scala.concurrent.duration.FiniteDuration interval)

startTimerWithFixedDelay

public void startTimerWithFixedDelay(java.lang.Object key,
                                     java.lang.Object msg,
                                     scala.concurrent.duration.FiniteDuration interval)

triggered

public java.lang.Object triggered(java.lang.Object key)