org.axonframework.test.eventscheduler
Class StubEventScheduler

java.lang.Object
  org.axonframework.test.eventscheduler.StubEventScheduler

All Implemented Interfaces:

EventScheduler, org.joda.time.DateTimeUtils.MillisProvider

public class StubEventScheduler
extends Object
implements EventScheduler, org.joda.time.DateTimeUtils.MillisProvider

EventScheduler implementation that uses it's own concept of "Current Time" for the purpose of testing. Instead of publishing events, it allows (test) classes to obtain a reference to scheduled events for a certain time frame.

To obtain scheduled events, the conceptual "current time" of the Scheduler must be advanced. All events that have been scheduled within the advanced time frame are returned. It is up to the calling class to decide what to do with these events.

Since:

1.1

Author:

Allard Buijze

Constructor Summary

StubEventScheduler()
Creates an instance of the StubScheduler that uses the current date time as its conceptual "current time".

StubEventScheduler(org.joda.time.ReadableInstant currentDateTime)
Creates an instance of the StubScheduler that uses the given currentDateTime as its conceptual "current time".

Method Summary

List<EventMessage>	advanceTime(org.joda.time.DateTime newDateTime) Advance time to the given newDateTime and returns all events scheduled for publication until that time.
List<EventMessage>	advanceTime(org.joda.time.Duration duration) Advance time by the given duration and returns all events scheduled for publication until that time.
EventMessage	advanceToNextTrigger() Advances the "current time" of the scheduler to the next scheduled Event, and returns that event.
void	cancelSchedule(ScheduleToken scheduleToken) Cancel the publication of a scheduled event.
org.joda.time.DateTime	getCurrentDateTime() Returns the "Current Date Time" as used by the scheduler.
long	getMillis()
List<ScheduledItem>	getScheduledItems() Returns a view of all the scheduled Events at the time this method is called.
ScheduleToken	schedule(org.joda.time.DateTime triggerDateTime, Object event) Schedule the given event for publication at the given triggerDateTime.
ScheduleToken	schedule(org.joda.time.Duration triggerDuration, Object event) Schedule the given event for publication after the given triggerDuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

StubEventScheduler

public StubEventScheduler()

Creates an instance of the StubScheduler that uses the current date time as its conceptual "current time". Unlike the real "current time", the time of the Event Scheduler is fixed.

StubEventScheduler

public StubEventScheduler(org.joda.time.ReadableInstant currentDateTime)

Creates an instance of the StubScheduler that uses the given currentDateTime as its conceptual "current time".

Parameters:

currentDateTime - The instant to use as current Date and Time

Method Detail

schedule

public ScheduleToken schedule(org.joda.time.DateTime triggerDateTime,
                              Object event)

Description copied from interface: EventScheduler

Schedule the given event for publication at the given triggerDateTime. The returned ScheduleToken can be used to cancel the planned publication.

The given event may be any object, as well as an EventMessage. In the latter case, the instance provided is the donor for the payload and Meta Data of the actual message being dispatched. In the former case, the given event will be wrapped as the payload of an EventMessage.

Specified by:

schedule in interface EventScheduler

Parameters:

triggerDateTime - The moment to trigger publication of the event

event - The event to publish

Returns:

the token to use when cancelling the schedule

schedule

public ScheduleToken schedule(org.joda.time.Duration triggerDuration,
                              Object event)

Description copied from interface: EventScheduler

Schedule the given event for publication after the given triggerDuration. The returned ScheduleToken can be used to cancel the planned publication.

The given event may be any object, as well as an EventMessage. In the latter case, the instance provided is the donor for the payload and Meta Data of the actual message being dispatched. In the former case, the given event will be wrapped as the payload of an EventMessage.

Specified by:

schedule in interface EventScheduler

Parameters:

triggerDuration - The amount of time to wait before publishing the event

event - The event to publish

Returns:

the token to use when cancelling the schedule

cancelSchedule

public void cancelSchedule(ScheduleToken scheduleToken)

Description copied from interface: EventScheduler

Cancel the publication of a scheduled event. If the events has already been published, this method does nothing.

Specified by:

cancelSchedule in interface EventScheduler

Parameters:

scheduleToken - the token returned when the event was scheduled

getScheduledItems

public List<ScheduledItem> getScheduledItems()

Returns a view of all the scheduled Events at the time this method is called.

Returns:

a view of all the scheduled Events at the time this method is called

getCurrentDateTime

public org.joda.time.DateTime getCurrentDateTime()

Returns the "Current Date Time" as used by the scheduler.

Returns:

the "Current Date Time" as used by the scheduler

advanceToNextTrigger

public EventMessage advanceToNextTrigger()

Advances the "current time" of the scheduler to the next scheduled Event, and returns that event. In theory, this may cause "current time" to move backwards.

Returns:

the first event scheduled

advanceTime

public List<EventMessage> advanceTime(org.joda.time.DateTime newDateTime)

Advance time to the given newDateTime and returns all events scheduled for publication until that time.

Parameters:

newDateTime - The time to advance the "current time" of the scheduler to

Returns:

A list of Events scheduled for publication on or before the new time

advanceTime

public List<EventMessage> advanceTime(org.joda.time.Duration duration)

Advance time by the given duration and returns all events scheduled for publication until that time.

Parameters:

duration - The amount of time to advance the "current time" of the scheduler with

Returns:

A list of Events scheduled for publication on or before the new time

getMillis

public long getMillis()

Specified by:

getMillis in interface org.joda.time.DateTimeUtils.MillisProvider