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 . |
<T> DeadlineMessage<T> |
DefaultDeadlineManagerSpanFactory.propagateContext(DeadlineMessage<T> eventMessage) |
<T> DeadlineMessage<T> |
DeadlineManagerSpanFactory.propagateContext(DeadlineMessage<T> deadlineMessage)
Propagates the context of the current span to the given deadline 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 |
---|---|
Span |
DefaultDeadlineManagerSpanFactory.createExecuteSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage) |
Span |
DeadlineManagerSpanFactory.createExecuteSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage)
Creates a span that represents the execution of a deadline.
|
Span |
DefaultDeadlineManagerSpanFactory.createScheduleSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage) |
Span |
DeadlineManagerSpanFactory.createScheduleSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage)
Creates a span that represents the scheduling of a deadline.
|
protected <T> DeadlineMessage<T> |
AbstractDeadlineManager.processDispatchInterceptors(DeadlineMessage<T> message)
Applies registered
MessageDispatchInterceptor s to the given message . |
<T> DeadlineMessage<T> |
DefaultDeadlineManagerSpanFactory.propagateContext(DeadlineMessage<T> eventMessage) |
<T> DeadlineMessage<T> |
DeadlineManagerSpanFactory.propagateContext(DeadlineMessage<T> deadlineMessage)
Propagates the context of the current span to the given deadline 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> |
ResultValidatorImpl.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher) |
ResultValidator<T> |
ResultValidator.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher)
Deprecated.
|
ResultValidator<T> |
ResultValidatorImpl.expectNoScheduledDeadlineMatching(Duration durationToScheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
ResultValidator<T> |
ResultValidator.expectNoScheduledDeadlineMatching(Duration durationToScheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher should be scheduled after the given durationToScheduledTime . |
ResultValidator<T> |
ResultValidatorImpl.expectNoScheduledDeadlineMatching(Instant from,
Instant to,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
ResultValidator<T> |
ResultValidator.expectNoScheduledDeadlineMatching(Instant from,
Instant to,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher has been scheduled between the to and from times, where to and
from are inclusive. |
ResultValidator<T> |
ResultValidatorImpl.expectNoScheduledDeadlineMatching(Instant scheduledTime,
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(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.expectScheduledDeadlineMatching(Duration duration,
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(Instant scheduledTime,
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.expectTriggeredDeadlinesMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher) |
ResultValidator<T> |
ResultValidator.expectTriggeredDeadlinesMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher)
Asserts that deadlines matching the given
matcher have been triggered for this aggregate. |
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 |
FixtureExecutionResultImpl.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectDeadlinesMetMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher)
Deprecated.
|
FixtureExecutionResult |
FixtureExecutionResultImpl.expectNoScheduledDeadlineMatching(Duration durationToScheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectNoScheduledDeadlineMatching(Duration durationToScheduledTime,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher should be scheduled after the given durationToScheduledTime . |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectNoScheduledDeadlineMatching(Instant from,
Instant to,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectNoScheduledDeadlineMatching(Instant from,
Instant to,
org.hamcrest.Matcher<? super DeadlineMessage<?>> matcher)
Asserts that no deadline matching the given
matcher has been scheduled between the to and from times, where to and
from are inclusive. |
FixtureExecutionResult |
FixtureExecutionResultImpl.expectNoScheduledDeadlineMatching(Instant scheduledTime,
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(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.expectScheduledDeadlineMatching(Duration duration,
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(Instant scheduledTime,
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.expectTriggeredDeadlinesMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher) |
FixtureExecutionResult |
FixtureExecutionResult.expectTriggeredDeadlinesMatching(org.hamcrest.Matcher<? extends List<? super DeadlineMessage<?>>> matcher)
Asserts that deadlines matching the given
matcher have been triggered for this aggregate. |
FixtureConfiguration |
SagaTestFixture.registerDeadlineDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> deadlineDispatchInterceptor) |
FixtureConfiguration |
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 |
SagaTestFixture.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor) |
FixtureConfiguration |
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.
|
Copyright © 2010–2024. All rights reserved.