Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.deadline | |
org.axonframework.deadline.dbscheduler | |
org.axonframework.deadline.jobrunr | |
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 . |
Span |
DefaultDeadlineManagerSpanFactory.createCancelAllWithinScopeSpan(String deadlineName,
ScopeDescriptor scopeDescriptor) |
Span |
DeadlineManagerSpanFactory.createCancelAllWithinScopeSpan(String deadlineName,
ScopeDescriptor scopeDescriptor)
Creates a span that represents the cancellation of all deadlines with a certain name within a certain 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 |
---|---|
ScopeDescriptor |
DbSchedulerHumanReadableDeadlineDetails.getDeserializedScopeDescriptor(Serializer serializer)
Returns the serialized
ScopeDescriptor using the supplied Serializer . |
ScopeDescriptor |
DbSchedulerBinaryDeadlineDetails.getDeserializedScopeDescriptor(Serializer serializer)
Returns the serialized
ScopeDescriptor using the supplied Serializer . |
Modifier and Type | Method and Description |
---|---|
void |
DbSchedulerDeadlineManager.cancelAllWithinScope(String deadlineName,
ScopeDescriptor scope) |
String |
DbSchedulerDeadlineManager.schedule(Instant triggerDateTime,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope) |
Modifier and Type | Method and Description |
---|---|
ScopeDescriptor |
DeadlineDetails.getDeserializedScopeDescriptor(Serializer serializer)
Returns the serialized
ScopeDescriptor using the supplied Serializer . |
Modifier and Type | Method and Description |
---|---|
void |
JobRunrDeadlineManager.cancelAllWithinScope(String deadlineName,
ScopeDescriptor scope) |
static String |
LabelUtils.getCombinedLabel(Serializer serializer,
String deadlineName,
ScopeDescriptor scope)
Creates a label from a scope and a deadlineName, by using the serializer.
|
String |
JobRunrDeadlineManager.schedule(Instant triggerDateTime,
String deadlineName,
Object messageOrPayload,
ScopeDescriptor deadlineScope) |
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–2024. All rights reserved.