Package | Description |
---|---|
org.axonframework.deadline | |
org.axonframework.deadline.quartz | |
org.axonframework.test.aggregate | |
org.axonframework.test.deadline | |
org.axonframework.test.saga |
Modifier and Type | Class and Description |
---|---|
class |
GenericDeadlineMessage<T>
Generic implementation of the
DeadlineMessage . |
Modifier and Type | Method and Description |
---|---|
DeadlineMessage<T> |
DeadlineMessage.andMetaData(Map<String,?> additionalMetaData)
Returns a copy of this DeadlineMessage with its MetaData merged with given
additionalMetaData . |
static <T> DeadlineMessage<T> |
GenericDeadlineMessage.asDeadlineMessage(String deadlineName,
Object messageOrPayload)
Deprecated.
Use
GenericDeadlineMessage.asDeadlineMessage(String, Object, Instant) instead, as it sets the timestamp of the
deadline, rather than the current time |
static <T> DeadlineMessage<T> |
GenericDeadlineMessage.asDeadlineMessage(String deadlineName,
Object messageOrPayload,
Instant expiryTime)
Returns the given
deadlineName and messageOrPayload as a DeadlineMessage which expires at the
given expiryTime . |
protected <T> DeadlineMessage<T> |
AbstractDeadlineManager.processDispatchInterceptors(DeadlineMessage<T> message)
Applies registered
MessageDispatchInterceptor s to the given message . |
DeadlineMessage<T> |
DeadlineMessage.withMetaData(Map<String,?> metaData)
Returns a copy of this DeadlineMessage with the given
metaData . |
Modifier and Type | Method and Description |
---|---|
protected List<MessageDispatchInterceptor<? super DeadlineMessage<?>>> |
AbstractDeadlineManager.dispatchInterceptors()
Provides a list of registered dispatch interceptors.
|
protected List<MessageHandlerInterceptor<? super DeadlineMessage<?>>> |
AbstractDeadlineManager.handlerInterceptors()
Provides a list of registered handler interceptors.
|
Modifier and Type | Method and Description |
---|---|
protected <T> DeadlineMessage<T> |
AbstractDeadlineManager.processDispatchInterceptors(DeadlineMessage<T> message)
Applies registered
MessageDispatchInterceptor s to the given message . |
Modifier and Type | Method and Description |
---|---|
Registration |
AbstractDeadlineManager.registerDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> dispatchInterceptor) |
Registration |
AbstractDeadlineManager.registerHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> handlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
static DeadlineMessage |
DeadlineJob.DeadlineJobDataBinder.deadlineMessage(Serializer serializer,
org.quartz.JobDataMap jobDataMap)
Extracts a
DeadlineMessage from provided jobDataMap . |
Modifier and Type | Method and Description |
---|---|
static org.quartz.JobDataMap |
DeadlineJob.DeadlineJobDataBinder.toJobData(Serializer serializer,
DeadlineMessage deadlineMessage,
ScopeDescriptor deadlineScope)
Serializes the provided
deadlineMessage and deadlineScope and puts them in a JobDataMap . |
Modifier and Type | Method and Description |
---|---|
protected void |
AggregateTestFixture.handleDeadline(ScopeDescriptor aggregateDescriptor,
DeadlineMessage<?> deadlineMessage)
Handles the given
deadlineMessage in the aggregate described by the given aggregateDescriptor . |
Modifier and Type | Method and Description |
---|---|
ResultValidator<T> |
ResultValidator.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher)
Asserts that deadlines match given
matcher have been met (which have passed in time) on this aggregate. |
ResultValidator<T> |
ResultValidatorImpl.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher) |
ResultValidator<T> |
ResultValidator.expectNoScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher should be scheduled after the given duration . |
ResultValidator<T> |
ResultValidatorImpl.expectNoScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
ResultValidator<T> |
ResultValidator.expectNoScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher has been scheduled at the given scheduledTime . |
ResultValidator<T> |
ResultValidatorImpl.expectNoScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
ResultValidator<T> |
ResultValidator.expectNoScheduledDeadlineMatching(org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher is scheduled. |
ResultValidator<T> |
ResultValidatorImpl.expectNoScheduledDeadlineMatching(org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
ResultValidator<T> |
ResultValidator.expectScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that a deadline scheduled after given
duration matches the given matcher . |
ResultValidator<T> |
ResultValidatorImpl.expectScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
ResultValidator<T> |
ResultValidator.expectScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that a deadline matching the given
matcher has been scheduled at the given scheduledTime . |
ResultValidator<T> |
ResultValidatorImpl.expectScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureConfiguration<T> |
FixtureConfiguration.registerDeadlineDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> deadlineDispatchInterceptor)
Registers a deadline dispatch interceptor which will always be invoked before a deadline is dispatched
(scheduled) on the
DeadlineManager to perform a task specified in the
interceptor. |
FixtureConfiguration<T> |
AggregateTestFixture.registerDeadlineDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> deadlineDispatchInterceptor) |
FixtureConfiguration<T> |
FixtureConfiguration.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor)
Registers a deadline handler interceptor which will always be invoked before a deadline is handled to perform a
task specified in the interceptor.
|
FixtureConfiguration<T> |
AggregateTestFixture.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
DeadlineMessage<?> |
ScheduledDeadlineInfo.deadlineMessage()
|
Modifier and Type | Method and Description |
---|---|
void |
DeadlineConsumer.consume(ScopeDescriptor deadlineScope,
DeadlineMessage<?> deadlineMessage)
Consumes given
deadlineMessage . |
ScheduledDeadlineInfo |
ScheduledDeadlineInfo.recreateWithNewMessage(DeadlineMessage<?> deadlineMessage)
Creates a new instance of scheduled deadline info with new
deadlineMessage . |
Modifier and Type | Method and Description |
---|---|
Registration |
StubDeadlineManager.registerDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> dispatchInterceptor) |
Registration |
StubDeadlineManager.registerHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> handlerInterceptor) |
Constructor and Description |
---|
ScheduledDeadlineInfo(Instant scheduleTime,
String deadlineName,
String scheduleId,
int counter,
DeadlineMessage<?> deadlineMessage,
ScopeDescriptor deadlineScope)
Instantiates a ScheduledDeadlineInfo.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SagaTestFixture.handleDeadline(ScopeDescriptor sagaDescriptor,
DeadlineMessage<?> deadlineMessage)
Handles the given
deadlineMessage in the saga described by the given sagaDescriptor . |
Modifier and Type | Method and Description |
---|---|
FixtureExecutionResult |
FixtureExecutionResult.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher)
Asserts that deadlines match given
matcher have been met (which have passed in time) on this saga. |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectNoScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher should be scheduled after the given duration . |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectNoScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectNoScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher has been scheduled at the given scheduledTime . |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectNoScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectNoScheduledDeadlineMatching(org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher is scheduled. |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectNoScheduledDeadlineMatching(org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that a deadline scheduled after given
duration matches the given matcher . |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectScheduledDeadlineMatching(Duration duration,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that a deadline matching the given
matcher has been scheduled at the given scheduledTime . |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectScheduledDeadlineMatching(Instant scheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureConfiguration |
SagaTestFixture.registerDeadlineDispatchInterceptor(MessageDispatchInterceptor<DeadlineMessage<?>> deadlineDispatchInterceptor) |
FixtureConfiguration |
FixtureConfiguration.registerDeadlineDispatchInterceptor(MessageDispatchInterceptor<DeadlineMessage<?>> deadlineDispatchInterceptor)
Registers a deadline dispatch interceptor which will always be invoked before a deadline is dispatched
(scheduled) on the
DeadlineManager to perform a task specified in the
interceptor. |
FixtureConfiguration |
SagaTestFixture.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<DeadlineMessage<?>> deadlineHandlerInterceptor) |
FixtureConfiguration |
FixtureConfiguration.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<DeadlineMessage<?>> deadlineHandlerInterceptor)
Registers a deadline handler interceptor which will always be invoked before a deadline is handled to perform a
task specified in the interceptor.
|
Copyright © 2010–2020. All rights reserved.