org.axonframework.test.saga

Interface ContinuedGivenState

All Known Implementing Classes:

AnnotatedSagaTestFixture

public interface ContinuedGivenState

Interface describing methods that can be executed after the first "given" state has been supplied. Either more "given" state can be appended, or a transition to the definition of "when" can be made.

Since:

1.1

Author:

Allard Buijze

Method Summary

Methods

Modifier and Type	Method and Description
GivenAggregateEventPublisher	andThenAggregate(Object aggregateIdentifier) Use this method to indicate that an aggregate with given identifier published certain events.
ContinuedGivenState	andThenAPublished(Object event) Indicates that the given event has been published in the past.
ContinuedGivenState	andThenTimeAdvancesTo(org.joda.time.DateTime newDateTime) Simulate time shifts in the current given state.
ContinuedGivenState	andThenTimeElapses(org.joda.time.Duration elapsedTime) Simulate time shifts in the current given state.
WhenAggregateEventPublisher	whenAggregate(Object aggregateIdentifier) Use this method to indicate that an aggregate with given identifier should publish certain events, while recording the outcome.
FixtureExecutionResult	whenPublishingA(Object event) Use this method to indicate an application is published, while recording the outcome.
FixtureExecutionResult	whenTimeAdvancesTo(org.joda.time.DateTime newDateTime) Mimic an elapsed time with no relevant activity for the Saga.
FixtureExecutionResult	whenTimeElapses(org.joda.time.Duration elapsedTime) Mimic an elapsed time with no relevant activity for the Saga.

Method Detail

andThenAggregate

GivenAggregateEventPublisher andThenAggregate(Object aggregateIdentifier)

Use this method to indicate that an aggregate with given identifier published certain events.

Can be chained to build natural sentences:
andThenAggregate(someIdentifier).published(someEvents)

Parameters:

aggregateIdentifier - The identifier of the aggregate the events should appear to come from

Returns:

an object that allows registration of the actual events to send

andThenTimeElapses

ContinuedGivenState andThenTimeElapses(org.joda.time.Duration elapsedTime)

Simulate time shifts in the current given state. This can be useful when the time between given events is of importance.

Parameters:

elapsedTime - The amount of time that will elapse

Returns:

an object that allows registration of the actual events to send

andThenTimeAdvancesTo

ContinuedGivenState andThenTimeAdvancesTo(org.joda.time.DateTime newDateTime)

Simulate time shifts in the current given state. This can be useful when the time between given events is of importance.

Parameters:

newDateTime - The time to advance the clock to

Returns:

an object that allows registration of the actual events to send

andThenAPublished

ContinuedGivenState andThenAPublished(Object event)

Indicates that the given event has been published in the past. This event is sent to the associated sagas.

Parameters:

event - The event to publish

Returns:

an object that allows chaining of more given state

whenAggregate

WhenAggregateEventPublisher whenAggregate(Object aggregateIdentifier)

Use this method to indicate that an aggregate with given identifier should publish certain events, while recording the outcome. In contrast to the FixtureConfiguration.givenAggregate(Object) given} and andThenAggregate(Object) andThen} methods, this method will start recording activity on the EventBus and CommandBus.

Can be chained to build natural sentences:
whenAggregate(someIdentifier).publishes(anEvent)

Note that if you inject resources using FixtureConfiguration.registerResource(Object), you may need to reset them yourself if they are manipulated by the Saga in the "given" stage of the test.

Parameters:

aggregateIdentifier - The identifier of the aggregate the events should appear to come from

Returns:

an object that allows registration of the actual events to send

whenPublishingA

FixtureExecutionResult whenPublishingA(Object event)

Use this method to indicate an application is published, while recording the outcome.

Note that if you inject resources using FixtureConfiguration.registerResource(Object), you may need to reset them yourself if they are manipulated by the Saga in the "given" stage of the test.

Parameters:

event - the event to publish

Returns:

an object allowing you to verify the test results

whenTimeElapses

FixtureExecutionResult whenTimeElapses(org.joda.time.Duration elapsedTime)

Mimic an elapsed time with no relevant activity for the Saga. If any Events are scheduled to be published within this time frame, they are published. All activity by the Saga on the CommandBus and EventBus (meaning that scheduled events are excluded) is recorded.

Note that if you inject resources using FixtureConfiguration.registerResource(Object), you may need to reset them yourself if they are manipulated by the Saga in the "given" stage of the test.

Parameters:

elapsedTime - The amount of time to elapse

Returns:

an object allowing you to verify the test results

whenTimeAdvancesTo

FixtureExecutionResult whenTimeAdvancesTo(org.joda.time.DateTime newDateTime)

Mimic an elapsed time with no relevant activity for the Saga. If any Events are scheduled to be published within this time frame, they are published. All activity by the Saga on the CommandBus and EventBus (meaning that scheduled events are excluded) is recorded.

Note that if you inject resources using FixtureConfiguration.registerResource(Object), you may need to reset them yourself if they are manipulated by the Saga in the "given" stage of the test.

Parameters:

newDateTime - The time to advance the clock to

Returns:

an object allowing you to verify the test results