Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.deadline | |
org.axonframework.deadline.quartz | |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.messaging.annotation | |
org.axonframework.modelling.command | |
org.axonframework.modelling.saga | |
org.axonframework.test.aggregate | |
org.axonframework.test.deadline | |
org.axonframework.test.saga |
Modifier and Type | Method and Description |
---|---|
Stream<ScopeAware> |
ConfigurationScopeAwareProvider.provideScopeAwareStream(ScopeDescriptor scopeDescriptor) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleDeadlineManager.cancelAllWithinScope(String deadlineName,
ScopeDescriptor scope) |
void |
DeadlineManager.cancelAllWithinScope(String deadlineName,
ScopeDescriptor scope)
Cancels all deadlines corresponding to the given
deadlineName and scope . |
default String |
DeadlineManager.schedule(Duration triggerDuration,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope)
Schedules a deadline after the given
triggerDuration with provided context. |
String |
SimpleDeadlineManager.schedule(Instant triggerDateTime,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope) |
String |
DeadlineManager.schedule(Instant triggerDateTime,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope)
Schedules a deadline at given
triggerDateTime with provided context. |
Modifier and Type | Method and Description |
---|---|
static ScopeDescriptor |
DeadlineJob.DeadlineJobDataBinder.deadlineScope(Serializer serializer,
org.quartz.JobDataMap jobDataMap)
|
Modifier and Type | Method and Description |
---|---|
void |
QuartzDeadlineManager.cancelAllWithinScope(String deadlineName,
ScopeDescriptor scope) |
String |
QuartzDeadlineManager.schedule(Duration triggerDuration,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope) |
String |
QuartzDeadlineManager.schedule(Instant triggerDateTime,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope) |
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 | Class and Description |
---|---|
class |
NoScopeDescriptor
A
ScopeDescriptor describing no active scope. |
Modifier and Type | Method and Description |
---|---|
static ScopeDescriptor |
Scope.describeCurrentScope()
Provide a description of the current
Scope . |
abstract ScopeDescriptor |
Scope.describeScope()
Provide a description of this
Scope . |
Modifier and Type | Method and Description |
---|---|
boolean |
ScopeAware.canResolve(ScopeDescriptor scopeDescription)
Check whether this implementation can resolve a
Scope object based on the provided scopeDescription . |
Stream<ScopeAware> |
ScopeAwareProvider.provideScopeAwareStream(ScopeDescriptor scopeDescriptor)
Retrieve a
Stream of ScopeAware components, by performing a check whether that component is able
to handle a Scope described by a ScopeDescriptor . |
void |
ScopeAware.send(Message<?> message,
ScopeDescriptor scopeDescription)
|
Modifier and Type | Method and Description |
---|---|
ParameterResolver<ScopeDescriptor> |
ScopeDescriptorParameterResolverFactory.createInstance(Executable executable,
Parameter[] parameters,
int parameterIndex) |
Modifier and Type | Class and Description |
---|---|
class |
AggregateScopeDescriptor
Describes the scope of an Aggregate by means of its type and identifier.
|
Modifier and Type | Method and Description |
---|---|
ScopeDescriptor |
AggregateLifecycle.describeScope() |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractRepository.canResolve(ScopeDescriptor scopeDescription) |
void |
AbstractRepository.send(Message<?> message,
ScopeDescriptor scopeDescription) |
Modifier and Type | Class and Description |
---|---|
class |
SagaScopeDescriptor
Describes the scope of a Saga by means of its type and identifier.
|
Modifier and Type | Method and Description |
---|---|
ScopeDescriptor |
SagaLifecycle.describeScope() |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractSagaManager.canResolve(ScopeDescriptor scopeDescription) |
void |
AbstractSagaManager.send(Message<?> message,
ScopeDescriptor scopeDescription) |
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 |
---|---|
ScopeDescriptor |
ScheduledDeadlineInfo.getDeadlineScope()
Retrieve a description of the
Scope in which the deadline is scheduled. |
Modifier and Type | Method and Description |
---|---|
void |
StubDeadlineManager.cancelAllWithinScope(String deadlineName,
ScopeDescriptor scope) |
void |
DeadlineConsumer.consume(ScopeDescriptor deadlineScope,
DeadlineMessage<?> deadlineMessage)
Consumes given
deadlineMessage . |
String |
StubDeadlineManager.schedule(Duration triggerDuration,
String deadlineName,
Object payloadOrMessage,
ScopeDescriptor deadlineScope) |
String |
StubDeadlineManager.schedule(Instant triggerDateTime,
String deadlineName,
Object payloadOrMessage,
ScopeDescriptor deadlineScope) |
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 . |
Copyright © 2010–2022. All rights reserved.