实例介绍
【实例简介】
AxonFramework是一个用于构建进化式、事件驱动微服务系统的框架，基于领域驱动设计（DDD）、命令查询责任分离（CQRS）和事件溯源原则。该框架为您提供了必要的构建模块来遵循这些原则。构建模块的示例包括聚合设计句柄、聚合存储库、命令总线、saga设计句柄、事件存储、查询总线等。框架为所有这些组件提供了明智的默认设置。命令、事件和查询的消息支持是这些构建模块的核心。正是消息基础使得通过它们提供的位置透明度实现了对微服务的进化式方法。Axon还将协助分发应用程序以支持可伸缩性或容错性，例如使用Axon Server可以快速调整消息总线到分布式实现。Axon Server提供了分布式命令总线、事件总线、查询总线以及可伸缩的事件溯源实现。此外，Axon Framework组织还有一些扩展可以在这方面提供帮助。所有这些都有助于创建一个结构良好的应用程序，无需担心基础设施。因此，您的关注点可以从非功能性要求转移到业务功能。有关Axon的更多信息，请访问我们的网站。各种资源可以帮助您使用Axon Framework的旅程。一个很好的起点是AxonIQ开发人员门户网站，提供博客、视频和描述的链接资源。此外，以下是其他几个有用的资源：文档的快速入门页面为您提供了一个简化的框架入口点，其中包含快速入门项目。我们拥有自己的学院！介绍课程是免费的，之后是更深入的（付费）课程。准备好后，您可以快速轻松地启动您自己的基于Axon Framework的应用程序。参考指南解释了Axon Framework产品中维护的所有组件。如果指南无法帮助，我们的论坛提供了一个空间，供您在开发过程中提出问题。酒店演示展示了使用Axon Framework的一个充分的示例。代码示例存储库包含更深入的示例，您可以受益于这些示例。
【实例截图】
【核心代码】
文件清单
└── AxonFramework-0a5f1ed37aa3e8a83c867aa72f4d58c1395e2e40
├── assembly
│ └── axon-full.xml
├── axon-4-api-changes.md
├── axon_code_style.xml
├── axon-server-connector
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── axonserver
│ │ │ └── connector
│ │ │ ├── AxonServerConfiguration.java
│ │ │ ├── AxonServerConnectionManager.java
│ │ │ ├── AxonServerException.java
│ │ │ ├── command
│ │ │ │ ├── AxonServerCommandBus.java
│ │ │ │ ├── AxonServerCommandDispatchException.java
│ │ │ │ ├── AxonServerNonTransientRemoteCommandHandlingException.java
│ │ │ │ ├── AxonServerRegistration.java
│ │ │ │ ├── AxonServerRemoteCommandHandlingException.java
│ │ │ │ ├── CommandLoadFactorProvider.java
│ │ │ │ ├── CommandPriorityCalculator.java
│ │ │ │ ├── CommandSerializer.java
│ │ │ │ └── GrpcBackedCommandMessage.java
│ │ │ ├── ConnectionManager.java
│ │ │ ├── DefaultHandlers.java
│ │ │ ├── DefaultInstructionAckSource.java
│ │ │ ├── DispatchInterceptors.java
│ │ │ ├── ErrorCode.java
│ │ │ ├── event
│ │ │ │ ├── axon
│ │ │ │ │ ├── AxonServerEventScheduler.java
│ │ │ │ │ ├── AxonServerEventStoreFactory.java
│ │ │ │ │ ├── AxonServerEventStore.java
│ │ │ │ │ ├── EventBuffer.java
│ │ │ │ │ ├── EventProcessorInfoConfiguration.java
│ │ │ │ │ ├── GrpcBackedDomainEventData.java
│ │ │ │ │ ├── GrpcMetaDataAwareSerializer.java
│ │ │ │ │ ├── QueryResult.java
│ │ │ │ │ ├── QueryResultStreamAdapter.java
│ │ │ │ │ └── QueryResultStream.java
│ │ │ │ └── util
│ │ │ │ ├── EventCipher.java
│ │ │ │ ├── EventStoreClientException.java
│ │ │ │ └── GrpcExceptionParser.java
│ │ │ ├── Handlers.java
│ │ │ ├── heartbeat
│ │ │ │ ├── connection
│ │ │ │ │ └── checker
│ │ │ │ │ ├── ActiveGrpcChannelChecker.java
│ │ │ │ │ └── HeartbeatConnectionChecker.java
│ │ │ │ ├── ConnectionSanityChecker.java
│ │ │ │ ├── HeartbeatConfiguration.java
│ │ │ │ ├── HeartbeatMonitor.java
│ │ │ │ ├── HeartbeatSource.java
│ │ │ │ └── source
│ │ │ │ └── GrpcHeartbeatSource.java
│ │ │ ├── InstructionAckSource.java
│ │ │ ├── InstructionResultPublisher.java
│ │ │ ├── ManagedChannelCustomizer.java
│ │ │ ├── PriorityCallable.java
│ │ │ ├── PriorityRunnable.java
│ │ │ ├── PriorityTask.java
│ │ │ ├── processor
│ │ │ │ ├── EventProcessorControlService.java
│ │ │ │ └── StreamingEventProcessorInfoMessage.java
│ │ │ ├── Publisher.java
│ │ │ ├── query
│ │ │ │ ├── AxonServerNonTransientRemoteQueryHandlingException.java
│ │ │ │ ├── AxonServerQueryBus.java
│ │ │ │ ├── AxonServerQueryDispatchException.java
│ │ │ │ ├── AxonServerRemoteQueryHandlingException.java
│ │ │ │ ├── GrpcBackedQueryMessage.java
│ │ │ │ ├── GrpcBackedResponseMessage.java
│ │ │ │ ├── QueryPriorityCalculator.java
│ │ │ │ ├── QueryProcessingTask.java
│ │ │ │ ├── QuerySerializer.java
│ │ │ │ ├── StreamableFluxResponse.java
│ │ │ │ ├── StreamableInstanceResponse.java
│ │ │ │ ├── StreamableMultiInstanceResponse.java
│ │ │ │ ├── StreamableResponse.java
│ │ │ │ └── subscription
│ │ │ │ ├── AxonServerSubscriptionQueryResult.java
│ │ │ │ ├── DeserializedResult.java
│ │ │ │ ├── DisposableResult.java
│ │ │ │ ├── GrpcBackedQueryUpdateMessage.java
│ │ │ │ ├── GrpcBackedSubscriptionQueryMessage.java
│ │ │ │ └── SubscriptionMessageSerializer.java
│ │ │ ├── ServerConnectorConfigurerModule.java
│ │ │ ├── TargetContextResolver.java
│ │ │ └── util
│ │ │ ├── ContextAddingInterceptor.java
│ │ │ ├── ExceptionSerializer.java
│ │ │ ├── ExecutorServiceBuilder.java
│ │ │ ├── FlowControllingStreamObserver.java
│ │ │ ├── GrpcBufferingInterceptor.java
│ │ │ ├── GrpcMetaDataConverter.java
│ │ │ ├── GrpcMetaData.java
│ │ │ ├── GrpcMetadataSerializer.java
│ │ │ ├── GrpcObjectSerializer.java
│ │ │ ├── GrpcPayloadSerializer.java
│ │ │ ├── GrpcSerializedObject.java
│ │ │ ├── PriorityExecutorService.java
│ │ │ ├── PriorityTaskSchedulers.java
│ │ │ ├── ProcessingInstructionHelper.java
│ │ │ ├── ResubscribableStreamObserver.java
│ │ │ ├── Scheduler.java
│ │ │ ├── TokenAddingInterceptor.java
│ │ │ └── UpstreamAwareStreamObserver.java
│ │ └── resources
│ │ ├── axonserver_download.txt
│ │ └── META-INF
│ │ └── services
│ │ └── org.axonframework.config.ConfigurerModule
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── axonserver
│ │ └── connector
│ │ ├── AxonServerConfigurationTest.java
│ │ ├── AxonServerConnectionManagerTest.java
│ │ ├── command
│ │ │ ├── AxonServerCommandBusTest.java
│ │ │ ├── CommandSerializerTest.java
│ │ │ ├── DummyMessagePlatformServer.java
│ │ │ └── GrpcBackedCommandMessageTest.java
│ │ ├── DispatchInterceptorsTest.java
│ │ ├── event
│ │ │ ├── axon
│ │ │ │ ├── AxonServerEventSchedulerTest.java
│ │ │ │ ├── AxonServerEventStoreFactoryTest.java
│ │ │ │ ├── AxonServerEventStoreTest.java
│ │ │ │ ├── ErrorCodeTest.java
│ │ │ │ ├── EventBufferTest.java
│ │ │ │ ├── EventProcessorInfoConfigurationTest.java
│ │ │ │ └── QueryResultStreamAdapterTest.java
│ │ │ ├── EventStoreImpl.java
│ │ │ ├── StubServer.java
│ │ │ └── util
│ │ │ └── EventCipherTests.java
│ │ ├── heartbeat
│ │ │ ├── HeartbeatConnectionCheckerTest.java
│ │ │ └── HeartbeatMonitorTest.java
│ │ ├── processor
│ │ │ └── EventProcessorControlServiceTest.java
│ │ ├── query
│ │ │ ├── AxonServerQueryBusTest.java
│ │ │ ├── GrpcBackedQueryMessageTest.java
│ │ │ ├── GrpcBackedResponseMessageTest.java
│ │ │ ├── QueryProcessingTaskIntegrationTest.java
│ │ │ ├── QuerySerializerTest.java
│ │ │ ├── StreamingQueryEndToEndTest.java
│ │ │ └── subscription
│ │ │ ├── AxonServerSubscriptionQueryResultTest.java
│ │ │ ├── FakeStreamObserver.java
│ │ │ ├── GrpcBackedQueryUpdateMessageTest.java
│ │ │ ├── GrpcBackedSubscriptionQueryMessageTest.java
│ │ │ └── SubscriptionMessageSerializerTest.java
│ │ ├── ServerConnectorConfigurerModuleTest.java
│ │ ├── ServerConnectorRunner.java
│ │ ├── TestStreamObserver.java
│ │ ├── TestTargetContextResolver.java
│ │ ├── util
│ │ │ ├── ExceptionSerializerTest.java
│ │ │ ├── GrpcBufferingInterceptorTest.java
│ │ │ ├── GrpcMetaDataConverterTest.java
│ │ │ ├── ProcessingInstructionHelperTest.java
│ │ │ └── TcpUtil.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── ContextInterceptor.java
│ │ ├── FakeClock.java
│ │ ├── FakeScheduler.java
│ │ ├── FutureUtils.java
│ │ ├── PlatformService.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── log4j2.properties
│ └── logback.xml
├── config
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── config
│ │ ├── AggregateConfiguration.java
│ │ ├── AggregateConfigurer.java
│ │ ├── AxonIQConsoleModule.java
│ │ ├── Component.java
│ │ ├── Configuration.java
│ │ ├── ConfigurationParameterResolverFactory.java
│ │ ├── ConfigurationResourceInjector.java
│ │ ├── ConfigurationScopeAwareProvider.java
│ │ ├── Configurer.java
│ │ ├── ConfigurerModule.java
│ │ ├── DefaultConfigurer.java
│ │ ├── EventProcessingConfiguration.java
│ │ ├── EventProcessingConfigurer.java
│ │ ├── EventProcessingModule.java
│ │ ├── LifecycleHandlerInspector.java
│ │ ├── LifecycleHandler.java
│ │ ├── LifecycleOperations.java
│ │ ├── MessageHandlerRegistrar.java
│ │ ├── MessageMonitorFactoryBuilder.java
│ │ ├── MessageMonitorFactory.java
│ │ ├── ModuleConfiguration.java
│ │ ├── ProcessingGroup.java
│ │ ├── SagaConfiguration.java
│ │ ├── SagaConfigurer.java
│ │ └── TagsConfiguration.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── config
│ │ ├── AggregateConfigurerTest.java
│ │ ├── ConfigAssertions.java
│ │ ├── ConfigurationParameterResolverFactoryTest.java
│ │ ├── ConfigurationResourceInjectorTest.java
│ │ ├── ConfigurationScopeAwareProviderTest.java
│ │ ├── DefaultConfigurerHandlerRegistrationTest.java
│ │ ├── DefaultConfigurerLifecycleOperationsTest.java
│ │ ├── DefaultConfigurerTest.java
│ │ ├── EventProcessingModuleTest.java
│ │ ├── LifecycleHandlerInspectorTest.java
│ │ ├── MessageCollectingMonitor.java
│ │ ├── MessageHandlerRegistrarTest.java
│ │ ├── MessageMonitorFactoryBuilderTest.java
│ │ ├── SagaConfigurerTest.java
│ │ ├── SingleEventProcessorAssigningToMultipleInvokersTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── log4j2.properties
│ └── META-INF
│ └── persistence.xml
├── CONTRIBUTING.md
├── copyright-template.xml
├── coverage-report
│ └── pom.xml
├── disruptor
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── disruptor
│ │ └── commandhandling
│ │ ├── AggregateBlacklistedException.java
│ │ ├── AggregateStateCorruptedException.java
│ │ ├── BlacklistDetectingCallback.java
│ │ ├── CommandHandlerInvoker.java
│ │ ├── CommandHandlingEntry.java
│ │ ├── DisruptorCommandBus.java
│ │ ├── DisruptorUnitOfWork.java
│ │ ├── EventPublisher.java
│ │ └── FirstLevelCache.java
│ └── test
│ └── java
│ └── org
│ └── axonframework
│ └── disruptor
│ └── commandhandling
│ ├── CommandHandlerInvokerTest.java
│ ├── CommandHandlingBenchmark.java
│ ├── DisruptorCommandBusBenchmark.java
│ ├── DisruptorCommandBusBuilderTest.java
│ ├── DisruptorCommandBusMultiThreadedTest.java
│ ├── DisruptorCommandBusTest.java
│ ├── DisruptorRepositoryTest.java
│ ├── FirstLevelCacheTest.java
│ └── utils
│ ├── AssertUtils.java
│ ├── MockException.java
│ └── SomethingDoneEvent.java
├── docs
│ ├── af-fundamentals-tutorial
│ │ ├── antora.yml
│ │ └── modules
│ │ ├── deadlines
│ │ │ ├── pages
│ │ │ │ ├── advanced.adoc
│ │ │ │ ├── deciding.adoc
│ │ │ │ ├── implementing.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ └── testing.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── dlq
│ │ │ ├── examples
│ │ │ │ └── source_code
│ │ │ ├── pages
│ │ │ │ ├── advanced.adoc
│ │ │ │ ├── implementing.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ └── retrying.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── nav.adoc
│ │ └── ROOT
│ │ ├── autoconfigure
│ │ │ └── autoconfigure
│ │ ├── config
│ │ │ └── config
│ │ ├── pages
│ │ │ └── index.adoc
│ │ └── partials
│ │ └── nav.adoc
│ ├── _playbook
│ │ ├── package.json
│ │ ├── package-lock.json
│ │ └── playbook.yaml
│ ├── reference
│ │ ├── antora.yml
│ │ └── modules
│ │ ├── axon-server-connector
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── configuration
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── disruptor
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── eventsourcing
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── legacy
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── messaging
│ │ │ ├── attachments
│ │ │ │ ├── axonframework_overview.gv
│ │ │ │ ├── base_classes.mermaid
│ │ │ │ ├── base_classes.puml
│ │ │ │ ├── command_messaging_classes.puml
│ │ │ │ ├── event_messaging_classes.puml
│ │ │ │ ├── generic_messaging_classes.puml
│ │ │ │ └── query_messaging_classes.puml
│ │ │ ├── pages
│ │ │ │ ├── advanced_messaging
│ │ │ │ │ ├── correlation.adoc
│ │ │ │ │ └── index.adoc
│ │ │ │ ├── deadlines
│ │ │ │ │ ├── index.adoc
│ │ │ │ │ └── manager_simple.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ ├── messages
│ │ │ │ │ ├── command_messages.adoc
│ │ │ │ │ ├── event_messages.adoc
│ │ │ │ │ ├── messages.adoc
│ │ │ │ │ └── query_messages.adoc
│ │ │ │ └── routing
│ │ │ │ ├── command_routing.adoc
│ │ │ │ ├── event_routing.adoc
│ │ │ │ ├── query_routing.adoc
│ │ │ │ └── routing.adoc
│ │ │ └── partials
│ │ │ ├── command_message.adoc
│ │ │ └── nav.adoc
│ │ ├── metrics
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── micrometer
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── modeling
│ │ │ ├── pages
│ │ │ │ ├── aggregate.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ └── saga.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── nav.adoc
│ │ ├── ROOT
│ │ │ ├── attachments
│ │ │ │ └── axonframework_overview.gv
│ │ │ ├── pages
│ │ │ │ ├── index.adoc
│ │ │ │ ├── overview.adoc
│ │ │ │ └── structure.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── spring
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── springboot-starter
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── test
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ └── tracing-open-telemetry
│ │ ├── pages
│ │ │ └── index.adoc
│ │ └── partials
│ │ └── nav.adoc
│ └── _source_code_links
│ ├── axon-server-connector
│ ├── config
│ ├── eventsourcing
│ ├── messaging
│ ├── modelling
│ ├── spring
│ └── spring-boot-autoconfigure
├── eventsourcing
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── eventsourcing
│ │ │ ├── AbstractAggregateFactory.java
│ │ │ ├── AbstractSnapshotter.java
│ │ │ ├── AbstractSnapshotTrigger.java
│ │ │ ├── AggregateCacheEntry.java
│ │ │ ├── AggregateDeletedException.java
│ │ │ ├── AggregateFactory.java
│ │ │ ├── AggregateLoadTimeSnapshotTriggerDefinition.java
│ │ │ ├── AggregateSnapshotter.java
│ │ │ ├── CachingEventSourcingRepository.java
│ │ │ ├── conflictresolution
│ │ │ │ ├── ConflictDescription.java
│ │ │ │ ├── ConflictExceptionSupplier.java
│ │ │ │ ├── ConflictResolution.java
│ │ │ │ ├── ConflictResolver.java
│ │ │ │ ├── Conflicts.java
│ │ │ │ ├── ContextAwareConflictExceptionSupplier.java
│ │ │ │ ├── DefaultConflictDescription.java
│ │ │ │ ├── DefaultConflictResolver.java
│ │ │ │ └── NoConflictResolver.java
│ │ │ ├── DefaultSnapshotterSpanFactory.java
│ │ │ ├── EventCountSnapshotTriggerDefinition.java
│ │ │ ├── EventSourcedAggregate.java
│ │ │ ├── EventSourcingHandler.java
│ │ │ ├── EventSourcingRepository.java
│ │ │ ├── eventstore
│ │ │ │ ├── AbstractEventStorageEngine.java
│ │ │ │ ├── AbstractEventStore.java
│ │ │ │ ├── AbstractSnapshotEventEntry.java
│ │ │ │ ├── BatchingEventStorageEngine.java
│ │ │ │ ├── ConcatenatingDomainEventStream.java
│ │ │ │ ├── DomainEventStream.java
│ │ │ │ ├── EmbeddedEventStore.java
│ │ │ │ ├── EqualRevisionPredicate.java
│ │ │ │ ├── EventStorageEngine.java
│ │ │ │ ├── EventStoreException.java
│ │ │ │ ├── EventStore.java
│ │ │ │ ├── FilteringDomainEventStream.java
│ │ │ │ ├── inmemory
│ │ │ │ │ └── InMemoryEventStorageEngine.java
│ │ │ │ ├── IteratorBackedDomainEventStream.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── AbstractEventTableFactory.java
│ │ │ │ │ ├── EventSchema.java
│ │ │ │ │ ├── EventTableFactory.java
│ │ │ │ │ ├── HsqlEventTableFactory.java
│ │ │ │ │ ├── JdbcEventStorageEngine.java
│ │ │ │ │ ├── JdbcSQLErrorCodesResolver.java
│ │ │ │ │ ├── MySqlEventTableFactory.java
│ │ │ │ │ ├── Oracle11EventTableFactory.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ ├── PostgresEventTableFactory.java
│ │ │ │ │ └── statements
│ │ │ │ │ ├── AppendEventsStatementBuilder.java
│ │ │ │ │ ├── AppendSnapshotStatementBuilder.java
│ │ │ │ │ ├── CleanGapsStatementBuilder.java
│ │ │ │ │ ├── CreateHeadTokenStatementBuilder.java
│ │ │ │ │ ├── CreateTailTokenStatementBuilder.java
│ │ │ │ │ ├── CreateTokenAtStatementBuilder.java
│ │ │ │ │ ├── DeleteSnapshotsStatementBuilder.java
│ │ │ │ │ ├── FetchTrackedEventsStatementBuilder.java
│ │ │ │ │ ├── JdbcEventStorageEngineStatements.java
│ │ │ │ │ ├── LastSequenceNumberForStatementBuilder.java
│ │ │ │ │ ├── ReadEventDataForAggregateStatementBuilder.java
│ │ │ │ │ ├── ReadEventDataWithGapsStatementBuilder.java
│ │ │ │ │ ├── ReadEventDataWithoutGapsStatementBuilder.java
│ │ │ │ │ ├── ReadSnapshotDataStatementBuilder.java
│ │ │ │ │ └── TimestampWriter.java
│ │ │ │ ├── jpa
│ │ │ │ │ ├── DomainEventEntry.java
│ │ │ │ │ ├── JpaEventStorageEngine.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ ├── SnapshotEventEntry.java
│ │ │ │ │ ├── SQLErrorCodesResolver.java
│ │ │ │ │ └── SQLStateResolver.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ ├── EmbeddedEventStore.java
│ │ │ │ │ ├── JpaEventStorageEngine.java
│ │ │ │ │ └── SQLErrorCodesResolver.java
│ │ │ │ ├── package-info.java
│ │ │ │ └── SequenceEventStorageEngine.java
│ │ │ ├── EventStreamUtils.java
│ │ │ ├── FilteringEventStorageEngine.java
│ │ │ ├── GenericAggregateFactory.java
│ │ │ ├── IncompatibleAggregateException.java
│ │ │ ├── MultiStreamableMessageSource.java
│ │ │ ├── NoSnapshotTriggerDefinition.java
│ │ │ ├── package-info.java
│ │ │ ├── Snapshotter.java
│ │ │ ├── SnapshotterSpanFactory.java
│ │ │ ├── snapshotting
│ │ │ │ ├── RevisionSnapshotFilter.java
│ │ │ │ └── SnapshotFilter.java
│ │ │ ├── SnapshotTriggerDefinition.java
│ │ │ └── SnapshotTrigger.java
│ │ └── resources
│ │ ├── META-INF
│ │ │ └── services
│ │ │ └── org.axonframework.messaging.annotation.ParameterResolverFactory
│ │ └── org
│ │ └── axonframework
│ │ └── eventsourcing
│ │ └── eventstore
│ │ ├── jpa
│ │ │ └── SQLErrorCode.properties
│ │ └── legacyjpa
│ │ └── SQLErrorCode.properties
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── eventsourcing
│ │ ├── AbstractAggregateFactoryTest.java
│ │ ├── AbstractSnapshotterTest.java
│ │ ├── AggregateLoadSnapshotTriggerDefinitionTest.java
│ │ ├── AggregateSnapshotterTest.java
│ │ ├── CachingEventSourcingRepositoryTest.java
│ │ ├── CachingRepositoryWithNestedUnitOfWorkTest.java
│ │ ├── conflictresolution
│ │ │ ├── ConflictResolutionTest.java
│ │ │ ├── ConflictsTest.java
│ │ │ └── DefaultConflictResolverTest.java
│ │ ├── DefaultSnapshotterSpanFactoryTest.java
│ │ ├── DomainEventStreamTest.java
│ │ ├── EventCountSnapshotTriggerDefinitionTest.java
│ │ ├── EventSourcingRepositoryIntegrationTest.java
│ │ ├── EventSourcingRepositoryTest.java
│ │ ├── eventstore
│ │ │ ├── AbstractEventStorageEngineTest.java
│ │ │ ├── BatchingEventStorageEngineTest.java
│ │ │ ├── ConcatenatingDomainEventStreamTest.java
│ │ │ ├── EmbeddedEventStoreTest.java
│ │ │ ├── EqualRevisionPredicateTest.java
│ │ │ ├── EventStorageEngineTest.java
│ │ │ ├── FilteringDomainEventStreamTest.java
│ │ │ ├── inmemory
│ │ │ │ ├── InMemoryEmbeddedEventStoreTest.java
│ │ │ │ └── InMemoryEventStorageEngineTest.java
│ │ │ ├── jdbc
│ │ │ │ ├── JdbcEmbeddedEventStoreTest.java
│ │ │ │ ├── JdbcEventStorageEngineTest.java
│ │ │ │ └── MysqlJdbcEventStorageEngineTest.java
│ │ │ ├── jpa
│ │ │ │ ├── DomainEventEntryTest.java
│ │ │ │ ├── SQLErrorCodesResolverTest.java
│ │ │ │ └── SQLStateResolverTest.java
│ │ │ ├── legacyjpa
│ │ │ │ ├── JpaEventStorageEngineTest.java
│ │ │ │ └── SQLErrorCodesResolverTest.java
│ │ │ └── SequenceEventStorageEngineTest.java
│ │ ├── EventStreamUtilsTest.java
│ │ ├── FilteringEventStorageEngineTest.java
│ │ ├── GenericAggregateFactoryTest.java
│ │ ├── NoSnapshotTriggerDefinitionTest.java
│ │ ├── snapshotting
│ │ │ ├── RevisionSnapshotFilterTest.java
│ │ │ └── SnapshotFilterTest.java
│ │ ├── SpawningNewAggregateTest.java
│ │ └── utils
│ │ ├── EventStoreTestUtils.java
│ │ ├── MockException.java
│ │ ├── RecordingAppender.java
│ │ ├── StubAggregate.java
│ │ ├── StubDomainEvent.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── ehcache.xml
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ ├── META-INF
│ │ └── persistence.xml
│ └── mysql.benchmark.properties
├── hibernate-6-integrationtests
│ ├── pom.xml
│ └── src
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── common
│ │ │ └── jpa
│ │ │ ├── PagingJpaQueryIterableTest.java
│ │ │ └── TestJpaEntry.java
│ │ ├── eventhandling
│ │ │ ├── deadletter
│ │ │ │ └── jpa
│ │ │ │ └── JpaSequencedDeadLetterQueueTest.java
│ │ │ └── tokenstore
│ │ │ └── jpa
│ │ │ └── JpaTokenStoreTest.java
│ │ ├── eventsourcing
│ │ │ └── eventstore
│ │ │ └── jpa
│ │ │ ├── CustomDomainEventEntry.java
│ │ │ ├── CustomSnapshotEventEntry.java
│ │ │ └── JpaEventStorageEngineTest.java
│ │ ├── messaging
│ │ │ └── interceptors
│ │ │ └── BeanValidationInterceptorTest.java
│ │ └── modelling
│ │ └── saga
│ │ └── repository
│ │ └── jpa
│ │ └── JpaSagaStoreTest.java
│ └── resources
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ └── META-INF
│ └── persistence.xml
├── integrationtests
│ ├── pom.xml
│ └── src
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── integrationtests
│ │ ├── axonserverconnector
│ │ │ └── MessagePriorityIntegrationTest.java
│ │ ├── cache
│ │ │ ├── CachedSaga.java
│ │ │ ├── CachingIntegrationTestSuite.java
│ │ │ ├── EhCache3IntegrationTest.java
│ │ │ ├── EhCacheIntegrationTest.java
│ │ │ ├── JCacheIntegrationTest.java
│ │ │ ├── TestAggregateRoot.java
│ │ │ └── WeakReferenceCacheIntegrationTest.java
│ │ ├── commandhandling
│ │ │ ├── AbstractAggregateMemberTest.java
│ │ │ ├── AggregateCreationFromCommandsTest.java
│ │ │ ├── CommandRetryAndDispatchInterceptorIntegrationTest.java
│ │ │ ├── CreateStubAggregateCommand.java
│ │ │ ├── EventPublicationOrderTest.java
│ │ │ ├── LoopingChangeDoneEvent.java
│ │ │ ├── LoopingCommand.java
│ │ │ ├── MyEvent.java
│ │ │ ├── ProblematicCommand.java
│ │ │ ├── StubAggregateChangedEvent.java
│ │ │ ├── StubAggregateCommandHandler.java
│ │ │ ├── StubAggregateCreatedEvent.java
│ │ │ ├── StubAggregateForCreation.java
│ │ │ ├── StubAggregate.java
│ │ │ ├── StubDomainEvent.java
│ │ │ ├── UpdateStubAggregateCommand.java
│ │ │ └── UpdateStubAggregateWithExtraEventCommand.java
│ │ ├── deadline
│ │ │ ├── dbscheduler
│ │ │ │ ├── BinaryDbSchedulerDeadlineManagerTest.java
│ │ │ │ └── HumanReadableDbSchedulerDeadlineManagerTest.java
│ │ │ ├── jobrunr
│ │ │ │ ├── JobrunrDeadlineManagerTest.java
│ │ │ │ └── SimpleActivator.java
│ │ │ ├── quartz
│ │ │ │ └── QuartzDeadlineManagerTest.java
│ │ │ └── SimpleDeadlineManagerTest.java
│ │ ├── eventhandling
│ │ │ ├── LoopingEventHandler.java
│ │ │ ├── MultiStreamableMessageSourceTest.java
│ │ │ ├── RegisteringEventHandler.java
│ │ │ ├── SubscribingEventProcessorTest.java
│ │ │ ├── TrackingEventProcessorTest.java
│ │ │ └── TrackingEventProcessorTest_MultiThreaded.java
│ │ ├── eventsourcing
│ │ │ ├── conflictresolution
│ │ │ │ └── ConflictResolutionIntegrationTest.java
│ │ │ ├── eventstore
│ │ │ │ ├── benchmark
│ │ │ │ │ ├── AbstractEventStoreBenchmark.java
│ │ │ │ │ ├── inmemory
│ │ │ │ │ │ └── InMemoryEventStoreBenchMark.java
│ │ │ │ │ ├── jdbc
│ │ │ │ │ │ └── JdbcEventStoreBenchmark.java
│ │ │ │ │ └── jpa
│ │ │ │ │ └── JpaEventStoreBenchMark.java
│ │ │ │ ├── jdbc
│ │ │ │ │ └── Oracle11EventTableFactoryTest.java
│ │ │ │ └── jpa
│ │ │ │ ├── JpaEmbeddedCborEventStoreTest.java
│ │ │ │ └── JpaEmbeddedEventStoreTest.java
│ │ │ └── NestedUnitOfWorkTest.java
│ │ ├── loopbacktest
│ │ │ ├── MessageCreatedEvent.java
│ │ │ ├── Message.java
│ │ │ ├── MessagingCommandHandler.java
│ │ │ ├── NestedUowRollbackTest.java
│ │ │ ├── StubDomainEvent.java
│ │ │ └── synchronous
│ │ │ ├── LoopBackWithInterwovenCommandsAndEventsTest.java
│ │ │ └── SynchronousLoopbackTest.java
│ │ ├── modelling
│ │ │ ├── command
│ │ │ │ ├── CommandHandlerInterceptorTest.java
│ │ │ │ ├── CommandHandlingTest.java
│ │ │ │ ├── ComplexAggregateStructureTest.java
│ │ │ │ └── JpaAggregate.java
│ │ │ └── saga
│ │ │ └── repository
│ │ │ └── jdbc
│ │ │ └── Oracle11SagaSqlSchemaTest.java
│ │ ├── polymorphic
│ │ │ ├── AbstractCommandHandlerCommand.java
│ │ │ ├── AbstractPolymorphicAggregateAnnotationCommandHandlerTestSuite.java
│ │ │ ├── Child1Aggregate.java
│ │ │ ├── Child1OnlyCommand.java
│ │ │ ├── Child2Aggregate.java
│ │ │ ├── ChildEvent.java
│ │ │ ├── CommonCommand.java
│ │ │ ├── CreateChild1Command.java
│ │ │ ├── CreateChild2Command.java
│ │ │ ├── CreateChildFactoryCommand.java
│ │ │ ├── CreatedEvent.java
│ │ │ ├── CreateSimpleAggregateCommand.java
│ │ │ ├── FireChildEventCommand.java
│ │ │ ├── FireParentEventCommand.java
│ │ │ ├── InterceptedByChildCommand.java
│ │ │ ├── InterceptedByParentCommand.java
│ │ │ ├── ParentAggregate.java
│ │ │ ├── ParentEvent.java
│ │ │ ├── PolymorphicESAggregateAnnotationCommandHandlerTest.java
│ │ │ ├── PolymorphicJpaAggregateAnnotationCommandHandlerTest.java
│ │ │ ├── SimpleAggregateCreatedEvent.java
│ │ │ └── SimpleAggregate.java
│ │ ├── queryhandling
│ │ │ ├── AbstractSubscriptionQueryTestSuite.java
│ │ │ ├── ProjectorTest.java
│ │ │ └── SimpleQueryBusSubscriptionQueryTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── EventTestUtils.java
│ │ ├── MockException.java
│ │ ├── StubAggregate.java
│ │ ├── StubDomainEvent.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── ehcache.xml
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ ├── log4j2_silenced.properties
│ ├── META-INF
│ │ ├── persistence.xml
│ │ └── spring
│ │ ├── benchmark-jdbc-context.xml
│ │ ├── benchmark-jpa-context.xml
│ │ ├── benchmark-mongo-context.xml
│ │ └── insertion-read-order-test-context.xml
│ ├── mysql.benchmark.properties
│ └── mysql.database.properties
├── legacy
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ ├── commandhandling
│ │ │ └── model
│ │ │ └── AggregateScopeDescriptor.java
│ │ ├── domain
│ │ │ ├── GenericEventMessage.java
│ │ │ ├── GenericMessage.java
│ │ │ └── MetaData.java
│ │ ├── eventhandling
│ │ │ ├── saga
│ │ │ │ └── SagaScopeDescriptor.java
│ │ │ └── scheduling
│ │ │ └── quartz
│ │ │ └── LegacyAwareJobDataBinder.java
│ │ ├── eventsourcing
│ │ │ └── eventstore
│ │ │ ├── GapAwareTrackingToken.java
│ │ │ └── GlobalSequenceTrackingToken.java
│ │ └── mongo
│ │ └── eventsourcing
│ │ └── eventstore
│ │ └── MongoTrackingToken.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── commandhandling
│ │ │ └── model
│ │ │ └── AggregateScopeDescriptorTest.java
│ │ ├── eventhandling
│ │ │ ├── saga
│ │ │ │ └── SagaScopeDescriptorTest.java
│ │ │ └── scheduling
│ │ │ └── quartz
│ │ │ └── LegacyAwareJobDataBinderTest.java
│ │ ├── eventsourcing
│ │ │ └── eventstore
│ │ │ ├── GapAwareTrackingTokenTest.java
│ │ │ └── GlobalSequenceTrackingTokenTest.java
│ │ └── utils
│ │ └── TestSerializer.java
│ └── resources
│ ├── log4j.properties
│ └── serialized.object
├── LICENSE.txt
├── messaging
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ ├── commandhandling
│ │ │ │ ├── AnnotationCommandHandlerAdapter.java
│ │ │ │ ├── AsynchronousCommandBus.java
│ │ │ │ ├── callbacks
│ │ │ │ │ ├── FailureLoggingCallback.java
│ │ │ │ │ ├── FutureCallback.java
│ │ │ │ │ ├── LoggingCallback.java
│ │ │ │ │ └── NoOpCallback.java
│ │ │ │ ├── CommandBus.java
│ │ │ │ ├── CommandBusSpanFactory.java
│ │ │ │ ├── CommandCallback.java
│ │ │ │ ├── CommandExecutionException.java
│ │ │ │ ├── CommandHandler.java
│ │ │ │ ├── CommandMessageHandler.java
│ │ │ │ ├── CommandMessageHandlingMember.java
│ │ │ │ ├── CommandMessage.java
│ │ │ │ ├── CommandResultMessage.java
│ │ │ │ ├── CurrentUnitOfWorkParameterResolverFactory.java
│ │ │ │ ├── DefaultCommandBusSpanFactory.java
│ │ │ │ ├── distributed
│ │ │ │ │ ├── AbstractRoutingStrategy.java
│ │ │ │ │ ├── AnnotationRoutingStrategy.java
│ │ │ │ │ ├── CommandBusConnectorCommunicationException.java
│ │ │ │ │ ├── CommandBusConnector.java
│ │ │ │ │ ├── CommandCallbackRepository.java
│ │ │ │ │ ├── CommandCallbackWrapper.java
│ │ │ │ │ ├── CommandDispatchException.java
│ │ │ │ │ ├── commandfilter
│ │ │ │ │ │ ├── AcceptAll.java
│ │ │ │ │ │ ├── AndCommandMessageFilter.java
│ │ │ │ │ │ ├── CommandNameFilter.java
│ │ │ │ │ │ ├── DenyAll.java
│ │ │ │ │ │ ├── DenyCommandNameFilter.java
│ │ │ │ │ │ ├── NegateCommandMessageFilter.java
│ │ │ │ │ │ └── OrCommandMessageFilter.java
│ │ │ │ │ ├── CommandMessageFilter.java
│ │ │ │ │ ├── CommandRouter.java
│ │ │ │ │ ├── ConsistentHashChangeListener.java
│ │ │ │ │ ├── ConsistentHash.java
│ │ │ │ │ ├── DispatchMessage.java
│ │ │ │ │ ├── DistributedCommandBus.java
│ │ │ │ │ ├── Member.java
│ │ │ │ │ ├── MetaDataRoutingStrategy.java
│ │ │ │ │ ├── ReplyMessage.java
│ │ │ │ │ ├── RoutingStrategy.java
│ │ │ │ │ ├── ServiceRegistryException.java
│ │ │ │ │ ├── SimpleMember.java
│ │ │ │ │ └── UnresolvedRoutingKeyPolicy.java
│ │ │ │ ├── DuplicateCommandHandlerResolution.java
│ │ │ │ ├── DuplicateCommandHandlerResolver.java
│ │ │ │ ├── DuplicateCommandHandlerSubscriptionException.java
│ │ │ │ ├── FailingDuplicateCommandHandlerResolver.java
│ │ │ │ ├── gateway
│ │ │ │ │ ├── AbstractCommandGateway.java
│ │ │ │ │ ├── AbstractRetryScheduler.java
│ │ │ │ │ ├── AxonNonTransientExceptionClassesPredicate.java
│ │ │ │ │ ├── CommandGatewayFactory.java
│ │ │ │ │ ├── CommandGateway.java
│ │ │ │ │ ├── DefaultCommandGateway.java
│ │ │ │ │ ├── ExponentialBackOffIntervalRetryScheduler.java
│ │ │ │ │ ├── IntervalRetryScheduler.java
│ │ │ │ │ ├── NonTransientExceptionClassesPredicate.java
│ │ │ │ │ ├── RetryingCallback.java
│ │ │ │ │ ├── RetryScheduler.java
│ │ │ │ │ └── Timeout.java
│ │ │ │ ├── GenericCommandMessage.java
│ │ │ │ ├── GenericCommandResultMessage.java
│ │ │ │ ├── LoggingDuplicateCommandHandlerResolver.java
│ │ │ │ ├── MethodCommandHandlerDefinition.java
│ │ │ │ ├── MonitorAwareCallback.java
│ │ │ │ ├── NoHandlerForCommandException.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── RoutingKey.java
│ │ │ │ ├── SimpleCommandBus.java
│ │ │ │ └── WrappedCommandCallback.java
│ │ │ ├── common
│ │ │ │ ├── annotation
│ │ │ │ │ ├── AnnotationUtils.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ └── PriorityAnnotationComparator.java
│ │ │ │ ├── Assert.java
│ │ │ │ ├── AxonConfigurationException.java
│ │ │ │ ├── AxonException.java
│ │ │ │ ├── AxonNonTransientException.java
│ │ │ │ ├── AxonThreadFactory.java
│ │ │ │ ├── AxonTransientException.java
│ │ │ │ ├── BuilderUtils.java
│ │ │ │ ├── caching
│ │ │ │ │ ├── AbstractCacheAdapter.java
│ │ │ │ │ ├── Cache.java
│ │ │ │ │ ├── EhCache3Adapter.java
│ │ │ │ │ ├── EhCacheAdapter.java
│ │ │ │ │ ├── JCacheAdapter.java
│ │ │ │ │ ├── NoCache.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ └── WeakReferenceCache.java
│ │ │ │ ├── CollectionUtils.java
│ │ │ │ ├── DateTimeUtils.java
│ │ │ │ ├── DefaultIdentifierFactory.java
│ │ │ │ ├── digest
│ │ │ │ │ └── Digester.java
│ │ │ │ ├── DirectExecutor.java
│ │ │ │ ├── ExceptionUtils.java
│ │ │ │ ├── IdentifierFactory.java
│ │ │ │ ├── IdentifierValidator.java
│ │ │ │ ├── io
│ │ │ │ │ └── IOUtils.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── ConnectionProvider.java
│ │ │ │ │ ├── ConnectionWrapperFactory.java
│ │ │ │ │ ├── DataSourceConnectionProvider.java
│ │ │ │ │ ├── JdbcException.java
│ │ │ │ │ ├── JdbcUtils.java
│ │ │ │ │ ├── Oracle11Utils.java
│ │ │ │ │ ├── PagingJdbcIterable.java
│ │ │ │ │ ├── PersistenceExceptionResolver.java
│ │ │ │ │ └── UnitOfWorkAwareConnectionProviderWrapper.java
│ │ │ │ ├── jpa
│ │ │ │ │ ├── EntityManagerProvider.java
│ │ │ │ │ ├── PagingJpaQueryIterable.java
│ │ │ │ │ └── SimpleEntityManagerProvider.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ ├── EntityManagerProvider.java
│ │ │ │ │ ├── PagingJpaQueryIterable.java
│ │ │ │ │ └── SimpleEntityManagerProvider.java
│ │ │ │ ├── ListUtils.java
│ │ │ │ ├── lock
│ │ │ │ │ ├── DeadlockException.java
│ │ │ │ │ ├── LockAcquisitionFailedException.java
│ │ │ │ │ ├── LockFactory.java
│ │ │ │ │ ├── Lock.java
│ │ │ │ │ ├── NoOpLock.java
│ │ │ │ │ ├── NullLockFactory.java
│ │ │ │ │ └── PessimisticLockFactory.java
│ │ │ │ ├── MemberAccessibilityCallback.java
│ │ │ │ ├── ObjectUtils.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── Priority.java
│ │ │ │ ├── ProcessRetriesExhaustedException.java
│ │ │ │ ├── ProcessUtils.java
│ │ │ │ ├── property
│ │ │ │ │ ├── AbstractMethodPropertyAccessStrategy.java
│ │ │ │ │ ├── BeanPropertyAccessStrategy.java
│ │ │ │ │ ├── DirectlyAccessedProperty.java
│ │ │ │ │ ├── DirectPropertyAccessStrategy.java
│ │ │ │ │ ├── MethodAccessedProperty.java
│ │ │ │ │ ├── PropertyAccessException.java
│ │ │ │ │ ├── PropertyAccessStrategy.java
│ │ │ │ │ ├── Property.java
│ │ │ │ │ └── UniformPropertyAccessStrategy.java
│ │ │ │ ├── ReflectionUtils.java
│ │ │ │ ├── Registration.java
│ │ │ │ ├── stream
│ │ │ │ │ ├── BlockingStream.java
│ │ │ │ │ └── StreamUtils.java
│ │ │ │ ├── StringUtils.java
│ │ │ │ ├── transaction
│ │ │ │ │ ├── NoTransactionManager.java
│ │ │ │ │ ├── Transaction.java
│ │ │ │ │ └── TransactionManager.java
│ │ │ │ └── TypeReflectionUtils.java
│ │ │ ├── deadline
│ │ │ │ ├── AbstractDeadlineManager.java
│ │ │ │ ├── annotation
│ │ │ │ │ ├── DeadlineHandler.java
│ │ │ │ │ ├── DeadlineHandlingMember.java
│ │ │ │ │ └── DeadlineMethodMessageHandlerDefinition.java
│ │ │ │ ├── dbscheduler
│ │ │ │ │ ├── DbSchedulerBinaryDeadlineDetails.java
│ │ │ │ │ ├── DbSchedulerDeadlineManager.java
│ │ │ │ │ ├── DbSchedulerDeadlineManagerSupplier.java
│ │ │ │ │ ├── DbSchedulerDeadlineToken.java
│ │ │ │ │ ├── DbSchedulerHumanReadableDeadlineDetails.java
│ │ │ │ │ └── DeadlineManagerNotSuppliedException.java
│ │ │ │ ├── DeadlineException.java
│ │ │ │ ├── DeadlineManager.java
│ │ │ │ ├── DeadlineManagerSpanFactory.java
│ │ │ │ ├── DeadlineMessage.java
│ │ │ │ ├── DefaultDeadlineManagerSpanFactory.java
│ │ │ │ ├── GenericDeadlineMessage.java
│ │ │ │ ├── jobrunr
│ │ │ │ │ ├── DeadlineDetails.java
│ │ │ │ │ ├── JobRunrDeadlineManager.java
│ │ │ │ │ └── LabelUtils.java
│ │ │ │ ├── quartz
│ │ │ │ │ ├── DeadlineJob.java
│ │ │ │ │ └── QuartzDeadlineManager.java
│ │ │ │ └── SimpleDeadlineManager.java
│ │ │ ├── eventhandling
│ │ │ │ ├── AbstractDomainEventEntry.java
│ │ │ │ ├── AbstractEventBus.java
│ │ │ │ ├── AbstractEventEntry.java
│ │ │ │ ├── AbstractEventProcessor.java
│ │ │ │ ├── AbstractSequencedDomainEventEntry.java
│ │ │ │ ├── AddedTrackerStatus.java
│ │ │ │ ├── AllowReplay.java
│ │ │ │ ├── AnnotationEventHandlerAdapter.java
│ │ │ │ ├── async
│ │ │ │ │ ├── AsynchronousEventProcessingStrategy.java
│ │ │ │ │ ├── EventProcessorTask.java
│ │ │ │ │ ├── FullConcurrencyPolicy.java
│ │ │ │ │ ├── PropertySequencingPolicy.java
│ │ │ │ │ ├── SequencingPolicy.java
│ │ │ │ │ ├── SequentialPerAggregatePolicy.java
│ │ │ │ │ └── SequentialPolicy.java
│ │ │ │ ├── ConcludesBatch.java
│ │ │ │ ├── ConcludesBatchParameterResolverFactory.java
│ │ │ │ ├── deadletter
│ │ │ │ │ ├── DeadLetteredEventProcessingTask.java
│ │ │ │ │ ├── DeadLetteringEventHandlerInvoker.java
│ │ │ │ │ ├── jdbc
│ │ │ │ │ │ ├── DeadLetterJdbcConverter.java
│ │ │ │ │ │ ├── DeadLetterSchema.java
│ │ │ │ │ │ ├── DeadLetterStatementFactory.java
│ │ │ │ │ │ ├── DeadLetterTableFactory.java
│ │ │ │ │ │ ├── DefaultDeadLetterJdbcConverter.java
│ │ │ │ │ │ ├── DefaultDeadLetterStatementFactory.java
│ │ │ │ │ │ ├── GenericDeadLetterTableFactory.java
│ │ │ │ │ │ ├── JdbcDeadLetter.java
│ │ │ │ │ │ └── JdbcSequencedDeadLetterQueue.java
│ │ │ │ │ ├── jpa
│ │ │ │ │ │ ├── DeadLetterEntry.java
│ │ │ │ │ │ ├── DeadLetterEventEntry.java
│ │ │ │ │ │ ├── DeadLetterJpaConverter.java
│ │ │ │ │ │ ├── EventMessageDeadLetterJpaConverter.java
│ │ │ │ │ │ ├── JpaDeadLetter.java
│ │ │ │ │ │ ├── JpaSequencedDeadLetterQueue.java
│ │ │ │ │ │ └── NoJpaConverterFoundException.java
│ │ │ │ │ ├── legacyjpa
│ │ │ │ │ │ ├── DeadLetterJpaConverter.java
│ │ │ │ │ │ ├── EventMessageDeadLetterJpaConverter.java
│ │ │ │ │ │ ├── JpaDeadLetter.java
│ │ │ │ │ │ └── JpaSequencedDeadLetterQueue.java
│ │ │ │ │ └── SequenceIdentifierCache.java
│ │ │ │ ├── DefaultEventBusSpanFactory.java
│ │ │ │ ├── DefaultEventProcessorSpanFactory.java
│ │ │ │ ├── DirectEventProcessingStrategy.java
│ │ │ │ ├── DisallowReplay.java
│ │ │ │ ├── DomainEventData.java
│ │ │ │ ├── DomainEventMessage.java
│ │ │ │ ├── DomainEventSequenceAware.java
│ │ │ │ ├── ErrorContext.java
│ │ │ │ ├── ErrorHandler.java
│ │ │ │ ├── EventBus.java
│ │ │ │ ├── EventBusSpanFactory.java
│ │ │ │ ├── EventData.java
│ │ │ │ ├── EventHandlerInvoker.java
│ │ │ │ ├── EventHandler.java
│ │ │ │ ├── EventMessageHandler.java
│ │ │ │ ├── EventMessage.java
│ │ │ │ ├── EventProcessingException.java
│ │ │ │ ├── EventProcessingStrategy.java
│ │ │ │ ├── EventProcessor.java
│ │ │ │ ├── EventProcessorSpanFactory.java
│ │ │ │ ├── EventTrackerStatusChangeListener.java
│ │ │ │ ├── EventTrackerStatus.java
│ │ │ │ ├── EventUtils.java
│ │ │ │ ├── GapAwareTrackingToken.java
│ │ │ │ ├── gateway
│ │ │ │ │ ├── AbstractEventGateway.java
│ │ │ │ │ ├── DefaultEventGateway.java
│ │ │ │ │ └── EventGateway.java
│ │ │ │ ├── GenericDomainEventEntry.java
│ │ │ │ ├── GenericDomainEventMessage.java
│ │ │ │ ├── GenericEventMessage.java
│ │ │ │ ├── GenericTrackedDomainEventMessage.java
│ │ │ │ ├── GenericTrackedEventMessage.java
│ │ │ │ ├── GlobalSequenceTrackingToken.java
│ │ │ │ ├── interceptors
│ │ │ │ │ └── EventLoggingInterceptor.java
│ │ │ │ ├── ListenerInvocationErrorHandler.java
│ │ │ │ ├── LoggingErrorHandler.java
│ │ │ │ ├── MergedTrackingToken.java
│ │ │ │ ├── MultiEventHandlerInvoker.java
│ │ │ │ ├── MultiSourceTrackingToken.java
│ │ │ │ ├── MultiStreamableMessageSource.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── pooled
│ │ │ │ │ ├── ClaimTask.java
│ │ │ │ │ ├── Coordinator.java
│ │ │ │ │ ├── CoordinatorTask.java
│ │ │ │ │ ├── MergeTask.java
│ │ │ │ │ ├── PooledStreamingEventProcessor.java
│ │ │ │ │ ├── SplitTask.java
│ │ │ │ │ └── WorkPackage.java
│ │ │ │ ├── PropagatingErrorHandler.java
│ │ │ │ ├── RemovedTrackerStatus.java
│ │ │ │ ├── replay
│ │ │ │ │ ├── GenericResetContext.java
│ │ │ │ │ ├── ReplayAwareMessageHandlerWrapper.java
│ │ │ │ │ ├── ReplayContext.java
│ │ │ │ │ ├── ReplayContextParameterResolverFactory.java
│ │ │ │ │ ├── ReplayParameterResolverFactory.java
│ │ │ │ │ └── ResetContext.java
│ │ │ │ ├── ReplayStatus.java
│ │ │ │ ├── ReplayToken.java
│ │ │ │ ├── ResetHandler.java
│ │ │ │ ├── ResetNotSupportedException.java
│ │ │ │ ├── scheduling
│ │ │ │ │ ├── dbscheduler
│ │ │ │ │ │ ├── DbSchedulerBinaryEventData.java
│ │ │ │ │ │ ├── DbSchedulerEventScheduler.java
│ │ │ │ │ │ ├── DbSchedulerEventSchedulerSupplier.java
│ │ │ │ │ │ ├── DbSchedulerHumanReadableEventData.java
│ │ │ │ │ │ ├── DbSchedulerScheduleToken.java
│ │ │ │ │ │ └── EventSchedulerNotSuppliedException.java
│ │ │ │ │ ├── EventScheduler.java
│ │ │ │ │ ├── java
│ │ │ │ │ │ ├── SimpleEventScheduler.java
│ │ │ │ │ │ └── SimpleScheduleToken.java
│ │ │ │ │ ├── jobrunr
│ │ │ │ │ │ ├── JobRunrEventScheduler.java
│ │ │ │ │ │ └── JobRunrScheduleToken.java
│ │ │ │ │ ├── quartz
│ │ │ │ │ │ ├── EventJobDataBinder.java
│ │ │ │ │ │ ├── FireEventJob.java
│ │ │ │ │ │ ├── QuartzEventScheduler.java
│ │ │ │ │ │ └── QuartzScheduleToken.java
│ │ │ │ │ ├── ScheduleToken.java
│ │ │ │ │ └── SchedulingException.java
│ │ │ │ ├── Segment.java
│ │ │ │ ├── SequenceNumber.java
│ │ │ │ ├── SequenceNumberParameterResolverFactory.java
│ │ │ │ ├── SimpleEventBus.java
│ │ │ │ ├── SimpleEventHandlerInvoker.java
│ │ │ │ ├── StreamingEventProcessor.java
│ │ │ │ ├── SubscribingEventProcessor.java
│ │ │ │ ├── Timestamp.java
│ │ │ │ ├── TimestampParameterResolverFactory.java
│ │ │ │ ├── tokenstore
│ │ │ │ │ ├── AbstractTokenEntry.java
│ │ │ │ │ ├── ConfigToken.java
│ │ │ │ │ ├── GenericTokenEntry.java
│ │ │ │ │ ├── inmemory
│ │ │ │ │ │ └── InMemoryTokenStore.java
│ │ │ │ │ ├── jdbc
│ │ │ │ │ │ ├── GenericTokenTableFactory.java
│ │ │ │ │ │ ├── JdbcTokenStore.java
│ │ │ │ │ │ ├── Oracle11TokenTableFactory.java
│ │ │ │ │ │ ├── PostgresTokenTableFactory.java
│ │ │ │ │ │ ├── TokenSchema.java
│ │ │ │ │ │ └── TokenTableFactory.java
│ │ │ │ │ ├── jpa
│ │ │ │ │ │ ├── JpaTokenStore.java
│ │ │ │ │ │ └── TokenEntry.java
│ │ │ │ │ ├── legacyjpa
│ │ │ │ │ │ └── JpaTokenStore.java
│ │ │ │ │ ├── TokenStore.java
│ │ │ │ │ ├── UnableToClaimTokenException.java
│ │ │ │ │ ├── UnableToInitializeTokenException.java
│ │ │ │ │ └── UnableToRetrieveIdentifierException.java
│ │ │ │ ├── TrackedDomainEventData.java
│ │ │ │ ├── TrackedEventData.java
│ │ │ │ ├── TrackedEventMessage.java
│ │ │ │ ├── TrackerStatus.java
│ │ │ │ ├── TrackingEventProcessorConfiguration.java
│ │ │ │ ├── TrackingEventProcessor.java
│ │ │ │ ├── TrackingEventStream.java
│ │ │ │ ├── TrackingToken.java
│ │ │ │ ├── TrackingTokenParameterResolverFactory.java
│ │ │ │ ├── TransactionMethodExecutionException.java
│ │ │ │ ├── WrappedToken.java
│ │ │ │ └── WrappedTrackerStatus.java
│ │ │ ├── lifecycle
│ │ │ │ ├── LifecycleHandlerInvocationException.java
│ │ │ │ ├── Lifecycle.java
│ │ │ │ ├── Phase.java
│ │ │ │ ├── ShutdownHandler.java
│ │ │ │ ├── ShutdownInProgressException.java
│ │ │ │ ├── ShutdownLatch.java
│ │ │ │ └── StartHandler.java
│ │ │ ├── messaging
│ │ │ │ ├── AbstractMessage.java
│ │ │ │ ├── annotation
│ │ │ │ │ ├── AbstractAnnotatedParameterResolverFactory.java
│ │ │ │ │ ├── AggregateType.java
│ │ │ │ │ ├── AggregateTypeParameterResolverFactory.java
│ │ │ │ │ ├── AnnotatedHandlerAttributes.java
│ │ │ │ │ ├── AnnotatedHandlerInspector.java
│ │ │ │ │ ├── AnnotatedMessageHandlingMemberDefinition.java
│ │ │ │ │ ├── AnnotatedMessageHandlingMember.java
│ │ │ │ │ ├── ClasspathHandlerDefinition.java
│ │ │ │ │ ├── ClasspathHandlerEnhancerDefinition.java
│ │ │ │ │ ├── ClasspathParameterResolverFactory.java
│ │ │ │ │ ├── DefaultParameterResolverFactory.java
│ │ │ │ │ ├── FixedValueParameterResolver.java
│ │ │ │ │ ├── HandlerComparator.java
│ │ │ │ │ ├── HandlerDefinition.java
│ │ │ │ │ ├── HandlerEnhancerDefinition.java
│ │ │ │ │ ├── HasHandlerAttributes.java
│ │ │ │ │ ├── InterceptorChainParameterResolverFactory.java
│ │ │ │ │ ├── MessageHandlerInterceptorDefinition.java
│ │ │ │ │ ├── MessageHandlerInterceptorMemberChain.java
│ │ │ │ │ ├── MessageHandlerInvocationException.java
│ │ │ │ │ ├── MessageHandler.java
│ │ │ │ │ ├── MessageHandlingMember.java
│ │ │ │ │ ├── MessageIdentifier.java
│ │ │ │ │ ├── MessageIdentifierParameterResolverFactory.java
│ │ │ │ │ ├── MessageInterceptingMember.java
│ │ │ │ │ ├── MetaDataValue.java
│ │ │ │ │ ├── MultiHandlerDefinition.java
│ │ │ │ │ ├── MultiHandlerEnhancerDefinition.java
│ │ │ │ │ ├── MultiParameterResolverFactory.java
│ │ │ │ │ ├── NoMoreInterceptors.java
│ │ │ │ │ ├── ParameterResolverFactory.java
│ │ │ │ │ ├── ParameterResolver.java
│ │ │ │ │ ├── PayloadParameterResolver.java
│ │ │ │ │ ├── ResultParameterResolverFactory.java
│ │ │ │ │ ├── ScopeDescriptorParameterResolverFactory.java
│ │ │ │ │ ├── SimpleResourceParameterResolverFactory.java
│ │ │ │ │ ├── SourceId.java
│ │ │ │ │ ├── SourceIdParameterResolverFactory.java
│ │ │ │ │ ├── UnsupportedHandlerException.java
│ │ │ │ │ └── WrappedMessageHandlingMember.java
│ │ │ │ ├── correlation
│ │ │ │ │ ├── CorrelationDataProvider.java
│ │ │ │ │ ├── MessageOriginProvider.java
│ │ │ │ │ ├── MultiCorrelationDataProvider.java
│ │ │ │ │ └── SimpleCorrelationDataProvider.java
│ │ │ │ ├── deadletter
│ │ │ │ │ ├── Cause.java
│ │ │ │ │ ├── DeadLetter.java
│ │ │ │ │ ├── DeadLetterParameterResolverFactory.java
│ │ │ │ │ ├── DeadLetterQueueOverflowException.java
│ │ │ │ │ ├── Decisions.java
│ │ │ │ │ ├── DoNotEnqueue.java
│ │ │ │ │ ├── EnqueueDecision.java
│ │ │ │ │ ├── EnqueuePolicy.java
│ │ │ │ │ ├── GenericDeadLetter.java
│ │ │ │ │ ├── Ignore.java
│ │ │ │ │ ├── InMemorySequencedDeadLetterQueue.java
│ │ │ │ │ ├── NoSuchDeadLetterException.java
│ │ │ │ │ ├── SequencedDeadLetterProcessor.java
│ │ │ │ │ ├── SequencedDeadLetterQueue.java
│ │ │ │ │ ├── ShouldEnqueue.java
│ │ │ │ │ ├── ThrowableCause.java
│ │ │ │ │ └── WrongDeadLetterTypeException.java
│ │ │ │ ├── DefaultInterceptorChain.java
│ │ │ │ ├── Distributed.java
│ │ │ │ ├── EventPublicationFailedException.java
│ │ │ │ ├── ExecutionException.java
│ │ │ │ ├── GenericMessage.java
│ │ │ │ ├── GenericResultMessage.java
│ │ │ │ ├── HandlerAttributes.java
│ │ │ │ ├── HandlerExecutionException.java
│ │ │ │ ├── Headers.java
│ │ │ │ ├── IllegalPayloadAccessException.java
│ │ │ │ ├── InterceptorChain.java
│ │ │ │ ├── interceptors
│ │ │ │ │ ├── BeanValidationInterceptor.java
│ │ │ │ │ ├── CorrelationDataInterceptor.java
│ │ │ │ │ ├── ExceptionHandler.java
│ │ │ │ │ ├── JSR303ViolationException.java
│ │ │ │ │ ├── legacyvalidation
│ │ │ │ │ │ ├── BeanValidationInterceptor.java
│ │ │ │ │ │ └── JSR303ViolationException.java
│ │ │ │ │ ├── LoggingInterceptor.java
│ │ │ │ │ ├── MessageHandlerInterceptor.java
│ │ │ │ │ ├── ResultHandler.java
│ │ │ │ │ └── TransactionManagingInterceptor.java
│ │ │ │ ├── MessageDecorator.java
│ │ │ │ ├── MessageDispatchInterceptor.java
│ │ │ │ ├── MessageDispatchInterceptorSupport.java
│ │ │ │ ├── MessageHandlerInterceptor.java
│ │ │ │ ├── MessageHandlerInterceptorSupport.java
│ │ │ │ ├── MessageHandler.java
│ │ │ │ ├── Message.java
│ │ │ │ ├── MetaData.java
│ │ │ │ ├── NoScopeDescriptor.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── RemoteExceptionDescription.java
│ │ │ │ ├── RemoteHandlingException.java
│ │ │ │ ├── RemoteNonTransientHandlingException.java
│ │ │ │ ├── responsetypes
│ │ │ │ │ ├── AbstractResponseType.java
│ │ │ │ │ ├── ConvertingResponseMessage.java
│ │ │ │ │ ├── InstanceResponseType.java
│ │ │ │ │ ├── MultipleInstancesResponseType.java
│ │ │ │ │ ├── OptionalResponseType.java
│ │ │ │ │ ├── PublisherResponseType.java
│ │ │ │ │ ├── ResponseType.java
│ │ │ │ │ └── ResponseTypes.java
│ │ │ │ ├── ResultMessage.java
│ │ │ │ ├── ScopeAware.java
│ │ │ │ ├── ScopeAwareProvider.java
│ │ │ │ ├── ScopeDescriptor.java
│ │ │ │ ├── Scope.java
│ │ │ │ ├── SimpleHandlerAttributes.java
│ │ │ │ ├── StreamableMessageSource.java
│ │ │ │ ├── SubscribableMessageSource.java
│ │ │ │ └── unitofwork
│ │ │ │ ├── AbstractUnitOfWork.java
│ │ │ │ ├── BatchingUnitOfWork.java
│ │ │ │ ├── CurrentUnitOfWork.java
│ │ │ │ ├── DefaultUnitOfWork.java
│ │ │ │ ├── ExecutionResult.java
│ │ │ │ ├── MessageProcessingContext.java
│ │ │ │ ├── RollbackConfiguration.java
│ │ │ │ ├── RollbackConfigurationType.java
│ │ │ │ └── UnitOfWork.java
│ │ │ ├── monitoring
│ │ │ │ ├── MessageMonitor.java
│ │ │ │ ├── MultiMessageMonitor.java
│ │ │ │ ├── NoOpMessageMonitorCallback.java
│ │ │ │ └── NoOpMessageMonitor.java
│ │ │ ├── queryhandling
│ │ │ │ ├── annotation
│ │ │ │ │ ├── AnnotationQueryHandlerAdapter.java
│ │ │ │ │ ├── MethodQueryMessageHandlerDefinition.java
│ │ │ │ │ └── QueryHandlingMember.java
│ │ │ │ ├── CompletedEmitterException.java
│ │ │ │ ├── DefaultQueryBusSpanFactory.java
│ │ │ │ ├── DefaultQueryGateway.java
│ │ │ │ ├── DefaultQueryUpdateEmitterSpanFactory.java
│ │ │ │ ├── DefaultSubscriptionQueryResult.java
│ │ │ │ ├── FluxSinkWrapper.java
│ │ │ │ ├── GenericQueryMessage.java
│ │ │ │ ├── GenericQueryResponseMessage.java
│ │ │ │ ├── GenericStreamingQueryMessage.java
│ │ │ │ ├── GenericSubscriptionQueryMessage.java
│ │ │ │ ├── GenericSubscriptionQueryUpdateMessage.java
│ │ │ │ ├── LoggingQueryInvocationErrorHandler.java
│ │ │ │ ├── MonoSinkWrapper.java
│ │ │ │ ├── NoHandlerForQueryException.java
│ │ │ │ ├── QueryBus.java
│ │ │ │ ├── QueryBusSpanFactory.java
│ │ │ │ ├── QueryExecutionException.java
│ │ │ │ ├── QueryGateway.java
│ │ │ │ ├── QueryHandlerAdapter.java
│ │ │ │ ├── QueryHandler.java
│ │ │ │ ├── QueryInvocationErrorHandler.java
│ │ │ │ ├── QueryMessage.java
│ │ │ │ ├── QueryResponseMessage.java
│ │ │ │ ├── QuerySubscription.java
│ │ │ │ ├── QueryUpdateEmitter.java
│ │ │ │ ├── QueryUpdateEmitterSpanFactory.java
│ │ │ │ ├── registration
│ │ │ │ │ ├── DuplicateQueryHandlerResolution.java
│ │ │ │ │ ├── DuplicateQueryHandlerResolver.java
│ │ │ │ │ ├── DuplicateQueryHandlerSubscriptionException.java
│ │ │ │ │ ├── FailingDuplicateQueryHandlerResolver.java
│ │ │ │ │ └── LoggingDuplicateQueryHandlerResolver.java
│ │ │ │ ├── SimpleQueryBus.java
│ │ │ │ ├── SimpleQueryUpdateEmitter.java
│ │ │ │ ├── SinksManyWrapper.java
│ │ │ │ ├── SinkWrapper.java
│ │ │ │ ├── StreamingQueryMessage.java
│ │ │ │ ├── SubscriptionQueryBackpressure.java
│ │ │ │ ├── SubscriptionQueryMessage.java
│ │ │ │ ├── SubscriptionQueryResult.java
│ │ │ │ ├── SubscriptionQueryUpdateMessage.java
│ │ │ │ └── UpdateHandlerRegistration.java
│ │ │ ├── serialization
│ │ │ │ ├── AbstractXStreamSerializer.java
│ │ │ │ ├── AnnotationRevisionResolver.java
│ │ │ │ ├── CachingSupplier.java
│ │ │ │ ├── CannotConvertBetweenTypesException.java
│ │ │ │ ├── ChainedConverter.java
│ │ │ │ ├── ChainingConverter.java
│ │ │ │ ├── ContentTypeConverter.java
│ │ │ │ ├── Converter.java
│ │ │ │ ├── converters
│ │ │ │ │ ├── BlobToInputStreamConverter.java
│ │ │ │ │ ├── ByteArrayToInputStreamConverter.java
│ │ │ │ │ ├── ByteArrayToStringConverter.java
│ │ │ │ │ ├── InputStreamToByteArrayConverter.java
│ │ │ │ │ └── StringToByteArrayConverter.java
│ │ │ │ ├── FixedValueRevisionResolver.java
│ │ │ │ ├── GapAwareTrackingTokenConverter.java
│ │ │ │ ├── JavaSerializer.java
│ │ │ │ ├── json
│ │ │ │ │ ├── ByteArrayToJsonNodeConverter.java
│ │ │ │ │ ├── JacksonSerializer.java
│ │ │ │ │ ├── JsonNodeToByteArrayConverter.java
│ │ │ │ │ ├── JsonNodeToObjectNodeConverter.java
│ │ │ │ │ ├── MetaDataDeserializer.java
│ │ │ │ │ └── ObjectNodeToJsonNodeConverter.java
│ │ │ │ ├── LazyDeserializingObject.java
│ │ │ │ ├── MavenArtifactRevisionResolver.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── Revision.java
│ │ │ │ ├── RevisionResolver.java
│ │ │ │ ├── SerializationException.java
│ │ │ │ ├── SerializedMessage.java
│ │ │ │ ├── SerializedMetaData.java
│ │ │ │ ├── SerializedObjectHolder.java
│ │ │ │ ├── SerializedObject.java
│ │ │ │ ├── SerializedType.java
│ │ │ │ ├── Serializer.java
│ │ │ │ ├── SerialVersionUIDRevisionResolver.java
│ │ │ │ ├── SimpleSerializedObject.java
│ │ │ │ ├── SimpleSerializedType.java
│ │ │ │ ├── UnknownSerializedType.java
│ │ │ │ ├── upcasting
│ │ │ │ │ ├── ContextAwareSingleEntryMultiUpcaster.java
│ │ │ │ │ ├── ContextAwareSingleEntryUpcaster.java
│ │ │ │ │ ├── event
│ │ │ │ │ │ ├── ContextAwareEventMultiUpcaster.java
│ │ │ │ │ │ ├── ContextAwareSingleEventUpcaster.java
│ │ │ │ │ │ ├── EventMultiUpcaster.java
│ │ │ │ │ │ ├── EventTypeUpcaster.java
│ │ │ │ │ │ ├── EventUpcasterChain.java
│ │ │ │ │ │ ├── EventUpcaster.java
│ │ │ │ │ │ ├── InitialEventRepresentation.java
│ │ │ │ │ │ ├── IntermediateEventRepresentation.java
│ │ │ │ │ │ ├── NoOpEventUpcaster.java
│ │ │ │ │ │ ├── SingleEventUpcaster.java
│ │ │ │ │ │ └── UpcastedEventRepresentation.java
│ │ │ │ │ ├── GenericUpcasterChain.java
│ │ │ │ │ ├── SingleEntryMultiUpcaster.java
│ │ │ │ │ ├── SingleEntryUpcaster.java
│ │ │ │ │ └── Upcaster.java
│ │ │ │ └── xml
│ │ │ │ ├── CompactDriver.java
│ │ │ │ ├── Dom4JToByteArrayConverter.java
│ │ │ │ ├── InputStreamToDom4jConverter.java
│ │ │ │ ├── InputStreamToXomConverter.java
│ │ │ │ ├── XomToStringConverter.java
│ │ │ │ └── XStreamSerializer.java
│ │ │ ├── tracing
│ │ │ │ ├── attributes
│ │ │ │ │ ├── AggregateIdentifierSpanAttributesProvider.java
│ │ │ │ │ ├── MessageIdSpanAttributesProvider.java
│ │ │ │ │ ├── MessageNameSpanAttributesProvider.java
│ │ │ │ │ ├── MessageTypeSpanAttributesProvider.java
│ │ │ │ │ ├── MetadataSpanAttributesProvider.java
│ │ │ │ │ └── PayloadTypeSpanAttributesProvider.java
│ │ │ │ ├── HandlerSpanFactory.java
│ │ │ │ ├── LoggingSpanFactory.java
│ │ │ │ ├── MultiSpanFactory.java
│ │ │ │ ├── NestingSpanFactory.java
│ │ │ │ ├── NoOpSpanFactory.java
│ │ │ │ ├── SpanAttributesProvider.java
│ │ │ │ ├── SpanFactory.java
│ │ │ │ ├── Span.java
│ │ │ │ ├── SpanScope.java
│ │ │ │ ├── SpanUtils.java
│ │ │ │ └── TracingHandlerEnhancerDefinition.java
│ │ │ └── util
│ │ │ ├── ClasspathResolver.java
│ │ │ ├── HandlerTypeResolver.java
│ │ │ └── MavenArtifactVersionResolver.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ ├── org.axonframework.common.property.PropertyAccessStrategy
│ │ ├── org.axonframework.messaging.annotation.HandlerDefinition
│ │ ├── org.axonframework.messaging.annotation.HandlerEnhancerDefinition
│ │ ├── org.axonframework.messaging.annotation.ParameterResolverFactory
│ │ └── org.axonframework.serialization.ContentTypeConverter
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── commandhandling
│ │ │ ├── AnnotationCommandHandlerAdapterTest.java
│ │ │ ├── AsynchronousCommandBusTest.java
│ │ │ ├── callbacks
│ │ │ │ └── FutureCallbackTest.java
│ │ │ ├── CurrentUnitOfWorkParameterResolverFactoryTest.java
│ │ │ ├── DefaultCommandBusSpanFactoryTest.java
│ │ │ ├── distributed
│ │ │ │ ├── AnnotationRoutingStrategyTest.java
│ │ │ │ ├── CommandCallbackRepositoryTest.java
│ │ │ │ ├── commandfilter
│ │ │ │ │ ├── AcceptAllSerializationTest.java
│ │ │ │ │ ├── AndCommandMessageFilterSerializationTest.java
│ │ │ │ │ ├── CommandFilterTest.java
│ │ │ │ │ ├── CommandNameFilterSerializationTest.java
│ │ │ │ │ ├── DenyAllSerializationTest.java
│ │ │ │ │ ├── DenyCommandNameFilterSerializationTest.java
│ │ │ │ │ ├── NegateCommandMessageFilterSerializationTest.java
│ │ │ │ │ └── OrCommandMessageFilterSerializationTest.java
│ │ │ │ ├── ConsistentHashTest.java
│ │ │ │ ├── DistributedCommandBusTest.java
│ │ │ │ ├── MetaDataRoutingStrategyTest.java
│ │ │ │ ├── ReplyMessageSerializationTest.java
│ │ │ │ └── UnresolvedRoutingKeyPolicyTest.java
│ │ │ ├── DuplicateCommandHandlerResolutionTest.java
│ │ │ ├── gateway
│ │ │ │ ├── AbstractRetrySchedulerTest.java
│ │ │ │ ├── CommandGatewayFactoryTest.java
│ │ │ │ ├── DefaultCommandGatewayTest.java
│ │ │ │ ├── ExponentialBackOffIntervalRetrySchedulerTest.java
│ │ │ │ └── IntervalRetrySchedulerTest.java
│ │ │ ├── GenericCommandMessageTest.java
│ │ │ ├── SimpleCommandBusTest.java
│ │ │ └── WrappedCommandCallbackTest.java
│ │ ├── common
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationUtilsTest.java
│ │ │ │ └── PriorityAnnotationComparatorTest.java
│ │ │ ├── AssertTest.java
│ │ │ ├── AxonThreadFactoryTest.java
│ │ │ ├── BuilderUtilsTest.java
│ │ │ ├── caching
│ │ │ │ ├── AbstractCacheAdapterTest.java
│ │ │ │ ├── EhCache3AdapterTest.java
│ │ │ │ ├── EhCacheAdapterTest.java
│ │ │ │ ├── JCacheAdapterTest.java
│ │ │ │ ├── NoCacheTest.java
│ │ │ │ └── WeakReferenceCacheTest.java
│ │ │ ├── CollectionUtilsTest.java
│ │ │ ├── DateTimeUtilsTest.java
│ │ │ ├── ExceptionUtilsTest.java
│ │ │ ├── IdentifierValidatorTest.java
│ │ │ ├── jdbc
│ │ │ │ ├── ConnectionWrapperFactoryTest.java
│ │ │ │ ├── JdbcUtilsTest.java
│ │ │ │ ├── PagingJdbcIterableTest.java
│ │ │ │ └── UnitOfWorkAwareConnectionProviderWrapperTest.java
│ │ │ ├── legacyjpa
│ │ │ │ ├── PagingJpaQueryIterableTest.java
│ │ │ │ └── TestJpaEntry.java
│ │ │ ├── lock
│ │ │ │ ├── LockFactoryTest.java
│ │ │ │ ├── NoOpLockTest.java
│ │ │ │ ├── NullLockFactoryTest.java
│ │ │ │ └── PessimisticLockFactoryTest.java
│ │ │ ├── ObjectUtilsTest.java
│ │ │ ├── ProcessUtilsTest.java
│ │ │ ├── property
│ │ │ │ ├── AbstractPropertyAccessStrategyTest.java
│ │ │ │ ├── BeanPropertyAccessStrategyTest.java
│ │ │ │ ├── DirectPropertyAccessStrategyTest.java
│ │ │ │ ├── PropertyAccessStrategyTest.java
│ │ │ │ └── UniformPropertyAccessStrategyTest.java
│ │ │ ├── ReflectionUtilsTest.java
│ │ │ ├── StringUtilsTest.java
│ │ │ └── transaction
│ │ │ └── NoOpTransactionManager.java
│ │ ├── deadline
│ │ │ ├── annotation
│ │ │ │ └── DeadlineMethodMessageHandlerDefinitionTest.java
│ │ │ ├── dbscheduler
│ │ │ │ ├── DbScheduledDeadlineTokenTest.java
│ │ │ │ ├── DbSchedulerBinaryDeadlineDetailsTest.java
│ │ │ │ ├── DbSchedulerDeadlineManagerBuilderTest.java
│ │ │ │ ├── DbSchedulerDeadlineManagerTest.java
│ │ │ │ └── DbSchedulerHumanReadableDeadlineDetailsTest.java
│ │ │ ├── DefaultDeadlineManagerSpanFactoryTest.java
│ │ │ ├── jobrunr
│ │ │ │ ├── DeadlineDetailsSerializationTest.java
│ │ │ │ ├── JobRunrDeadlineManagerBuilderTest.java
│ │ │ │ └── LabelUtilsTest.java
│ │ │ ├── quartz
│ │ │ │ └── DeadlineJobDataBinderTest.java
│ │ │ └── TestScopeDescriptor.java
│ │ ├── eventhandling
│ │ │ ├── AbstractEventBusTest.java
│ │ │ ├── AbstractEventProcessorTest.java
│ │ │ ├── AddedTrackerStatusTest.java
│ │ │ ├── AnnotatedParameterResolverFactoryTest.java
│ │ │ ├── AnnotationEventHandlerAdapterTest.java
│ │ │ ├── async
│ │ │ │ ├── AsynchronousEventProcessingStrategyTest.java
│ │ │ │ ├── AsynchronousEventProcessorConcurrencyTest.java
│ │ │ │ ├── FullConcurrencyPolicyTest.java
│ │ │ │ ├── PropertySequencingPolicyTest.java
│ │ │ │ ├── SequentialPerAggregatePolicyTest.java
│ │ │ │ └── SequentialPolicyTest.java
│ │ │ ├── ConcludesBatchParameterResolverFactoryTest.java
│ │ │ ├── deadletter
│ │ │ │ ├── DeadLetteredEventProcessingTaskTest.java
│ │ │ │ ├── DeadLetteringEventHandlerInvokerTest.java
│ │ │ │ ├── DeadLetteringEventIntegrationTest.java
│ │ │ │ ├── InMemoryDeadLetteringIntegrationTest.java
│ │ │ │ ├── InMemoryWithCacheDeadLetteringIntegrationTest.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── DeadLetterSchemaTest.java
│ │ │ │ │ ├── DefaultDeadLetterJdbcConverterTest.java
│ │ │ │ │ ├── DefaultDeadLetterStatementFactoryTest.java
│ │ │ │ │ ├── JdbcDeadLetteringEventIntegrationTest.java
│ │ │ │ │ └── JdbcSequencedDeadLetterQueueTest.java
│ │ │ │ ├── jpa
│ │ │ │ │ └── EventMessageDeadLetterJpaConverterTest.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaSequencedDeadLetterQueueTest.java
│ │ │ │ └── SequenceIdentifierCacheTest.java
│ │ │ ├── DefaultEventBusSpanFactoryTest.java
│ │ │ ├── DefaultEventProcessorSpanFactoryTest.java
│ │ │ ├── DirectEventProcessingStrategyTest.java
│ │ │ ├── EventHandlerInvokerTest.java
│ │ │ ├── EventMessageHandlerTest.java
│ │ │ ├── EventTrackerStatusChangeListenerTest.java
│ │ │ ├── EventTrackerStatusTest.java
│ │ │ ├── FakeEventTrackerStatus.java
│ │ │ ├── GapAwareTrackingTokenSerializationTest.java
│ │ │ ├── GapAwareTrackingTokenTest.java
│ │ │ ├── gateway
│ │ │ │ └── DefaultEventGatewayTest.java
│ │ │ ├── GenericDomainEventMessageTest.java
│ │ │ ├── GenericEventMessageTest.java
│ │ │ ├── GlobalSequenceTrackingTokenSerializationTest.java
│ │ │ ├── GlobalSequenceTrackingTokenTest.java
│ │ │ ├── MergedTrackingTokenSerializationTest.java
│ │ │ ├── MergedTrackingTokenTest.java
│ │ │ ├── MultiEventHandlerInvokerTest.java
│ │ │ ├── MultiSourceTrackingTokenSerializationTest.java
│ │ │ ├── MultiSourceTrackingTokenTest.java
│ │ │ ├── pooled
│ │ │ │ ├── CoordinatorTest.java
│ │ │ │ ├── MergeTaskTest.java
│ │ │ │ ├── PooledStreamingEventProcessorTest.java
│ │ │ │ ├── SplitTaskTest.java
│ │ │ │ └── WorkPackageTest.java
│ │ │ ├── PropagatingErrorHandlerTest.java
│ │ │ ├── RemovedTrackerStatusTest.java
│ │ │ ├── replay
│ │ │ │ ├── GenericResetContextTest.java
│ │ │ │ ├── ReplayAwareMessageHandlerWrapperTest.java
│ │ │ │ ├── ReplayAwareMessageHandlerWrapperWithDisallowReplayTest.java
│ │ │ │ ├── ReplayContextParameterResolverFactoryTest.java
│ │ │ │ └── ReplayParameterResolverFactoryTest.java
│ │ │ ├── ReplayTokenSerializationTest.java
│ │ │ ├── ReplayTokenTest.java
│ │ │ ├── scheduling
│ │ │ │ ├── dbscheduler
│ │ │ │ │ ├── AbstractDbSchedulerEventSchedulerTest.java
│ │ │ │ │ ├── BinaryDbSchedulerEventSchedulerTest.java
│ │ │ │ │ ├── DbScheduledScheduleTokenTest.java
│ │ │ │ │ ├── DbSchedulerBinaryEventDataTest.java
│ │ │ │ │ ├── DbSchedulerEventSchedulerBuilderTest.java
│ │ │ │ │ ├── DbSchedulerHumanReadableEventDataTest.java
│ │ │ │ │ └── HumanReadableDbSchedulerEventSchedulerTest.java
│ │ │ │ ├── java
│ │ │ │ │ ├── SimpleEventSchedulerTest.java
│ │ │ │ │ └── SimpleScheduleTokenSerializationTest.java
│ │ │ │ ├── jobrunr
│ │ │ │ │ ├── JobRunrEventSchedulerBuilderTest.java
│ │ │ │ │ ├── JobRunrEventSchedulerTest.java
│ │ │ │ │ └── JobRunrScheduleTokenTest.java
│ │ │ │ └── quartz
│ │ │ │ ├── DirectEventJobDataBinderTest.java
│ │ │ │ ├── QuartzEventSchedulerTest.java
│ │ │ │ └── QuartzScheduleTokenSerializationTest.java
│ │ │ ├── SegmentTest.java
│ │ │ ├── SimpleEventBusTest.java
│ │ │ ├── SimpleEventHandlerInvokerTest.java
│ │ │ ├── TimestampParameterResolverFactoryTest.java
│ │ │ ├── tokenstore
│ │ │ │ ├── ConfigTokenTest.java
│ │ │ │ ├── inmemory
│ │ │ │ │ └── InMemoryTokenStoreTest.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── JdbcTokenStoreTest.java
│ │ │ │ │ └── TokenSchemaTest.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaTokenStoreTest.java
│ │ │ │ └── TokenStoreTest.java
│ │ │ ├── TrackingEventProcessorConfigurationTest.java
│ │ │ └── TrackingTokenParameterResolverFactoryTest.java
│ │ ├── lifecycle
│ │ │ └── ShutdownLatchTest.java
│ │ ├── messaging
│ │ │ ├── annotation
│ │ │ │ ├── AggregateTypeParameterResolverFactoryTest.java
│ │ │ │ ├── AnnotatedHandlerAttributesTest.java
│ │ │ │ ├── AnnotatedHandlerInspectorTest.java
│ │ │ │ ├── AnnotatedMessageHandlingMemberTest.java
│ │ │ │ ├── HandlerComparatorTest.java
│ │ │ │ ├── HandlerHierarchyTest.java
│ │ │ │ ├── MessageIdentifierParameterResolverFactoryTest.java
│ │ │ │ ├── MultiParameterResolverFactoryTest.java
│ │ │ │ ├── ScopeDescriptorParameterResolverFactoryTest.java
│ │ │ │ ├── SimpleResourceParameterResolverFactoryTest.java
│ │ │ │ ├── SourceIdParameterResolverFactoryTest.java
│ │ │ │ └── WrappedMessageHandlingMemberTest.java
│ │ │ ├── correlation
│ │ │ │ ├── MetaDataValueTest.java
│ │ │ │ ├── SimpleCorrelationDataProviderTest.java
│ │ │ │ └── ThrowingCorrelationDataProvider.java
│ │ │ ├── deadletter
│ │ │ │ ├── DeadLetterParameterResolverFactoryTest.java
│ │ │ │ ├── DoNotEnqueueTest.java
│ │ │ │ ├── GenericDeadLetterTest.java
│ │ │ │ ├── IgnoreTest.java
│ │ │ │ ├── InMemorySequencedDeadLetterQueueTest.java
│ │ │ │ ├── SequencedDeadLetterQueueTest.java
│ │ │ │ ├── ShouldEnqueueTest.java
│ │ │ │ └── ThrowableCauseTest.java
│ │ │ ├── DefaultInterceptorChainTest.java
│ │ │ ├── GenericMessageTest.java
│ │ │ ├── GenericResultMessageTest.java
│ │ │ ├── HandlerExecutionExceptionTest.java
│ │ │ ├── HeadersTests.java
│ │ │ ├── interceptors
│ │ │ │ ├── CorrelationDataInterceptorTest.java
│ │ │ │ ├── ExceptionHandlerTest.java
│ │ │ │ ├── legacyvalidation
│ │ │ │ │ └── BeanValidationInterceptorTest.java
│ │ │ │ ├── LoggingInterceptorTest.java
│ │ │ │ └── TransactionManagingInterceptorTest.java
│ │ │ ├── MetaDataTest.java
│ │ │ ├── RemoteExceptionDescriptionSerializationTest.java
│ │ │ ├── responsetypes
│ │ │ │ ├── AbstractResponseTypeTest.java
│ │ │ │ ├── ConvertingResponseMessageTest.java
│ │ │ │ ├── InstanceResponseTypeSerializationTest.java
│ │ │ │ ├── InstanceResponseTypeTest.java
│ │ │ │ ├── MultipleInstancesResponseTypeSerializationTest.java
│ │ │ │ ├── MultipleInstancesResponseTypeTest.java
│ │ │ │ ├── OptionalResponseTypeSerializationTest.java
│ │ │ │ └── OptionalResponseTypeTest.java
│ │ │ ├── SimpleHandlerAttributesTest.java
│ │ │ └── unitofwork
│ │ │ ├── AbstractUnitOfWorkTest.java
│ │ │ ├── BatchingUnitOfWorkTest.java
│ │ │ ├── CurrentUnitOfWorkTest.java
│ │ │ ├── ExecutionResultTest.java
│ │ │ ├── RollbackConfigurationTypeTest.java
│ │ │ └── UnitOfWorkNestingTest.java
│ │ ├── monitoring
│ │ │ └── MultiMessageMonitorTest.java
│ │ ├── queryhandling
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationQueryHandlerAdapterTest.java
│ │ │ │ └── MethodQueryMessageHandlerDefinitionTest.java
│ │ │ ├── DefaultQueryBusSpanFactoryTest.java
│ │ │ ├── DefaultQueryGatewayTest.java
│ │ │ ├── DefaultQueryUpdateEmitterSpanFactoryTest.java
│ │ │ ├── FutureAsResponseTypeToQueryHandlersTest.java
│ │ │ ├── GenericQueryMessageTest.java
│ │ │ ├── GenericSubscriptionQueryUpdateMessageTest.java
│ │ │ ├── PrimitiveQueryHandlerResponseTypeTest.java
│ │ │ ├── registration
│ │ │ │ ├── FailingDuplicateQueryHandlerResolverTest.java
│ │ │ │ └── LoggingDuplicateQueryHandlerResolverTest.java
│ │ │ ├── SimpleQueryBusTest.java
│ │ │ ├── SimpleQueryUpdateEmitterTest.java
│ │ │ ├── StreamingQueryTest.java
│ │ │ └── UpdateHandlerRegistrationTest.java
│ │ ├── serialization
│ │ │ ├── AnnotationRevisionResolverTest.java
│ │ │ ├── ChainedConverterTest.java
│ │ │ ├── converters
│ │ │ │ ├── ByteArrayToStringConverterTest.java
│ │ │ │ ├── InputStreamToByteArrayConverterTest.java
│ │ │ │ └── StringToByteArrayConverterTest.java
│ │ │ ├── FixedValueRevisionResolverTest.java
│ │ │ ├── JavaSerializerTest.java
│ │ │ ├── json
│ │ │ │ ├── ByteArrayToJsonNodeConverterTest.java
│ │ │ │ ├── JacksonSerializerTest.java
│ │ │ │ ├── JsonNodeToByteArrayConverterTest.java
│ │ │ │ ├── JsonNodeToObjectNodeConverterTest.java
│ │ │ │ ├── MetaDataDeserializerTest.java
│ │ │ │ └── ObjectNodeToJsonNodeConverterTest.java
│ │ │ ├── LazyDeserializingObjectTest.java
│ │ │ ├── MavenArtifactRevisionResolverTest.java
│ │ │ ├── SerializationAwareTest.java
│ │ │ ├── SerializedMessageTest.java
│ │ │ ├── SerializedMetaDataValueTest.java
│ │ │ ├── SerialVersionUIDRevisionResolverTest.java
│ │ │ ├── TestSerializer.java
│ │ │ ├── upcasting
│ │ │ │ ├── event
│ │ │ │ │ ├── ContextAwareEventMultiUpcasterTest.java
│ │ │ │ │ ├── ContextAwareSingleEventUpcasterTest.java
│ │ │ │ │ ├── EventMultiUpcasterTest.java
│ │ │ │ │ ├── EventTypeUpcasterTest.java
│ │ │ │ │ ├── EventUpcasterChainTest.java
│ │ │ │ │ ├── InitialEventRepresentationTest.java
│ │ │ │ │ ├── IntermediateRepresentationTest.java
│ │ │ │ │ ├── SingleEventUpcasterTest.java
│ │ │ │ │ └── UpcastedEventRepresentationTest.java
│ │ │ │ └── GenericUpcasterChainTest.java
│ │ │ └── xml
│ │ │ ├── Dom4JToByteArrayConverterTest.java
│ │ │ ├── GapAwareTrackingTokenConverterTest.java
│ │ │ ├── InputStreamToDom4jConverterTest.java
│ │ │ ├── InputStreamToXomConverterTest.java
│ │ │ ├── XomToStringConverterTest.java
│ │ │ └── XStreamSerializerTest.java
│ │ ├── tracing
│ │ │ ├── attributes
│ │ │ │ ├── AggregateIdentifierSpanAttributesProviderTest.java
│ │ │ │ ├── MessageIdSpanAttributesProviderTest.java
│ │ │ │ ├── MessageNameSpanAttributesProviderTest.java
│ │ │ │ ├── MessageTypeSpanAttributesProviderTest.java
│ │ │ │ ├── MetadataSpanAttributesProviderTest.java
│ │ │ │ └── PayloadTypeSpanAttributesProviderTest.java
│ │ │ ├── IntermediateSpanFactoryTest.java
│ │ │ ├── LoggingSpanFactoryTest.java
│ │ │ ├── MultiSpanFactoryTest.java
│ │ │ ├── NestingSpanFactoryTest.java
│ │ │ ├── NoOpSpanFactoryTest.java
│ │ │ ├── SpanTest.java
│ │ │ ├── SpanUtilsTest.java
│ │ │ ├── TestSpanFactory.java
│ │ │ └── TracingHandlerEnhancerDefinitionTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── DbSchedulerTestUtil.java
│ │ ├── DelegateScheduledExecutorService.java
│ │ ├── EventTestUtils.java
│ │ ├── InMemoryStreamableEventSource.java
│ │ ├── MockException.java
│ │ ├── SecondStubEvent.java
│ │ ├── StubDomainEvent.java
│ │ ├── TestDomainEventEntry.java
│ │ └── ThirdStubEvent.java
│ └── resources
│ ├── ehcache.xml
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ └── META-INF
│ ├── maven
│ │ └── org.axonframework
│ │ └── axon-modelling
│ │ └── pom.properties
│ └── persistence.xml
├── metrics
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── metrics
│ │ ├── CapacityMonitor.java
│ │ ├── EventProcessorLatencyMonitor.java
│ │ ├── GlobalMetricRegistry.java
│ │ ├── MessageCountingMonitor.java
│ │ ├── MessageTimerMonitor.java
│ │ ├── MetricsConfigurerModule.java
│ │ └── PayloadTypeMessageMonitorWrapper.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── metrics
│ │ ├── CapacityMonitorTest.java
│ │ ├── EventProcessorLatencyMonitorTest.java
│ │ ├── GlobalMetricRegistryTest.java
│ │ ├── MessageCountingMonitorTest.java
│ │ ├── MessageTimerMonitorTest.java
│ │ ├── MetricsConfigurerModuleTest.java
│ │ ├── PayloadTypeMessageMonitorWrapperTest.java
│ │ └── TestClock.java
│ └── resources
│ └── log4j2.properties
├── metrics-micrometer
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── micrometer
│ │ ├── CapacityMonitor.java
│ │ ├── EventProcessorLatencyMonitor.java
│ │ ├── GlobalMetricRegistry.java
│ │ ├── MessageCountingMonitor.java
│ │ ├── MessageTimerMonitor.java
│ │ ├── MetricsConfigurerModule.java
│ │ ├── PayloadTypeMessageMonitorWrapper.java
│ │ ├── reservoir
│ │ │ └── SlidingTimeWindowReservoir.java
│ │ └── TagsUtil.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── micrometer
│ │ ├── CapacityMonitorTest.java
│ │ ├── EventProcessorLatencyMonitorTest.java
│ │ ├── GlobalMetricRegistryTest.java
│ │ ├── MessageCountingMonitorTest.java
│ │ ├── MessageTimerMonitorTest.java
│ │ ├── MetricsConfigurerModuleTest.java
│ │ ├── PayloadTypeMessageMonitorWrapperTest.java
│ │ └── reservoir
│ │ └── SlidingTimeWindowReservoirTest.java
│ └── resources
│ └── log4j2.properties
├── migration
│ ├── pom.xml
│ ├── README.md
│ └── src
│ ├── main
│ │ └── resources
│ │ └── META-INF
│ │ └── rewrite
│ │ ├── axon-jakarta-4.yml
│ │ └── axon-javax-4.yml
│ └── test
│ └── java
│ └── org
│ └── axonframework
│ └── migration
│ ├── AxonJakartaTest.java
│ └── AxonJavaxTest.java
├── modelling
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── modelling
│ │ │ ├── command
│ │ │ │ ├── AbstractRepository.java
│ │ │ │ ├── AggregateAnnotationCommandHandler.java
│ │ │ │ ├── AggregateCreationPolicy.java
│ │ │ │ ├── AggregateEntityNotFoundException.java
│ │ │ │ ├── AggregateIdentifier.java
│ │ │ │ ├── AggregateInvocationException.java
│ │ │ │ ├── Aggregate.java
│ │ │ │ ├── AggregateLifecycle.java
│ │ │ │ ├── AggregateMember.java
│ │ │ │ ├── AggregateNotFoundException.java
│ │ │ │ ├── AggregateRolledBackException.java
│ │ │ │ ├── AggregateRoot.java
│ │ │ │ ├── AggregateScopeDescriptor.java
│ │ │ │ ├── AggregateStreamCreationException.java
│ │ │ │ ├── AggregateVersion.java
│ │ │ │ ├── AnnotationCommandTargetResolver.java
│ │ │ │ ├── ApplyMore.java
│ │ │ │ ├── CommandHandlerInterceptor.java
│ │ │ │ ├── CommandTargetResolver.java
│ │ │ │ ├── ConcurrencyException.java
│ │ │ │ ├── ConflictingAggregateVersionException.java
│ │ │ │ ├── ConflictingModificationException.java
│ │ │ │ ├── CreationPolicyAggregateFactory.java
│ │ │ │ ├── CreationPolicy.java
│ │ │ │ ├── DefaultRepositorySpanFactory.java
│ │ │ │ ├── EntityId.java
│ │ │ │ ├── ForwardingMode.java
│ │ │ │ ├── ForwardMatchingInstances.java
│ │ │ │ ├── ForwardNone.java
│ │ │ │ ├── ForwardToAll.java
│ │ │ │ ├── GenericJpaRepository.java
│ │ │ │ ├── IdentifierMissingException.java
│ │ │ │ ├── inspection
│ │ │ │ │ ├── AbstractChildEntityDefinition.java
│ │ │ │ │ ├── AggregateMemberAnnotatedChildEntityCollectionDefinition.java
│ │ │ │ │ ├── AggregateMemberAnnotatedChildEntityDefinition.java
│ │ │ │ │ ├── AggregateMemberAnnotatedChildEntityMapDefinition.java
│ │ │ │ │ ├── AggregateMetaModelFactory.java
│ │ │ │ │ ├── AggregateModel.java
│ │ │ │ │ ├── AggregateModellingException.java
│ │ │ │ │ ├── AnnotatedAggregate.java
│ │ │ │ │ ├── AnnotatedAggregateMetaModelFactory.java
│ │ │ │ │ ├── AnnotatedChildEntity.java
│ │ │ │ │ ├── AnnotatedCommandHandlerInterceptor.java
│ │ │ │ │ ├── ChildEntityDefinition.java
│ │ │ │ │ ├── ChildEntity.java
│ │ │ │ │ ├── ChildForwardingCommandMessageHandlingMember.java
│ │ │ │ │ ├── CommandHandlerInterceptorHandlingMember.java
│ │ │ │ │ ├── CreationPolicyMember.java
│ │ │ │ │ ├── EntityModel.java
│ │ │ │ │ ├── ForwardingCommandMessageHandlingMember.java
│ │ │ │ │ ├── MethodCommandHandlerInterceptorDefinition.java
│ │ │ │ │ └── MethodCreationPolicyDefinition.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── GenericJpaRepository.java
│ │ │ │ ├── LockAwareAggregate.java
│ │ │ │ ├── LockingRepository.java
│ │ │ │ ├── MetaDataCommandTargetResolver.java
│ │ │ │ ├── NoArgumentConstructorCreationPolicyAggregateFactory.java
│ │ │ │ ├── Repository.java
│ │ │ │ ├── RepositoryProvider.java
│ │ │ │ ├── RepositorySpanFactory.java
│ │ │ │ ├── TargetAggregateIdentifier.java
│ │ │ │ ├── TargetAggregateVersion.java
│ │ │ │ └── VersionedAggregateIdentifier.java
│ │ │ └── saga
│ │ │ ├── AbstractResourceInjector.java
│ │ │ ├── AbstractSagaManager.java
│ │ │ ├── AnnotatedSaga.java
│ │ │ ├── AnnotatedSagaManager.java
│ │ │ ├── AssociationResolver.java
│ │ │ ├── AssociationValue.java
│ │ │ ├── AssociationValuesImpl.java
│ │ │ ├── AssociationValues.java
│ │ │ ├── DefaultSagaManagerSpanFactory.java
│ │ │ ├── EndSaga.java
│ │ │ ├── EndSagaMessageHandlerDefinition.java
│ │ │ ├── MetaDataAssociationResolver.java
│ │ │ ├── metamodel
│ │ │ │ ├── AnnotationSagaMetaModelFactory.java
│ │ │ │ ├── SagaMetaModelFactory.java
│ │ │ │ └── SagaModel.java
│ │ │ ├── PayloadAssociationResolver.java
│ │ │ ├── repository
│ │ │ │ ├── AnnotatedSagaRepository.java
│ │ │ │ ├── AssociationValueMap.java
│ │ │ │ ├── CachingSagaStore.java
│ │ │ │ ├── inmemory
│ │ │ │ │ └── InMemorySagaStore.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── GenericSagaSqlSchema.java
│ │ │ │ │ ├── HsqlSagaSqlSchema.java
│ │ │ │ │ ├── JdbcSagaStore.java
│ │ │ │ │ ├── Oracle11SagaSqlSchema.java
│ │ │ │ │ ├── PostgresSagaSqlSchema.java
│ │ │ │ │ ├── SagaSchema.java
│ │ │ │ │ └── SagaSqlSchema.java
│ │ │ │ ├── jpa
│ │ │ │ │ ├── AbstractSagaEntry.java
│ │ │ │ │ ├── AssociationValueEntry.java
│ │ │ │ │ ├── JpaSagaStore.java
│ │ │ │ │ ├── SagaEntry.java
│ │ │ │ │ └── SerializedSaga.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaSagaStore.java
│ │ │ │ ├── LockingSagaRepository.java
│ │ │ │ ├── NoResourceInjector.java
│ │ │ │ ├── SagaCreationException.java
│ │ │ │ └── SagaStore.java
│ │ │ ├── ResourceInjector.java
│ │ │ ├── SagaCreationPolicy.java
│ │ │ ├── SagaEventHandler.java
│ │ │ ├── SagaExecutionException.java
│ │ │ ├── SagaInitializationPolicy.java
│ │ │ ├── SagaInstantiationException.java
│ │ │ ├── Saga.java
│ │ │ ├── SagaLifecycle.java
│ │ │ ├── SagaManagerSpanFactory.java
│ │ │ ├── SagaMethodMessageHandlerDefinition.java
│ │ │ ├── SagaMethodMessageHandlingMember.java
│ │ │ ├── SagaRepository.java
│ │ │ ├── SagaScopeDescriptor.java
│ │ │ ├── SagaStorageException.java
│ │ │ ├── SimpleResourceInjector.java
│ │ │ └── StartSaga.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ ├── org.axonframework.messaging.annotation.HandlerEnhancerDefinition
│ │ └── org.axonframework.modelling.command.inspection.ChildEntityDefinition
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── modelling
│ │ ├── command
│ │ │ ├── AbstractRepositoryTest.java
│ │ │ ├── AggregateAnnotationCommandHandlerTest.java
│ │ │ ├── AggregateScopeDescriptorSerializationTest.java
│ │ │ ├── AnnotatedAggregateTest.java
│ │ │ ├── AnnotationCommandTargetResolverTest.java
│ │ │ ├── EntityEventForwardingModelInspectorTest.java
│ │ │ ├── GenericJpaRepositoryTest.java
│ │ │ ├── inspection
│ │ │ │ ├── AnnotatedAggregateAggregateMemberMetaModelFactoryTest.java
│ │ │ │ ├── AnnotatedAggregateMetaModelFactoryTest.java
│ │ │ │ ├── AnnotatedPolymorphicAggregateMetaModelFactoryTest.java
│ │ │ │ ├── AnnotatedRootMessageHandlingMemberAggregateMetaModelFactoryTest.java
│ │ │ │ ├── ChildForwardingCommandMessageHandlingMemberTest.java
│ │ │ │ └── legacyvalidation
│ │ │ │ └── AnnotatedAggregateMetaModelFactoryTest.java
│ │ │ ├── JpaAggregate.java
│ │ │ ├── LegacyGenericJpaRepositoryTest.java
│ │ │ ├── LockAwareAggregateTest.java
│ │ │ ├── LockingRepositoryTest.java
│ │ │ └── StubAggregate.java
│ │ ├── OnlyAcceptConstructorPropertiesAnnotation.java
│ │ ├── saga
│ │ │ ├── AnnotatedSagaManagerTest.java
│ │ │ ├── AnnotatedSagaTest.java
│ │ │ ├── AssociationValuesImplTest.java
│ │ │ ├── CustomEndingSagaEventHandler.java
│ │ │ ├── CustomStartingSagaEventHandler.java
│ │ │ ├── metamodel
│ │ │ │ └── AnnotationSagaMetaModelFactoryTest.java
│ │ │ ├── PayLoadAssociationResolverTest.java
│ │ │ ├── repository
│ │ │ │ ├── AnnotatedSagaRepositoryTest.java
│ │ │ │ ├── AssociationValueMapTest.java
│ │ │ │ ├── CachingSagaStoreTest.java
│ │ │ │ ├── concurrent
│ │ │ │ │ ├── AbstractTestSaga.java
│ │ │ │ │ ├── ConcurrentSaga.java
│ │ │ │ │ ├── CreateEvent.java
│ │ │ │ │ ├── DeleteEvent.java
│ │ │ │ │ ├── NonConcurrentSaga.java
│ │ │ │ │ └── UpdateEvent.java
│ │ │ │ ├── EhCache3SagaStoreTest.java
│ │ │ │ ├── EhCachingSagaStoreTest.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── JdbcSagaStoreTest.java
│ │ │ │ │ └── SagaSchemaTest.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaSagaStoreTest.java
│ │ │ │ ├── LockingSagaRepositoryTest.java
│ │ │ │ ├── StubSaga.java
│ │ │ │ └── WeakReferenceCachingSagaStoreTest.java
│ │ │ ├── SagaManagerTest.java
│ │ │ ├── SagaMethodMessageHandlerDefinitionTest.java
│ │ │ ├── SagaScopeDescriptorSerializationTest.java
│ │ │ └── SimpleResourceInjectorTest.java
│ │ └── utils
│ │ ├── ConcurrencyUtils.java
│ │ ├── EventTestUtils.java
│ │ ├── MockException.java
│ │ ├── StubDomainEvent.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ └── META-INF
│ └── persistence.xml
├── mvnw
├── mvnw.cmd
├── pom.xml
├── reactorless-test
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── reactorlesstest
│ │ └── ReactorlessStartup.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── reactorlesstest
│ │ └── ReactorlessStartupTest.java
│ └── resources
│ ├── application.properties
│ └── log4j2.properties
├── README.md
├── spring
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── spring
│ │ ├── config
│ │ │ ├── AbstractAnnotationHandlerBeanPostProcessor.java
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationCommandHandlerBeanPostProcessor.java
│ │ │ │ ├── AnnotationQueryHandlerBeanPostProcessor.java
│ │ │ │ ├── HandlerDefinitionFactoryBean.java
│ │ │ │ ├── SpringBeanDependencyResolverFactory.java
│ │ │ │ ├── SpringBeanParameterResolverFactory.java
│ │ │ │ ├── SpringContextHandlerDefinitionBuilder.java
│ │ │ │ ├── SpringContextParameterResolverFactoryBuilder.java
│ │ │ │ ├── SpringHandlerDefinitionBean.java
│ │ │ │ ├── SpringHandlerEnhancerDefinitionBean.java
│ │ │ │ └── SpringParameterResolverFactoryBean.java
│ │ │ ├── AnnotationDriven.java
│ │ │ ├── AnnotationDrivenRegistrar.java
│ │ │ ├── ApplicationContextLookupParameterResolverFactory.java
│ │ │ ├── AxonConfiguration.java
│ │ │ ├── BeanHelper.java
│ │ │ ├── CommandHandlerSubscriber.java
│ │ │ ├── ConfigurerFactoryBean.java
│ │ │ ├── EventHandlerRegistrar.java
│ │ │ ├── MessageHandlerConfigurer.java
│ │ │ ├── MessageHandlerLookup.java
│ │ │ ├── NoBeanOfType.java
│ │ │ ├── QueryHandlerSubscriber.java
│ │ │ ├── RepositoryFactoryBean.java
│ │ │ ├── SpringAggregateConfigurer.java
│ │ │ ├── SpringAggregateLookup.java
│ │ │ ├── SpringAxonAutoConfigurer.java
│ │ │ ├── SpringAxonConfiguration.java
│ │ │ ├── SpringConfigurer.java
│ │ │ ├── SpringSagaConfigurer.java
│ │ │ ├── SpringSagaLookup.java
│ │ │ └── TransactionManagerFactoryBean.java
│ │ ├── event
│ │ │ └── AxonStartedEvent.java
│ │ ├── eventhandling
│ │ │ └── scheduling
│ │ │ ├── java
│ │ │ │ └── SimpleEventSchedulerFactoryBean.java
│ │ │ └── quartz
│ │ │ └── QuartzEventSchedulerFactoryBean.java
│ │ ├── eventsourcing
│ │ │ ├── SpringAggregateSnapshotterFactoryBean.java
│ │ │ ├── SpringAggregateSnapshotter.java
│ │ │ └── SpringPrototypeAggregateFactory.java
│ │ ├── jdbc
│ │ │ └── SpringDataSourceConnectionProvider.java
│ │ ├── messaging
│ │ │ ├── ApplicationContextEventPublisher.java
│ │ │ ├── DefaultEventMessageConverter.java
│ │ │ ├── EventMessageConverter.java
│ │ │ ├── InboundEventMessageChannelAdapter.java
│ │ │ ├── OutboundEventMessageChannelAdapter.java
│ │ │ ├── package-info.java
│ │ │ └── unitofwork
│ │ │ └── SpringTransactionManager.java
│ │ ├── modelling
│ │ │ └── SpringRepositoryFactoryBean.java
│ │ ├── saga
│ │ │ └── SpringResourceInjector.java
│ │ ├── SpringUtils.java
│ │ └── stereotype
│ │ ├── Aggregate.java
│ │ └── Saga.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── integrationtests
│ │ │ └── deadline
│ │ │ └── AbstractDeadlineManagerTestSuite.java
│ │ └── spring
│ │ ├── AggregatePolymorphismTest.java
│ │ ├── config
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationCommandHandlerBeanPostProcessorTest.java
│ │ │ │ ├── AnnotationQueryHandlerBeanPostProcessorTest.java
│ │ │ │ ├── SomeCommandHandlerInterface.java
│ │ │ │ ├── SomeMeaninglessInterface.java
│ │ │ │ ├── SpringBeanResolverFactoryTest.java
│ │ │ │ ├── StubAggregate.java
│ │ │ │ ├── TransactionalCommandHandler.java
│ │ │ │ ├── TransactionalCommandHandlerSuperClass.java
│ │ │ │ └── TransactionalListener.java
│ │ │ ├── AnnotationDrivenConfigurationTest_CustomValues.java
│ │ │ ├── AnnotationDrivenConfigurationTest_DefaultValues.java
│ │ │ ├── AutoWiredEventSourcedAggregateTest.java
│ │ │ ├── AutoWiredStateStoredAggregateTest.java
│ │ │ ├── BeanHelperTest.java
│ │ │ ├── EventHandlerRegistrarTest.java
│ │ │ ├── EventProcessingModuleConfigTest.java
│ │ │ ├── EventProcessingModuleWithInterceptorsTest.java
│ │ │ ├── SpringAxonAutoConfigurerTest_CustomEventHandlerConfiguration.java
│ │ │ ├── SpringAxonAutoConfigurerTest.java
│ │ │ ├── SpringAxonConfigurationTest.java
│ │ │ ├── SpringConfigurerTest.java
│ │ │ ├── StubDomainEvent.java
│ │ │ └── UpcasterOrderingTest.java
│ │ ├── eventhandling
│ │ │ ├── deadletter
│ │ │ │ └── SpringJpaDeadLetteringIntegrationTest.java
│ │ │ ├── scheduling
│ │ │ │ ├── java
│ │ │ │ │ └── ResultStoringScheduledExecutorService.java
│ │ │ │ ├── MySagaExpiredEvent.java
│ │ │ │ ├── quartz
│ │ │ │ │ └── QuartzTableMaker.java
│ │ │ │ ├── SimpleTimingSaga.java
│ │ │ │ └── StartingEvent.java
│ │ │ └── tokenstore
│ │ │ └── jpa
│ │ │ └── JpaTokenStoreTest.java
│ │ ├── eventsourcing
│ │ │ ├── benchmark
│ │ │ │ └── JpaStorageEngineInsertionReadOrderTest.java
│ │ │ ├── context
│ │ │ │ └── SpringWiredAggregate.java
│ │ │ ├── SpringAggregateSnapshotterFactoryBeanTest.java
│ │ │ └── SpringPrototypeAggregateFactoryTest.java
│ │ ├── jdbc
│ │ │ └── SpringDataSourceConnectionProviderTest.java
│ │ ├── messaging
│ │ │ ├── ApplicationContextEventPublisherTest.java
│ │ │ ├── DefaultEventMessageConverterTest.java
│ │ │ ├── InboundEventMessageChannelAdapterTest.java
│ │ │ ├── OutboundEventMessageChannelAdapterTest.java
│ │ │ └── unitofwork
│ │ │ └── SpringTransactionManagerTest.java
│ │ ├── modeling
│ │ │ └── command
│ │ │ ├── GenericJpaRepositoryIntegrationTest.java
│ │ │ └── JpaAggregate.java
│ │ ├── saga
│ │ │ └── SpringResourceInjectorTest.java
│ │ ├── trial
│ │ │ ├── MyOtherSaga.java
│ │ │ └── MySaga.java
│ │ └── utils
│ │ ├── MysqlTestContainerExtension.java
│ │ └── StubDomainEvent.java
│ └── resources
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ ├── META-INF
│ │ └── persistence.xml
│ ├── quartz.test.properties
│ ├── tables_hsqldb.sql
│ └── tables_mysql_innodb.sql
├── spring-boot3-dummy
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── org
│ └── springframework
│ └── boot
│ ├── autoconfigure
│ │ └── service
│ │ └── connection
│ │ └── ConnectionDetails.java
│ ├── docker
│ │ └── compose
│ │ ├── core
│ │ │ ├── ConnectionPorts.java
│ │ │ ├── ImageReference.java
│ │ │ └── RunningService.java
│ │ └── service
│ │ └── connection
│ │ ├── DockerComposeConnectionDetailsFactory.java
│ │ └── DockerComposeConnectionSource.java
│ └── testcontainers
│ └── service
│ └── connection
│ ├── ContainerConnectionDetailsFactory.java
│ └── ContainerConnectionSource.java
├── spring-boot-3-integrationtests
│ ├── pom.xml
│ ├── src
│ │ └── test
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ ├── eventhandling
│ │ │ │ └── deadletter
│ │ │ │ └── DeadLetteringEventIntegrationTest.java
│ │ │ ├── integrationtests
│ │ │ │ └── eventsourcing
│ │ │ │ └── eventstore
│ │ │ │ ├── EmbeddedEventStoreTest.java
│ │ │ │ └── jpa
│ │ │ │ └── JpaEmbeddedEventStoreTest.java
│ │ │ ├── spring
│ │ │ │ ├── eventhandling
│ │ │ │ │ ├── deadletter
│ │ │ │ │ │ └── SpringJpaDeadLetteringIntegrationTest.java
│ │ │ │ │ └── tokenstore
│ │ │ │ │ └── jpa
│ │ │ │ │ └── JpaTokenStoreTest.java
│ │ │ │ ├── eventsourcing
│ │ │ │ │ └── benchmark
│ │ │ │ │ └── JpaStorageEngineInsertionReadOrderTest.java
│ │ │ │ └── modeling
│ │ │ │ └── command
│ │ │ │ ├── GenericJpaRepositoryIntegrationTest.java
│ │ │ │ └── JpaAggregate.java
│ │ │ └── springboot
│ │ │ ├── autoconfig
│ │ │ │ ├── AggregatePolymorphismAutoConfigurationTest.java
│ │ │ │ ├── AggregateStereotypeAutoConfigurationTest.java
│ │ │ │ └── context
│ │ │ │ ├── Animal.java
│ │ │ │ ├── AnimalRenamedEvent.java
│ │ │ │ ├── CatCreatedEvent.java
│ │ │ │ ├── Cat.java
│ │ │ │ ├── CreateCatCommand.java
│ │ │ │ ├── CreateDogCommand.java
│ │ │ │ ├── DogCreatedEvent.java
│ │ │ │ ├── Dog.java
│ │ │ │ └── RenameAnimalCommand.java
│ │ │ ├── AxonAutoConfigurationWithEventSerializerPropertiesTest.java
│ │ │ ├── AxonAutoConfigurationWithEventSerializerTest.java
│ │ │ ├── AxonAutoConfigurationWithHibernateTest.java
│ │ │ ├── JpaAutoConfigurationLazySagaStoreTest.java
│ │ │ ├── JpaAutoConfigurationTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithoutAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithSnapshottingTest.java
│ │ │ ├── RepositoryWiringTest.java
│ │ │ ├── service
│ │ │ │ └── connection
│ │ │ │ ├── SpringBootApplication.java
│ │ │ │ ├── SpringBootDockerComposeIntegrationTest.java
│ │ │ │ └── SpringBootTestContainerIntegrationTest.java
│ │ │ ├── TrackingEventProcessorIntegrationTest.java
│ │ │ ├── util
│ │ │ │ └── XStreamSecurityTypeUtilityTest.java
│ │ │ └── utils
│ │ │ ├── ControlChannelStub.java
│ │ │ ├── GrpcServerStub.java
│ │ │ └── TcpUtils.java
│ │ └── resources
│ │ ├── application.serializertest.properties
│ │ ├── hsqldb.database.properties
│ │ ├── log4j2.properties
│ │ ├── logback-test.xml
│ │ └── META-INF
│ │ └── persistence.xml
│ └── test-docker-compose.yml
├── spring-boot-autoconfigure
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ ├── actuator
│ │ │ │ ├── axonserver
│ │ │ │ │ ├── AxonServerHealthIndicator.java
│ │ │ │ │ └── AxonServerStatusAggregator.java
│ │ │ │ └── HealthStatus.java
│ │ │ └── springboot
│ │ │ ├── autoconfig
│ │ │ │ ├── AxonAutoConfiguration.java
│ │ │ │ ├── AxonDbSchedulerAutoConfiguration.java
│ │ │ │ ├── AxonJobRunrAutoConfiguration.java
│ │ │ │ ├── AxonServerActuatorAutoConfiguration.java
│ │ │ │ ├── AxonServerAutoConfiguration.java
│ │ │ │ ├── AxonServerBusAutoConfiguration.java
│ │ │ │ ├── AxonTracingAutoConfiguration.java
│ │ │ │ ├── CBORMapperAutoConfiguration.java
│ │ │ │ ├── EventProcessingAutoConfiguration.java
│ │ │ │ ├── InfraConfiguration.java
│ │ │ │ ├── JdbcAutoConfiguration.java
│ │ │ │ ├── JpaAutoConfiguration.java
│ │ │ │ ├── JpaEventStoreAutoConfiguration.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ ├── JpaJavaxAutoConfiguration.java
│ │ │ │ │ └── JpaJavaxEventStoreAutoConfiguration.java
│ │ │ │ ├── MetricsAutoConfiguration.java
│ │ │ │ ├── MicrometerMetricsAutoConfiguration.java
│ │ │ │ ├── NoOpTransactionAutoConfiguration.java
│ │ │ │ ├── ObjectMapperAutoConfiguration.java
│ │ │ │ ├── OpenTelemetryAutoConfiguration.java
│ │ │ │ ├── TransactionAutoConfiguration.java
│ │ │ │ └── XStreamAutoConfiguration.java
│ │ │ ├── DistributedCommandBusProperties.java
│ │ │ ├── EventProcessorProperties.java
│ │ │ ├── MetricsProperties.java
│ │ │ ├── SerializerProperties.java
│ │ │ ├── service
│ │ │ │ └── connection
│ │ │ │ ├── AxonServerConnectionDetails.java
│ │ │ │ ├── AxonServerDockerComposeConnectionDetailsFactory.java
│ │ │ │ └── AxonServerTestContainerConnectionDetailsFactory.java
│ │ │ ├── TagsConfigurationProperties.java
│ │ │ ├── TokenStoreProperties.java
│ │ │ ├── TracingProperties.java
│ │ │ └── util
│ │ │ ├── AbstractQualifiedBeanCondition.java
│ │ │ ├── ConditionalOnMissingQualifiedBean.java
│ │ │ ├── ConditionalOnQualifiedBean.java
│ │ │ ├── DeadLetterQueueProviderConfigurerModule.java
│ │ │ ├── DefaultEntityRegistrar.java
│ │ │ ├── jpa
│ │ │ │ └── ContainerManagedEntityManagerProvider.java
│ │ │ ├── legacyjpa
│ │ │ │ └── ContainerManagedEntityManagerProvider.java
│ │ │ ├── OnMissingQualifiedBeanCondition.java
│ │ │ ├── OnQualifiedBeanCondition.java
│ │ │ ├── RegisterDefaultEntities.java
│ │ │ └── XStreamSecurityTypeUtility.java
│ │ └── resources
│ │ └── META-INF
│ │ ├── spring
│ │ │ └── org.springframework.boot.autoconfigure.AutoConfiguration.imports
│ │ └── spring.factories
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── actuator
│ │ │ └── axonserver
│ │ │ └── AxonServerHealthIndicatorTest.java
│ │ └── springboot
│ │ ├── autoconfig
│ │ │ ├── AxonServerActuatorAutoConfigurationTest.java
│ │ │ ├── AxonServerAutoConfigurationLoadFactorTest.java
│ │ │ ├── AxonServerAutoConfigurationTest.java
│ │ │ ├── CBORMapperAutoConfigurationTest.java
│ │ │ ├── InfraConfigurationTest.java
│ │ │ ├── LoadBalancingStrategyAutoConfigurationTest.java
│ │ │ ├── ObjectMapperAutoConfigurationTest.java
│ │ │ └── XStreamAutoConfigurationTest.java
│ │ ├── AxonAutoConfigurationTest.java
│ │ ├── AxonAutoConfigurationWithDisruptorTest.java
│ │ ├── AxonAutoConfigurationWithMetricsTest.java
│ │ ├── AxonAutoConfigurationWithMetricsWithoutConfigurerTest.java
│ │ ├── AxonAutoConfigurationWithMicrometerMetricsTest.java
│ │ ├── AxonAutoConfigurationWithMicrometerMetricsWithoutConfigurerTest.java
│ │ ├── AxonAutoConfigurationWithOnlyEventSerializerTest.java
│ │ ├── AxonAutoConfigurationWithOpenTelemetryTest.java
│ │ ├── AxonAutoConfigurationWithoutObjectMapperTest.java
│ │ ├── AxonAutoConfigurationWithTagsTest.java
│ │ ├── AxonAutoConfigurationWithTracingTest.java
│ │ ├── AxonHandlerConfigurationTest.java
│ │ ├── DbSchedulerAutoConfigurationTest.java
│ │ ├── EventProcessorConfigurationTest.java
│ │ ├── HandlerEnhancerDefinitionConfigurationTest.java
│ │ ├── JdbcAutoConfigurationTest.java
│ │ ├── JobRunrAutoConfigurationTest.java
│ │ ├── legacyjpa
│ │ │ ├── JpaEventStoreAutoConfigurationWithAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithoutAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithSnapshottingTest.java
│ │ │ ├── JpaJavaxAutoConfigurationLazySagaStoreTest.java
│ │ │ └── JpaJavaxAutoConfigurationTest.java
│ │ ├── PooledStreamingEventProcessorIntegrationTest.java
│ │ ├── RepositoryWiringTest.java
│ │ ├── SagaCustomizeIntegrationTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── ControlChannelStub.java
│ │ ├── GrpcServerStub.java
│ │ ├── TcpUtils.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── application.serializertest.properties
│ ├── application.serializer-without-jackson.test.properties
│ ├── log4j2.properties
│ ├── test.jgroups.application.properties
│ ├── test.metrics.application.properties
│ └── test.springcloud.application.properties
├── spring-boot-starter
│ └── pom.xml
├── test
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── test
│ │ │ ├── aggregate
│ │ │ │ ├── AggregateTestFixture.java
│ │ │ │ ├── FixtureConfiguration.java
│ │ │ │ ├── Reporter.java
│ │ │ │ ├── ResultValidatorImpl.java
│ │ │ │ ├── ResultValidator.java
│ │ │ │ ├── StubAggregateLifecycleExtension.java
│ │ │ │ ├── StubAggregateLifecycle.java
│ │ │ │ ├── StubAggregateLifecycleRule.java
│ │ │ │ └── TestExecutor.java
│ │ │ ├── AxonAssertionError.java
│ │ │ ├── deadline
│ │ │ │ ├── DeadlineConsumer.java
│ │ │ │ ├── DeadlineManagerValidator.java
│ │ │ │ ├── ScheduledDeadlineInfo.java
│ │ │ │ └── StubDeadlineManager.java
│ │ │ ├── eventscheduler
│ │ │ │ ├── EventConsumer.java
│ │ │ │ ├── EventSchedulerValidator.java
│ │ │ │ ├── ScheduledItem.java
│ │ │ │ ├── StubEventScheduler.java
│ │ │ │ └── StubScheduleToken.java
│ │ │ ├── FixtureExecutionException.java
│ │ │ ├── FixtureResourceParameterResolverFactory.java
│ │ │ ├── matchers
│ │ │ │ ├── AllFieldsFilter.java
│ │ │ │ ├── DeepEqualsMatcher.java
│ │ │ │ ├── EmptyCollectionMatcher.java
│ │ │ │ ├── EqualFieldsMatcher.java
│ │ │ │ ├── EqualsMatcher.java
│ │ │ │ ├── ExactClassMatcher.java
│ │ │ │ ├── ExactSequenceMatcher.java
│ │ │ │ ├── FieldFilter.java
│ │ │ │ ├── IgnoreField.java
│ │ │ │ ├── ListMatcher.java
│ │ │ │ ├── ListWithAllOfMatcher.java
│ │ │ │ ├── ListWithAnyOfMatcher.java
│ │ │ │ ├── MapEntryMatcher.java
│ │ │ │ ├── MatchAllFieldFilter.java
│ │ │ │ ├── MatcherExecutionException.java
│ │ │ │ ├── Matchers.java
│ │ │ │ ├── NonStaticFieldsFilter.java
│ │ │ │ ├── NonTransientFieldsFilter.java
│ │ │ │ ├── NullOrVoidMatcher.java
│ │ │ │ ├── PayloadMatcher.java
│ │ │ │ ├── PayloadsMatcher.java
│ │ │ │ ├── PredicateMatcher.java
│ │ │ │ └── SequenceMatcher.java
│ │ │ ├── package-info.java
│ │ │ ├── saga
│ │ │ │ ├── CommandValidator.java
│ │ │ │ ├── ContinuedGivenState.java
│ │ │ │ ├── DescriptionUtils.java
│ │ │ │ ├── EventValidator.java
│ │ │ │ ├── FixtureConfiguration.java
│ │ │ │ ├── FixtureExecutionResultImpl.java
│ │ │ │ ├── FixtureExecutionResult.java
│ │ │ │ ├── GivenAggregateEventPublisher.java
│ │ │ │ ├── RecordingListenerInvocationErrorHandler.java
│ │ │ │ ├── RepositoryContentValidator.java
│ │ │ │ ├── SagaTestFixture.java
│ │ │ │ ├── WhenAggregateEventPublisher.java
│ │ │ │ └── WhenState.java
│ │ │ ├── server
│ │ │ │ ├── AxonServerContainer.java
│ │ │ │ ├── AxonServerContainerUtils.java
│ │ │ │ ├── AxonServerEEContainer.java
│ │ │ │ └── AxonServerSEContainer.java
│ │ │ └── utils
│ │ │ ├── AutowiredResourceInjector.java
│ │ │ ├── CallbackBehavior.java
│ │ │ ├── DefaultCallbackBehavior.java
│ │ │ ├── package-info.java
│ │ │ └── RecordingCommandBus.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ └── org.axonframework.messaging.annotation.ParameterResolverFactory
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── test
│ │ ├── aggregate
│ │ │ ├── AnnotatedAggregateInterface.java
│ │ │ ├── AnnotatedAggregate.java
│ │ │ ├── CreateAggregateCommand.java
│ │ │ ├── DeleteCommand.java
│ │ │ ├── FixtureRepositoryRegistrationTest.java
│ │ │ ├── FixtureTest_Annotated.java
│ │ │ ├── FixtureTest_CommandInterceptors.java
│ │ │ ├── FixtureTest_CreationPolicy.java
│ │ │ ├── FixtureTest_Deadlines.java
│ │ │ ├── FixtureTest_ExceptionHandling.java
│ │ │ ├── FixtureTest_Generic.java
│ │ │ ├── FixtureTest_Hierarchy.java
│ │ │ ├── FixtureTest_MarkDeleted.java
│ │ │ ├── FixtureTest_MatcherParams.java
│ │ │ ├── FixtureTest_Polymorphism.java
│ │ │ ├── FixtureTest_RegisteringMethodEnhancements.java
│ │ │ ├── FixtureTest_RegularParams.java
│ │ │ ├── FixtureTest_Resources.java
│ │ │ ├── FixtureTest_ScopeDescriptor.java
│ │ │ ├── FixtureTest_SpawningNewAggregate.java
│ │ │ ├── FixtureTest_StateStorage.java
│ │ │ ├── FixtureWhenPhaseAggregateInvocationTest.java
│ │ │ ├── HardToCreateResource.java
│ │ │ ├── IllegalStateChangeCommand.java
│ │ │ ├── MyAggregateDeletedEvent.java
│ │ │ ├── MyApplicationEvent.java
│ │ │ ├── MyCommandHandler.java
│ │ │ ├── MyEntity.java
│ │ │ ├── MyEvent.java
│ │ │ ├── MyOtherEvent.java
│ │ │ ├── ParameterResolvedEvent.java
│ │ │ ├── PublishEventCommand.java
│ │ │ ├── ResolveParameterCommand.java
│ │ │ ├── ResultValidatorImplTest.java
│ │ │ ├── StandardAggregate.java
│ │ │ ├── StrangeCommand.java
│ │ │ ├── StrangeCommandReceivedException.java
│ │ │ ├── StubAggregateLifecycleExtensionTest.java
│ │ │ ├── StubAggregateLifecycleRuleTest.java
│ │ │ ├── StubAggregateLifecycleTest.java
│ │ │ ├── TestCommand.java
│ │ │ └── TestEvent.java
│ │ ├── deadline
│ │ │ └── StubDeadlineManagerTest.java
│ │ ├── eventscheduler
│ │ │ └── StubEventSchedulerTest.java
│ │ ├── matchers
│ │ │ ├── DeepEqualsMatcherTest.java
│ │ │ ├── EqualFieldsMatcherTest.java
│ │ │ ├── ExactClassMatcherTest.java
│ │ │ ├── ExactSequenceOfEventsMatcherTest.java
│ │ │ ├── IgnoreFieldTest.java
│ │ │ ├── ListWithAllOfMatcherTest.java
│ │ │ ├── ListWithAnyOfMatcherTest.java
│ │ │ ├── MapEntryMatcherTest.java
│ │ │ ├── MatchAllFieldFilterTest.java
│ │ │ ├── NonStaticFieldsFilterTest.java
│ │ │ ├── NonTransientFieldsFilterTest.java
│ │ │ ├── NullOrVoidMatcherTest.java
│ │ │ ├── SequenceOfEventsMatcherTest.java
│ │ │ └── StubEvent.java
│ │ ├── saga
│ │ │ ├── AnnotatedSagaTest.java
│ │ │ ├── CommandValidatorTest.java
│ │ │ ├── EventValidatorTest.java
│ │ │ ├── FixtureExecutionResultImplTest.java
│ │ │ ├── FixtureMessageHandlerInterceptorTest.java
│ │ │ ├── FixtureTest_Deadlines.java
│ │ │ ├── FixtureTest_RegisteringMethodEnhancements.java
│ │ │ ├── FixtureTest_RegisteringSagaEnhancements.java
│ │ │ ├── FixtureTest_ScheduledEvents.java
│ │ │ ├── FixtureTest_ScopeDescriptor.java
│ │ │ ├── ForceTriggerSagaStartEvent.java
│ │ │ ├── NonTransientResource.java
│ │ │ ├── ParameterResolvedEvent.java
│ │ │ ├── RecordingListenerInvocationErrorHandlerTest.java
│ │ │ ├── ResetTriggerEvent.java
│ │ │ ├── ResolveParameterCommand.java
│ │ │ ├── SagaWasTriggeredEvent.java
│ │ │ ├── StubGateway.java
│ │ │ ├── StubSaga.java
│ │ │ ├── TimerTriggeredEvent.java
│ │ │ ├── TriggerExceptionWhileHandlingEvent.java
│ │ │ ├── TriggerExistingSagaEvent.java
│ │ │ ├── TriggerSagaEndEvent.java
│ │ │ └── TriggerSagaStartEvent.java
│ │ ├── server
│ │ │ ├── AxonServerContainerTest.java
│ │ │ ├── AxonServerEEContainerTest.java
│ │ │ └── AxonServerSEContainerTest.java
│ │ └── utils
│ │ └── RecordingCommandBusTest.java
│ └── resources
│ └── log4j2.properties
└── tracing-opentelemetry
├── pom.xml
└── src
├── main
│ └── java
│ └── org
│ └── axonframework
│ └── tracing
│ └── opentelemetry
│ ├── MetadataContextGetter.java
│ ├── MetadataContextSetter.java
│ ├── OpenTelemetrySpanFactory.java
│ └── OpenTelemetrySpan.java
└── test
└── java
└── org
└── axonframework
└── tracing
└── opentelemetry
├── MetadataContextGetterTest.java
├── MetadataContextSetterTest.java
├── OpenTelemetrySpanFactoryTest.java
└── OpenTelemetrySpanTest.java
674 directories, 2089 files
AxonFramework是一个用于构建进化式、事件驱动微服务系统的框架，基于领域驱动设计（DDD）、命令查询责任分离（CQRS）和事件溯源原则。该框架为您提供了必要的构建模块来遵循这些原则。构建模块的示例包括聚合设计句柄、聚合存储库、命令总线、saga设计句柄、事件存储、查询总线等。框架为所有这些组件提供了明智的默认设置。命令、事件和查询的消息支持是这些构建模块的核心。正是消息基础使得通过它们提供的位置透明度实现了对微服务的进化式方法。Axon还将协助分发应用程序以支持可伸缩性或容错性，例如使用Axon Server可以快速调整消息总线到分布式实现。Axon Server提供了分布式命令总线、事件总线、查询总线以及可伸缩的事件溯源实现。此外，Axon Framework组织还有一些扩展可以在这方面提供帮助。所有这些都有助于创建一个结构良好的应用程序，无需担心基础设施。因此，您的关注点可以从非功能性要求转移到业务功能。有关Axon的更多信息，请访问我们的网站。各种资源可以帮助您使用Axon Framework的旅程。一个很好的起点是AxonIQ开发人员门户网站，提供博客、视频和描述的链接资源。此外，以下是其他几个有用的资源：文档的快速入门页面为您提供了一个简化的框架入口点，其中包含快速入门项目。我们拥有自己的学院！介绍课程是免费的，之后是更深入的（付费）课程。准备好后，您可以快速轻松地启动您自己的基于Axon Framework的应用程序。参考指南解释了Axon Framework产品中维护的所有组件。如果指南无法帮助，我们的论坛提供了一个空间，供您在开发过程中提出问题。酒店演示展示了使用Axon Framework的一个充分的示例。代码示例存储库包含更深入的示例，您可以受益于这些示例。
【实例截图】
【核心代码】
文件清单
└── AxonFramework-0a5f1ed37aa3e8a83c867aa72f4d58c1395e2e40
├── assembly
│ └── axon-full.xml
├── axon-4-api-changes.md
├── axon_code_style.xml
├── axon-server-connector
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── axonserver
│ │ │ └── connector
│ │ │ ├── AxonServerConfiguration.java
│ │ │ ├── AxonServerConnectionManager.java
│ │ │ ├── AxonServerException.java
│ │ │ ├── command
│ │ │ │ ├── AxonServerCommandBus.java
│ │ │ │ ├── AxonServerCommandDispatchException.java
│ │ │ │ ├── AxonServerNonTransientRemoteCommandHandlingException.java
│ │ │ │ ├── AxonServerRegistration.java
│ │ │ │ ├── AxonServerRemoteCommandHandlingException.java
│ │ │ │ ├── CommandLoadFactorProvider.java
│ │ │ │ ├── CommandPriorityCalculator.java
│ │ │ │ ├── CommandSerializer.java
│ │ │ │ └── GrpcBackedCommandMessage.java
│ │ │ ├── ConnectionManager.java
│ │ │ ├── DefaultHandlers.java
│ │ │ ├── DefaultInstructionAckSource.java
│ │ │ ├── DispatchInterceptors.java
│ │ │ ├── ErrorCode.java
│ │ │ ├── event
│ │ │ │ ├── axon
│ │ │ │ │ ├── AxonServerEventScheduler.java
│ │ │ │ │ ├── AxonServerEventStoreFactory.java
│ │ │ │ │ ├── AxonServerEventStore.java
│ │ │ │ │ ├── EventBuffer.java
│ │ │ │ │ ├── EventProcessorInfoConfiguration.java
│ │ │ │ │ ├── GrpcBackedDomainEventData.java
│ │ │ │ │ ├── GrpcMetaDataAwareSerializer.java
│ │ │ │ │ ├── QueryResult.java
│ │ │ │ │ ├── QueryResultStreamAdapter.java
│ │ │ │ │ └── QueryResultStream.java
│ │ │ │ └── util
│ │ │ │ ├── EventCipher.java
│ │ │ │ ├── EventStoreClientException.java
│ │ │ │ └── GrpcExceptionParser.java
│ │ │ ├── Handlers.java
│ │ │ ├── heartbeat
│ │ │ │ ├── connection
│ │ │ │ │ └── checker
│ │ │ │ │ ├── ActiveGrpcChannelChecker.java
│ │ │ │ │ └── HeartbeatConnectionChecker.java
│ │ │ │ ├── ConnectionSanityChecker.java
│ │ │ │ ├── HeartbeatConfiguration.java
│ │ │ │ ├── HeartbeatMonitor.java
│ │ │ │ ├── HeartbeatSource.java
│ │ │ │ └── source
│ │ │ │ └── GrpcHeartbeatSource.java
│ │ │ ├── InstructionAckSource.java
│ │ │ ├── InstructionResultPublisher.java
│ │ │ ├── ManagedChannelCustomizer.java
│ │ │ ├── PriorityCallable.java
│ │ │ ├── PriorityRunnable.java
│ │ │ ├── PriorityTask.java
│ │ │ ├── processor
│ │ │ │ ├── EventProcessorControlService.java
│ │ │ │ └── StreamingEventProcessorInfoMessage.java
│ │ │ ├── Publisher.java
│ │ │ ├── query
│ │ │ │ ├── AxonServerNonTransientRemoteQueryHandlingException.java
│ │ │ │ ├── AxonServerQueryBus.java
│ │ │ │ ├── AxonServerQueryDispatchException.java
│ │ │ │ ├── AxonServerRemoteQueryHandlingException.java
│ │ │ │ ├── GrpcBackedQueryMessage.java
│ │ │ │ ├── GrpcBackedResponseMessage.java
│ │ │ │ ├── QueryPriorityCalculator.java
│ │ │ │ ├── QueryProcessingTask.java
│ │ │ │ ├── QuerySerializer.java
│ │ │ │ ├── StreamableFluxResponse.java
│ │ │ │ ├── StreamableInstanceResponse.java
│ │ │ │ ├── StreamableMultiInstanceResponse.java
│ │ │ │ ├── StreamableResponse.java
│ │ │ │ └── subscription
│ │ │ │ ├── AxonServerSubscriptionQueryResult.java
│ │ │ │ ├── DeserializedResult.java
│ │ │ │ ├── DisposableResult.java
│ │ │ │ ├── GrpcBackedQueryUpdateMessage.java
│ │ │ │ ├── GrpcBackedSubscriptionQueryMessage.java
│ │ │ │ └── SubscriptionMessageSerializer.java
│ │ │ ├── ServerConnectorConfigurerModule.java
│ │ │ ├── TargetContextResolver.java
│ │ │ └── util
│ │ │ ├── ContextAddingInterceptor.java
│ │ │ ├── ExceptionSerializer.java
│ │ │ ├── ExecutorServiceBuilder.java
│ │ │ ├── FlowControllingStreamObserver.java
│ │ │ ├── GrpcBufferingInterceptor.java
│ │ │ ├── GrpcMetaDataConverter.java
│ │ │ ├── GrpcMetaData.java
│ │ │ ├── GrpcMetadataSerializer.java
│ │ │ ├── GrpcObjectSerializer.java
│ │ │ ├── GrpcPayloadSerializer.java
│ │ │ ├── GrpcSerializedObject.java
│ │ │ ├── PriorityExecutorService.java
│ │ │ ├── PriorityTaskSchedulers.java
│ │ │ ├── ProcessingInstructionHelper.java
│ │ │ ├── ResubscribableStreamObserver.java
│ │ │ ├── Scheduler.java
│ │ │ ├── TokenAddingInterceptor.java
│ │ │ └── UpstreamAwareStreamObserver.java
│ │ └── resources
│ │ ├── axonserver_download.txt
│ │ └── META-INF
│ │ └── services
│ │ └── org.axonframework.config.ConfigurerModule
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── axonserver
│ │ └── connector
│ │ ├── AxonServerConfigurationTest.java
│ │ ├── AxonServerConnectionManagerTest.java
│ │ ├── command
│ │ │ ├── AxonServerCommandBusTest.java
│ │ │ ├── CommandSerializerTest.java
│ │ │ ├── DummyMessagePlatformServer.java
│ │ │ └── GrpcBackedCommandMessageTest.java
│ │ ├── DispatchInterceptorsTest.java
│ │ ├── event
│ │ │ ├── axon
│ │ │ │ ├── AxonServerEventSchedulerTest.java
│ │ │ │ ├── AxonServerEventStoreFactoryTest.java
│ │ │ │ ├── AxonServerEventStoreTest.java
│ │ │ │ ├── ErrorCodeTest.java
│ │ │ │ ├── EventBufferTest.java
│ │ │ │ ├── EventProcessorInfoConfigurationTest.java
│ │ │ │ └── QueryResultStreamAdapterTest.java
│ │ │ ├── EventStoreImpl.java
│ │ │ ├── StubServer.java
│ │ │ └── util
│ │ │ └── EventCipherTests.java
│ │ ├── heartbeat
│ │ │ ├── HeartbeatConnectionCheckerTest.java
│ │ │ └── HeartbeatMonitorTest.java
│ │ ├── processor
│ │ │ └── EventProcessorControlServiceTest.java
│ │ ├── query
│ │ │ ├── AxonServerQueryBusTest.java
│ │ │ ├── GrpcBackedQueryMessageTest.java
│ │ │ ├── GrpcBackedResponseMessageTest.java
│ │ │ ├── QueryProcessingTaskIntegrationTest.java
│ │ │ ├── QuerySerializerTest.java
│ │ │ ├── StreamingQueryEndToEndTest.java
│ │ │ └── subscription
│ │ │ ├── AxonServerSubscriptionQueryResultTest.java
│ │ │ ├── FakeStreamObserver.java
│ │ │ ├── GrpcBackedQueryUpdateMessageTest.java
│ │ │ ├── GrpcBackedSubscriptionQueryMessageTest.java
│ │ │ └── SubscriptionMessageSerializerTest.java
│ │ ├── ServerConnectorConfigurerModuleTest.java
│ │ ├── ServerConnectorRunner.java
│ │ ├── TestStreamObserver.java
│ │ ├── TestTargetContextResolver.java
│ │ ├── util
│ │ │ ├── ExceptionSerializerTest.java
│ │ │ ├── GrpcBufferingInterceptorTest.java
│ │ │ ├── GrpcMetaDataConverterTest.java
│ │ │ ├── ProcessingInstructionHelperTest.java
│ │ │ └── TcpUtil.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── ContextInterceptor.java
│ │ ├── FakeClock.java
│ │ ├── FakeScheduler.java
│ │ ├── FutureUtils.java
│ │ ├── PlatformService.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── log4j2.properties
│ └── logback.xml
├── config
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── config
│ │ ├── AggregateConfiguration.java
│ │ ├── AggregateConfigurer.java
│ │ ├── AxonIQConsoleModule.java
│ │ ├── Component.java
│ │ ├── Configuration.java
│ │ ├── ConfigurationParameterResolverFactory.java
│ │ ├── ConfigurationResourceInjector.java
│ │ ├── ConfigurationScopeAwareProvider.java
│ │ ├── Configurer.java
│ │ ├── ConfigurerModule.java
│ │ ├── DefaultConfigurer.java
│ │ ├── EventProcessingConfiguration.java
│ │ ├── EventProcessingConfigurer.java
│ │ ├── EventProcessingModule.java
│ │ ├── LifecycleHandlerInspector.java
│ │ ├── LifecycleHandler.java
│ │ ├── LifecycleOperations.java
│ │ ├── MessageHandlerRegistrar.java
│ │ ├── MessageMonitorFactoryBuilder.java
│ │ ├── MessageMonitorFactory.java
│ │ ├── ModuleConfiguration.java
│ │ ├── ProcessingGroup.java
│ │ ├── SagaConfiguration.java
│ │ ├── SagaConfigurer.java
│ │ └── TagsConfiguration.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── config
│ │ ├── AggregateConfigurerTest.java
│ │ ├── ConfigAssertions.java
│ │ ├── ConfigurationParameterResolverFactoryTest.java
│ │ ├── ConfigurationResourceInjectorTest.java
│ │ ├── ConfigurationScopeAwareProviderTest.java
│ │ ├── DefaultConfigurerHandlerRegistrationTest.java
│ │ ├── DefaultConfigurerLifecycleOperationsTest.java
│ │ ├── DefaultConfigurerTest.java
│ │ ├── EventProcessingModuleTest.java
│ │ ├── LifecycleHandlerInspectorTest.java
│ │ ├── MessageCollectingMonitor.java
│ │ ├── MessageHandlerRegistrarTest.java
│ │ ├── MessageMonitorFactoryBuilderTest.java
│ │ ├── SagaConfigurerTest.java
│ │ ├── SingleEventProcessorAssigningToMultipleInvokersTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── log4j2.properties
│ └── META-INF
│ └── persistence.xml
├── CONTRIBUTING.md
├── copyright-template.xml
├── coverage-report
│ └── pom.xml
├── disruptor
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── disruptor
│ │ └── commandhandling
│ │ ├── AggregateBlacklistedException.java
│ │ ├── AggregateStateCorruptedException.java
│ │ ├── BlacklistDetectingCallback.java
│ │ ├── CommandHandlerInvoker.java
│ │ ├── CommandHandlingEntry.java
│ │ ├── DisruptorCommandBus.java
│ │ ├── DisruptorUnitOfWork.java
│ │ ├── EventPublisher.java
│ │ └── FirstLevelCache.java
│ └── test
│ └── java
│ └── org
│ └── axonframework
│ └── disruptor
│ └── commandhandling
│ ├── CommandHandlerInvokerTest.java
│ ├── CommandHandlingBenchmark.java
│ ├── DisruptorCommandBusBenchmark.java
│ ├── DisruptorCommandBusBuilderTest.java
│ ├── DisruptorCommandBusMultiThreadedTest.java
│ ├── DisruptorCommandBusTest.java
│ ├── DisruptorRepositoryTest.java
│ ├── FirstLevelCacheTest.java
│ └── utils
│ ├── AssertUtils.java
│ ├── MockException.java
│ └── SomethingDoneEvent.java
├── docs
│ ├── af-fundamentals-tutorial
│ │ ├── antora.yml
│ │ └── modules
│ │ ├── deadlines
│ │ │ ├── pages
│ │ │ │ ├── advanced.adoc
│ │ │ │ ├── deciding.adoc
│ │ │ │ ├── implementing.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ └── testing.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── dlq
│ │ │ ├── examples
│ │ │ │ └── source_code
│ │ │ ├── pages
│ │ │ │ ├── advanced.adoc
│ │ │ │ ├── implementing.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ └── retrying.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── nav.adoc
│ │ └── ROOT
│ │ ├── autoconfigure
│ │ │ └── autoconfigure
│ │ ├── config
│ │ │ └── config
│ │ ├── pages
│ │ │ └── index.adoc
│ │ └── partials
│ │ └── nav.adoc
│ ├── _playbook
│ │ ├── package.json
│ │ ├── package-lock.json
│ │ └── playbook.yaml
│ ├── reference
│ │ ├── antora.yml
│ │ └── modules
│ │ ├── axon-server-connector
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── configuration
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── disruptor
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── eventsourcing
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── legacy
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── messaging
│ │ │ ├── attachments
│ │ │ │ ├── axonframework_overview.gv
│ │ │ │ ├── base_classes.mermaid
│ │ │ │ ├── base_classes.puml
│ │ │ │ ├── command_messaging_classes.puml
│ │ │ │ ├── event_messaging_classes.puml
│ │ │ │ ├── generic_messaging_classes.puml
│ │ │ │ └── query_messaging_classes.puml
│ │ │ ├── pages
│ │ │ │ ├── advanced_messaging
│ │ │ │ │ ├── correlation.adoc
│ │ │ │ │ └── index.adoc
│ │ │ │ ├── deadlines
│ │ │ │ │ ├── index.adoc
│ │ │ │ │ └── manager_simple.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ ├── messages
│ │ │ │ │ ├── command_messages.adoc
│ │ │ │ │ ├── event_messages.adoc
│ │ │ │ │ ├── messages.adoc
│ │ │ │ │ └── query_messages.adoc
│ │ │ │ └── routing
│ │ │ │ ├── command_routing.adoc
│ │ │ │ ├── event_routing.adoc
│ │ │ │ ├── query_routing.adoc
│ │ │ │ └── routing.adoc
│ │ │ └── partials
│ │ │ ├── command_message.adoc
│ │ │ └── nav.adoc
│ │ ├── metrics
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── micrometer
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── modeling
│ │ │ ├── pages
│ │ │ │ ├── aggregate.adoc
│ │ │ │ ├── index.adoc
│ │ │ │ └── saga.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── nav.adoc
│ │ ├── ROOT
│ │ │ ├── attachments
│ │ │ │ └── axonframework_overview.gv
│ │ │ ├── pages
│ │ │ │ ├── index.adoc
│ │ │ │ ├── overview.adoc
│ │ │ │ └── structure.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── spring
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── springboot-starter
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ ├── test
│ │ │ ├── pages
│ │ │ │ └── index.adoc
│ │ │ └── partials
│ │ │ └── nav.adoc
│ │ └── tracing-open-telemetry
│ │ ├── pages
│ │ │ └── index.adoc
│ │ └── partials
│ │ └── nav.adoc
│ └── _source_code_links
│ ├── axon-server-connector
│ ├── config
│ ├── eventsourcing
│ ├── messaging
│ ├── modelling
│ ├── spring
│ └── spring-boot-autoconfigure
├── eventsourcing
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── eventsourcing
│ │ │ ├── AbstractAggregateFactory.java
│ │ │ ├── AbstractSnapshotter.java
│ │ │ ├── AbstractSnapshotTrigger.java
│ │ │ ├── AggregateCacheEntry.java
│ │ │ ├── AggregateDeletedException.java
│ │ │ ├── AggregateFactory.java
│ │ │ ├── AggregateLoadTimeSnapshotTriggerDefinition.java
│ │ │ ├── AggregateSnapshotter.java
│ │ │ ├── CachingEventSourcingRepository.java
│ │ │ ├── conflictresolution
│ │ │ │ ├── ConflictDescription.java
│ │ │ │ ├── ConflictExceptionSupplier.java
│ │ │ │ ├── ConflictResolution.java
│ │ │ │ ├── ConflictResolver.java
│ │ │ │ ├── Conflicts.java
│ │ │ │ ├── ContextAwareConflictExceptionSupplier.java
│ │ │ │ ├── DefaultConflictDescription.java
│ │ │ │ ├── DefaultConflictResolver.java
│ │ │ │ └── NoConflictResolver.java
│ │ │ ├── DefaultSnapshotterSpanFactory.java
│ │ │ ├── EventCountSnapshotTriggerDefinition.java
│ │ │ ├── EventSourcedAggregate.java
│ │ │ ├── EventSourcingHandler.java
│ │ │ ├── EventSourcingRepository.java
│ │ │ ├── eventstore
│ │ │ │ ├── AbstractEventStorageEngine.java
│ │ │ │ ├── AbstractEventStore.java
│ │ │ │ ├── AbstractSnapshotEventEntry.java
│ │ │ │ ├── BatchingEventStorageEngine.java
│ │ │ │ ├── ConcatenatingDomainEventStream.java
│ │ │ │ ├── DomainEventStream.java
│ │ │ │ ├── EmbeddedEventStore.java
│ │ │ │ ├── EqualRevisionPredicate.java
│ │ │ │ ├── EventStorageEngine.java
│ │ │ │ ├── EventStoreException.java
│ │ │ │ ├── EventStore.java
│ │ │ │ ├── FilteringDomainEventStream.java
│ │ │ │ ├── inmemory
│ │ │ │ │ └── InMemoryEventStorageEngine.java
│ │ │ │ ├── IteratorBackedDomainEventStream.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── AbstractEventTableFactory.java
│ │ │ │ │ ├── EventSchema.java
│ │ │ │ │ ├── EventTableFactory.java
│ │ │ │ │ ├── HsqlEventTableFactory.java
│ │ │ │ │ ├── JdbcEventStorageEngine.java
│ │ │ │ │ ├── JdbcSQLErrorCodesResolver.java
│ │ │ │ │ ├── MySqlEventTableFactory.java
│ │ │ │ │ ├── Oracle11EventTableFactory.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ ├── PostgresEventTableFactory.java
│ │ │ │ │ └── statements
│ │ │ │ │ ├── AppendEventsStatementBuilder.java
│ │ │ │ │ ├── AppendSnapshotStatementBuilder.java
│ │ │ │ │ ├── CleanGapsStatementBuilder.java
│ │ │ │ │ ├── CreateHeadTokenStatementBuilder.java
│ │ │ │ │ ├── CreateTailTokenStatementBuilder.java
│ │ │ │ │ ├── CreateTokenAtStatementBuilder.java
│ │ │ │ │ ├── DeleteSnapshotsStatementBuilder.java
│ │ │ │ │ ├── FetchTrackedEventsStatementBuilder.java
│ │ │ │ │ ├── JdbcEventStorageEngineStatements.java
│ │ │ │ │ ├── LastSequenceNumberForStatementBuilder.java
│ │ │ │ │ ├── ReadEventDataForAggregateStatementBuilder.java
│ │ │ │ │ ├── ReadEventDataWithGapsStatementBuilder.java
│ │ │ │ │ ├── ReadEventDataWithoutGapsStatementBuilder.java
│ │ │ │ │ ├── ReadSnapshotDataStatementBuilder.java
│ │ │ │ │ └── TimestampWriter.java
│ │ │ │ ├── jpa
│ │ │ │ │ ├── DomainEventEntry.java
│ │ │ │ │ ├── JpaEventStorageEngine.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ ├── SnapshotEventEntry.java
│ │ │ │ │ ├── SQLErrorCodesResolver.java
│ │ │ │ │ └── SQLStateResolver.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ ├── EmbeddedEventStore.java
│ │ │ │ │ ├── JpaEventStorageEngine.java
│ │ │ │ │ └── SQLErrorCodesResolver.java
│ │ │ │ ├── package-info.java
│ │ │ │ └── SequenceEventStorageEngine.java
│ │ │ ├── EventStreamUtils.java
│ │ │ ├── FilteringEventStorageEngine.java
│ │ │ ├── GenericAggregateFactory.java
│ │ │ ├── IncompatibleAggregateException.java
│ │ │ ├── MultiStreamableMessageSource.java
│ │ │ ├── NoSnapshotTriggerDefinition.java
│ │ │ ├── package-info.java
│ │ │ ├── Snapshotter.java
│ │ │ ├── SnapshotterSpanFactory.java
│ │ │ ├── snapshotting
│ │ │ │ ├── RevisionSnapshotFilter.java
│ │ │ │ └── SnapshotFilter.java
│ │ │ ├── SnapshotTriggerDefinition.java
│ │ │ └── SnapshotTrigger.java
│ │ └── resources
│ │ ├── META-INF
│ │ │ └── services
│ │ │ └── org.axonframework.messaging.annotation.ParameterResolverFactory
│ │ └── org
│ │ └── axonframework
│ │ └── eventsourcing
│ │ └── eventstore
│ │ ├── jpa
│ │ │ └── SQLErrorCode.properties
│ │ └── legacyjpa
│ │ └── SQLErrorCode.properties
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── eventsourcing
│ │ ├── AbstractAggregateFactoryTest.java
│ │ ├── AbstractSnapshotterTest.java
│ │ ├── AggregateLoadSnapshotTriggerDefinitionTest.java
│ │ ├── AggregateSnapshotterTest.java
│ │ ├── CachingEventSourcingRepositoryTest.java
│ │ ├── CachingRepositoryWithNestedUnitOfWorkTest.java
│ │ ├── conflictresolution
│ │ │ ├── ConflictResolutionTest.java
│ │ │ ├── ConflictsTest.java
│ │ │ └── DefaultConflictResolverTest.java
│ │ ├── DefaultSnapshotterSpanFactoryTest.java
│ │ ├── DomainEventStreamTest.java
│ │ ├── EventCountSnapshotTriggerDefinitionTest.java
│ │ ├── EventSourcingRepositoryIntegrationTest.java
│ │ ├── EventSourcingRepositoryTest.java
│ │ ├── eventstore
│ │ │ ├── AbstractEventStorageEngineTest.java
│ │ │ ├── BatchingEventStorageEngineTest.java
│ │ │ ├── ConcatenatingDomainEventStreamTest.java
│ │ │ ├── EmbeddedEventStoreTest.java
│ │ │ ├── EqualRevisionPredicateTest.java
│ │ │ ├── EventStorageEngineTest.java
│ │ │ ├── FilteringDomainEventStreamTest.java
│ │ │ ├── inmemory
│ │ │ │ ├── InMemoryEmbeddedEventStoreTest.java
│ │ │ │ └── InMemoryEventStorageEngineTest.java
│ │ │ ├── jdbc
│ │ │ │ ├── JdbcEmbeddedEventStoreTest.java
│ │ │ │ ├── JdbcEventStorageEngineTest.java
│ │ │ │ └── MysqlJdbcEventStorageEngineTest.java
│ │ │ ├── jpa
│ │ │ │ ├── DomainEventEntryTest.java
│ │ │ │ ├── SQLErrorCodesResolverTest.java
│ │ │ │ └── SQLStateResolverTest.java
│ │ │ ├── legacyjpa
│ │ │ │ ├── JpaEventStorageEngineTest.java
│ │ │ │ └── SQLErrorCodesResolverTest.java
│ │ │ └── SequenceEventStorageEngineTest.java
│ │ ├── EventStreamUtilsTest.java
│ │ ├── FilteringEventStorageEngineTest.java
│ │ ├── GenericAggregateFactoryTest.java
│ │ ├── NoSnapshotTriggerDefinitionTest.java
│ │ ├── snapshotting
│ │ │ ├── RevisionSnapshotFilterTest.java
│ │ │ └── SnapshotFilterTest.java
│ │ ├── SpawningNewAggregateTest.java
│ │ └── utils
│ │ ├── EventStoreTestUtils.java
│ │ ├── MockException.java
│ │ ├── RecordingAppender.java
│ │ ├── StubAggregate.java
│ │ ├── StubDomainEvent.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── ehcache.xml
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ ├── META-INF
│ │ └── persistence.xml
│ └── mysql.benchmark.properties
├── hibernate-6-integrationtests
│ ├── pom.xml
│ └── src
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── common
│ │ │ └── jpa
│ │ │ ├── PagingJpaQueryIterableTest.java
│ │ │ └── TestJpaEntry.java
│ │ ├── eventhandling
│ │ │ ├── deadletter
│ │ │ │ └── jpa
│ │ │ │ └── JpaSequencedDeadLetterQueueTest.java
│ │ │ └── tokenstore
│ │ │ └── jpa
│ │ │ └── JpaTokenStoreTest.java
│ │ ├── eventsourcing
│ │ │ └── eventstore
│ │ │ └── jpa
│ │ │ ├── CustomDomainEventEntry.java
│ │ │ ├── CustomSnapshotEventEntry.java
│ │ │ └── JpaEventStorageEngineTest.java
│ │ ├── messaging
│ │ │ └── interceptors
│ │ │ └── BeanValidationInterceptorTest.java
│ │ └── modelling
│ │ └── saga
│ │ └── repository
│ │ └── jpa
│ │ └── JpaSagaStoreTest.java
│ └── resources
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ └── META-INF
│ └── persistence.xml
├── integrationtests
│ ├── pom.xml
│ └── src
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── integrationtests
│ │ ├── axonserverconnector
│ │ │ └── MessagePriorityIntegrationTest.java
│ │ ├── cache
│ │ │ ├── CachedSaga.java
│ │ │ ├── CachingIntegrationTestSuite.java
│ │ │ ├── EhCache3IntegrationTest.java
│ │ │ ├── EhCacheIntegrationTest.java
│ │ │ ├── JCacheIntegrationTest.java
│ │ │ ├── TestAggregateRoot.java
│ │ │ └── WeakReferenceCacheIntegrationTest.java
│ │ ├── commandhandling
│ │ │ ├── AbstractAggregateMemberTest.java
│ │ │ ├── AggregateCreationFromCommandsTest.java
│ │ │ ├── CommandRetryAndDispatchInterceptorIntegrationTest.java
│ │ │ ├── CreateStubAggregateCommand.java
│ │ │ ├── EventPublicationOrderTest.java
│ │ │ ├── LoopingChangeDoneEvent.java
│ │ │ ├── LoopingCommand.java
│ │ │ ├── MyEvent.java
│ │ │ ├── ProblematicCommand.java
│ │ │ ├── StubAggregateChangedEvent.java
│ │ │ ├── StubAggregateCommandHandler.java
│ │ │ ├── StubAggregateCreatedEvent.java
│ │ │ ├── StubAggregateForCreation.java
│ │ │ ├── StubAggregate.java
│ │ │ ├── StubDomainEvent.java
│ │ │ ├── UpdateStubAggregateCommand.java
│ │ │ └── UpdateStubAggregateWithExtraEventCommand.java
│ │ ├── deadline
│ │ │ ├── dbscheduler
│ │ │ │ ├── BinaryDbSchedulerDeadlineManagerTest.java
│ │ │ │ └── HumanReadableDbSchedulerDeadlineManagerTest.java
│ │ │ ├── jobrunr
│ │ │ │ ├── JobrunrDeadlineManagerTest.java
│ │ │ │ └── SimpleActivator.java
│ │ │ ├── quartz
│ │ │ │ └── QuartzDeadlineManagerTest.java
│ │ │ └── SimpleDeadlineManagerTest.java
│ │ ├── eventhandling
│ │ │ ├── LoopingEventHandler.java
│ │ │ ├── MultiStreamableMessageSourceTest.java
│ │ │ ├── RegisteringEventHandler.java
│ │ │ ├── SubscribingEventProcessorTest.java
│ │ │ ├── TrackingEventProcessorTest.java
│ │ │ └── TrackingEventProcessorTest_MultiThreaded.java
│ │ ├── eventsourcing
│ │ │ ├── conflictresolution
│ │ │ │ └── ConflictResolutionIntegrationTest.java
│ │ │ ├── eventstore
│ │ │ │ ├── benchmark
│ │ │ │ │ ├── AbstractEventStoreBenchmark.java
│ │ │ │ │ ├── inmemory
│ │ │ │ │ │ └── InMemoryEventStoreBenchMark.java
│ │ │ │ │ ├── jdbc
│ │ │ │ │ │ └── JdbcEventStoreBenchmark.java
│ │ │ │ │ └── jpa
│ │ │ │ │ └── JpaEventStoreBenchMark.java
│ │ │ │ ├── jdbc
│ │ │ │ │ └── Oracle11EventTableFactoryTest.java
│ │ │ │ └── jpa
│ │ │ │ ├── JpaEmbeddedCborEventStoreTest.java
│ │ │ │ └── JpaEmbeddedEventStoreTest.java
│ │ │ └── NestedUnitOfWorkTest.java
│ │ ├── loopbacktest
│ │ │ ├── MessageCreatedEvent.java
│ │ │ ├── Message.java
│ │ │ ├── MessagingCommandHandler.java
│ │ │ ├── NestedUowRollbackTest.java
│ │ │ ├── StubDomainEvent.java
│ │ │ └── synchronous
│ │ │ ├── LoopBackWithInterwovenCommandsAndEventsTest.java
│ │ │ └── SynchronousLoopbackTest.java
│ │ ├── modelling
│ │ │ ├── command
│ │ │ │ ├── CommandHandlerInterceptorTest.java
│ │ │ │ ├── CommandHandlingTest.java
│ │ │ │ ├── ComplexAggregateStructureTest.java
│ │ │ │ └── JpaAggregate.java
│ │ │ └── saga
│ │ │ └── repository
│ │ │ └── jdbc
│ │ │ └── Oracle11SagaSqlSchemaTest.java
│ │ ├── polymorphic
│ │ │ ├── AbstractCommandHandlerCommand.java
│ │ │ ├── AbstractPolymorphicAggregateAnnotationCommandHandlerTestSuite.java
│ │ │ ├── Child1Aggregate.java
│ │ │ ├── Child1OnlyCommand.java
│ │ │ ├── Child2Aggregate.java
│ │ │ ├── ChildEvent.java
│ │ │ ├── CommonCommand.java
│ │ │ ├── CreateChild1Command.java
│ │ │ ├── CreateChild2Command.java
│ │ │ ├── CreateChildFactoryCommand.java
│ │ │ ├── CreatedEvent.java
│ │ │ ├── CreateSimpleAggregateCommand.java
│ │ │ ├── FireChildEventCommand.java
│ │ │ ├── FireParentEventCommand.java
│ │ │ ├── InterceptedByChildCommand.java
│ │ │ ├── InterceptedByParentCommand.java
│ │ │ ├── ParentAggregate.java
│ │ │ ├── ParentEvent.java
│ │ │ ├── PolymorphicESAggregateAnnotationCommandHandlerTest.java
│ │ │ ├── PolymorphicJpaAggregateAnnotationCommandHandlerTest.java
│ │ │ ├── SimpleAggregateCreatedEvent.java
│ │ │ └── SimpleAggregate.java
│ │ ├── queryhandling
│ │ │ ├── AbstractSubscriptionQueryTestSuite.java
│ │ │ ├── ProjectorTest.java
│ │ │ └── SimpleQueryBusSubscriptionQueryTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── EventTestUtils.java
│ │ ├── MockException.java
│ │ ├── StubAggregate.java
│ │ ├── StubDomainEvent.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── ehcache.xml
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ ├── log4j2_silenced.properties
│ ├── META-INF
│ │ ├── persistence.xml
│ │ └── spring
│ │ ├── benchmark-jdbc-context.xml
│ │ ├── benchmark-jpa-context.xml
│ │ ├── benchmark-mongo-context.xml
│ │ └── insertion-read-order-test-context.xml
│ ├── mysql.benchmark.properties
│ └── mysql.database.properties
├── legacy
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ ├── commandhandling
│ │ │ └── model
│ │ │ └── AggregateScopeDescriptor.java
│ │ ├── domain
│ │ │ ├── GenericEventMessage.java
│ │ │ ├── GenericMessage.java
│ │ │ └── MetaData.java
│ │ ├── eventhandling
│ │ │ ├── saga
│ │ │ │ └── SagaScopeDescriptor.java
│ │ │ └── scheduling
│ │ │ └── quartz
│ │ │ └── LegacyAwareJobDataBinder.java
│ │ ├── eventsourcing
│ │ │ └── eventstore
│ │ │ ├── GapAwareTrackingToken.java
│ │ │ └── GlobalSequenceTrackingToken.java
│ │ └── mongo
│ │ └── eventsourcing
│ │ └── eventstore
│ │ └── MongoTrackingToken.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── commandhandling
│ │ │ └── model
│ │ │ └── AggregateScopeDescriptorTest.java
│ │ ├── eventhandling
│ │ │ ├── saga
│ │ │ │ └── SagaScopeDescriptorTest.java
│ │ │ └── scheduling
│ │ │ └── quartz
│ │ │ └── LegacyAwareJobDataBinderTest.java
│ │ ├── eventsourcing
│ │ │ └── eventstore
│ │ │ ├── GapAwareTrackingTokenTest.java
│ │ │ └── GlobalSequenceTrackingTokenTest.java
│ │ └── utils
│ │ └── TestSerializer.java
│ └── resources
│ ├── log4j.properties
│ └── serialized.object
├── LICENSE.txt
├── messaging
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ ├── commandhandling
│ │ │ │ ├── AnnotationCommandHandlerAdapter.java
│ │ │ │ ├── AsynchronousCommandBus.java
│ │ │ │ ├── callbacks
│ │ │ │ │ ├── FailureLoggingCallback.java
│ │ │ │ │ ├── FutureCallback.java
│ │ │ │ │ ├── LoggingCallback.java
│ │ │ │ │ └── NoOpCallback.java
│ │ │ │ ├── CommandBus.java
│ │ │ │ ├── CommandBusSpanFactory.java
│ │ │ │ ├── CommandCallback.java
│ │ │ │ ├── CommandExecutionException.java
│ │ │ │ ├── CommandHandler.java
│ │ │ │ ├── CommandMessageHandler.java
│ │ │ │ ├── CommandMessageHandlingMember.java
│ │ │ │ ├── CommandMessage.java
│ │ │ │ ├── CommandResultMessage.java
│ │ │ │ ├── CurrentUnitOfWorkParameterResolverFactory.java
│ │ │ │ ├── DefaultCommandBusSpanFactory.java
│ │ │ │ ├── distributed
│ │ │ │ │ ├── AbstractRoutingStrategy.java
│ │ │ │ │ ├── AnnotationRoutingStrategy.java
│ │ │ │ │ ├── CommandBusConnectorCommunicationException.java
│ │ │ │ │ ├── CommandBusConnector.java
│ │ │ │ │ ├── CommandCallbackRepository.java
│ │ │ │ │ ├── CommandCallbackWrapper.java
│ │ │ │ │ ├── CommandDispatchException.java
│ │ │ │ │ ├── commandfilter
│ │ │ │ │ │ ├── AcceptAll.java
│ │ │ │ │ │ ├── AndCommandMessageFilter.java
│ │ │ │ │ │ ├── CommandNameFilter.java
│ │ │ │ │ │ ├── DenyAll.java
│ │ │ │ │ │ ├── DenyCommandNameFilter.java
│ │ │ │ │ │ ├── NegateCommandMessageFilter.java
│ │ │ │ │ │ └── OrCommandMessageFilter.java
│ │ │ │ │ ├── CommandMessageFilter.java
│ │ │ │ │ ├── CommandRouter.java
│ │ │ │ │ ├── ConsistentHashChangeListener.java
│ │ │ │ │ ├── ConsistentHash.java
│ │ │ │ │ ├── DispatchMessage.java
│ │ │ │ │ ├── DistributedCommandBus.java
│ │ │ │ │ ├── Member.java
│ │ │ │ │ ├── MetaDataRoutingStrategy.java
│ │ │ │ │ ├── ReplyMessage.java
│ │ │ │ │ ├── RoutingStrategy.java
│ │ │ │ │ ├── ServiceRegistryException.java
│ │ │ │ │ ├── SimpleMember.java
│ │ │ │ │ └── UnresolvedRoutingKeyPolicy.java
│ │ │ │ ├── DuplicateCommandHandlerResolution.java
│ │ │ │ ├── DuplicateCommandHandlerResolver.java
│ │ │ │ ├── DuplicateCommandHandlerSubscriptionException.java
│ │ │ │ ├── FailingDuplicateCommandHandlerResolver.java
│ │ │ │ ├── gateway
│ │ │ │ │ ├── AbstractCommandGateway.java
│ │ │ │ │ ├── AbstractRetryScheduler.java
│ │ │ │ │ ├── AxonNonTransientExceptionClassesPredicate.java
│ │ │ │ │ ├── CommandGatewayFactory.java
│ │ │ │ │ ├── CommandGateway.java
│ │ │ │ │ ├── DefaultCommandGateway.java
│ │ │ │ │ ├── ExponentialBackOffIntervalRetryScheduler.java
│ │ │ │ │ ├── IntervalRetryScheduler.java
│ │ │ │ │ ├── NonTransientExceptionClassesPredicate.java
│ │ │ │ │ ├── RetryingCallback.java
│ │ │ │ │ ├── RetryScheduler.java
│ │ │ │ │ └── Timeout.java
│ │ │ │ ├── GenericCommandMessage.java
│ │ │ │ ├── GenericCommandResultMessage.java
│ │ │ │ ├── LoggingDuplicateCommandHandlerResolver.java
│ │ │ │ ├── MethodCommandHandlerDefinition.java
│ │ │ │ ├── MonitorAwareCallback.java
│ │ │ │ ├── NoHandlerForCommandException.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── RoutingKey.java
│ │ │ │ ├── SimpleCommandBus.java
│ │ │ │ └── WrappedCommandCallback.java
│ │ │ ├── common
│ │ │ │ ├── annotation
│ │ │ │ │ ├── AnnotationUtils.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ └── PriorityAnnotationComparator.java
│ │ │ │ ├── Assert.java
│ │ │ │ ├── AxonConfigurationException.java
│ │ │ │ ├── AxonException.java
│ │ │ │ ├── AxonNonTransientException.java
│ │ │ │ ├── AxonThreadFactory.java
│ │ │ │ ├── AxonTransientException.java
│ │ │ │ ├── BuilderUtils.java
│ │ │ │ ├── caching
│ │ │ │ │ ├── AbstractCacheAdapter.java
│ │ │ │ │ ├── Cache.java
│ │ │ │ │ ├── EhCache3Adapter.java
│ │ │ │ │ ├── EhCacheAdapter.java
│ │ │ │ │ ├── JCacheAdapter.java
│ │ │ │ │ ├── NoCache.java
│ │ │ │ │ ├── package-info.java
│ │ │ │ │ └── WeakReferenceCache.java
│ │ │ │ ├── CollectionUtils.java
│ │ │ │ ├── DateTimeUtils.java
│ │ │ │ ├── DefaultIdentifierFactory.java
│ │ │ │ ├── digest
│ │ │ │ │ └── Digester.java
│ │ │ │ ├── DirectExecutor.java
│ │ │ │ ├── ExceptionUtils.java
│ │ │ │ ├── IdentifierFactory.java
│ │ │ │ ├── IdentifierValidator.java
│ │ │ │ ├── io
│ │ │ │ │ └── IOUtils.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── ConnectionProvider.java
│ │ │ │ │ ├── ConnectionWrapperFactory.java
│ │ │ │ │ ├── DataSourceConnectionProvider.java
│ │ │ │ │ ├── JdbcException.java
│ │ │ │ │ ├── JdbcUtils.java
│ │ │ │ │ ├── Oracle11Utils.java
│ │ │ │ │ ├── PagingJdbcIterable.java
│ │ │ │ │ ├── PersistenceExceptionResolver.java
│ │ │ │ │ └── UnitOfWorkAwareConnectionProviderWrapper.java
│ │ │ │ ├── jpa
│ │ │ │ │ ├── EntityManagerProvider.java
│ │ │ │ │ ├── PagingJpaQueryIterable.java
│ │ │ │ │ └── SimpleEntityManagerProvider.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ ├── EntityManagerProvider.java
│ │ │ │ │ ├── PagingJpaQueryIterable.java
│ │ │ │ │ └── SimpleEntityManagerProvider.java
│ │ │ │ ├── ListUtils.java
│ │ │ │ ├── lock
│ │ │ │ │ ├── DeadlockException.java
│ │ │ │ │ ├── LockAcquisitionFailedException.java
│ │ │ │ │ ├── LockFactory.java
│ │ │ │ │ ├── Lock.java
│ │ │ │ │ ├── NoOpLock.java
│ │ │ │ │ ├── NullLockFactory.java
│ │ │ │ │ └── PessimisticLockFactory.java
│ │ │ │ ├── MemberAccessibilityCallback.java
│ │ │ │ ├── ObjectUtils.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── Priority.java
│ │ │ │ ├── ProcessRetriesExhaustedException.java
│ │ │ │ ├── ProcessUtils.java
│ │ │ │ ├── property
│ │ │ │ │ ├── AbstractMethodPropertyAccessStrategy.java
│ │ │ │ │ ├── BeanPropertyAccessStrategy.java
│ │ │ │ │ ├── DirectlyAccessedProperty.java
│ │ │ │ │ ├── DirectPropertyAccessStrategy.java
│ │ │ │ │ ├── MethodAccessedProperty.java
│ │ │ │ │ ├── PropertyAccessException.java
│ │ │ │ │ ├── PropertyAccessStrategy.java
│ │ │ │ │ ├── Property.java
│ │ │ │ │ └── UniformPropertyAccessStrategy.java
│ │ │ │ ├── ReflectionUtils.java
│ │ │ │ ├── Registration.java
│ │ │ │ ├── stream
│ │ │ │ │ ├── BlockingStream.java
│ │ │ │ │ └── StreamUtils.java
│ │ │ │ ├── StringUtils.java
│ │ │ │ ├── transaction
│ │ │ │ │ ├── NoTransactionManager.java
│ │ │ │ │ ├── Transaction.java
│ │ │ │ │ └── TransactionManager.java
│ │ │ │ └── TypeReflectionUtils.java
│ │ │ ├── deadline
│ │ │ │ ├── AbstractDeadlineManager.java
│ │ │ │ ├── annotation
│ │ │ │ │ ├── DeadlineHandler.java
│ │ │ │ │ ├── DeadlineHandlingMember.java
│ │ │ │ │ └── DeadlineMethodMessageHandlerDefinition.java
│ │ │ │ ├── dbscheduler
│ │ │ │ │ ├── DbSchedulerBinaryDeadlineDetails.java
│ │ │ │ │ ├── DbSchedulerDeadlineManager.java
│ │ │ │ │ ├── DbSchedulerDeadlineManagerSupplier.java
│ │ │ │ │ ├── DbSchedulerDeadlineToken.java
│ │ │ │ │ ├── DbSchedulerHumanReadableDeadlineDetails.java
│ │ │ │ │ └── DeadlineManagerNotSuppliedException.java
│ │ │ │ ├── DeadlineException.java
│ │ │ │ ├── DeadlineManager.java
│ │ │ │ ├── DeadlineManagerSpanFactory.java
│ │ │ │ ├── DeadlineMessage.java
│ │ │ │ ├── DefaultDeadlineManagerSpanFactory.java
│ │ │ │ ├── GenericDeadlineMessage.java
│ │ │ │ ├── jobrunr
│ │ │ │ │ ├── DeadlineDetails.java
│ │ │ │ │ ├── JobRunrDeadlineManager.java
│ │ │ │ │ └── LabelUtils.java
│ │ │ │ ├── quartz
│ │ │ │ │ ├── DeadlineJob.java
│ │ │ │ │ └── QuartzDeadlineManager.java
│ │ │ │ └── SimpleDeadlineManager.java
│ │ │ ├── eventhandling
│ │ │ │ ├── AbstractDomainEventEntry.java
│ │ │ │ ├── AbstractEventBus.java
│ │ │ │ ├── AbstractEventEntry.java
│ │ │ │ ├── AbstractEventProcessor.java
│ │ │ │ ├── AbstractSequencedDomainEventEntry.java
│ │ │ │ ├── AddedTrackerStatus.java
│ │ │ │ ├── AllowReplay.java
│ │ │ │ ├── AnnotationEventHandlerAdapter.java
│ │ │ │ ├── async
│ │ │ │ │ ├── AsynchronousEventProcessingStrategy.java
│ │ │ │ │ ├── EventProcessorTask.java
│ │ │ │ │ ├── FullConcurrencyPolicy.java
│ │ │ │ │ ├── PropertySequencingPolicy.java
│ │ │ │ │ ├── SequencingPolicy.java
│ │ │ │ │ ├── SequentialPerAggregatePolicy.java
│ │ │ │ │ └── SequentialPolicy.java
│ │ │ │ ├── ConcludesBatch.java
│ │ │ │ ├── ConcludesBatchParameterResolverFactory.java
│ │ │ │ ├── deadletter
│ │ │ │ │ ├── DeadLetteredEventProcessingTask.java
│ │ │ │ │ ├── DeadLetteringEventHandlerInvoker.java
│ │ │ │ │ ├── jdbc
│ │ │ │ │ │ ├── DeadLetterJdbcConverter.java
│ │ │ │ │ │ ├── DeadLetterSchema.java
│ │ │ │ │ │ ├── DeadLetterStatementFactory.java
│ │ │ │ │ │ ├── DeadLetterTableFactory.java
│ │ │ │ │ │ ├── DefaultDeadLetterJdbcConverter.java
│ │ │ │ │ │ ├── DefaultDeadLetterStatementFactory.java
│ │ │ │ │ │ ├── GenericDeadLetterTableFactory.java
│ │ │ │ │ │ ├── JdbcDeadLetter.java
│ │ │ │ │ │ └── JdbcSequencedDeadLetterQueue.java
│ │ │ │ │ ├── jpa
│ │ │ │ │ │ ├── DeadLetterEntry.java
│ │ │ │ │ │ ├── DeadLetterEventEntry.java
│ │ │ │ │ │ ├── DeadLetterJpaConverter.java
│ │ │ │ │ │ ├── EventMessageDeadLetterJpaConverter.java
│ │ │ │ │ │ ├── JpaDeadLetter.java
│ │ │ │ │ │ ├── JpaSequencedDeadLetterQueue.java
│ │ │ │ │ │ └── NoJpaConverterFoundException.java
│ │ │ │ │ ├── legacyjpa
│ │ │ │ │ │ ├── DeadLetterJpaConverter.java
│ │ │ │ │ │ ├── EventMessageDeadLetterJpaConverter.java
│ │ │ │ │ │ ├── JpaDeadLetter.java
│ │ │ │ │ │ └── JpaSequencedDeadLetterQueue.java
│ │ │ │ │ └── SequenceIdentifierCache.java
│ │ │ │ ├── DefaultEventBusSpanFactory.java
│ │ │ │ ├── DefaultEventProcessorSpanFactory.java
│ │ │ │ ├── DirectEventProcessingStrategy.java
│ │ │ │ ├── DisallowReplay.java
│ │ │ │ ├── DomainEventData.java
│ │ │ │ ├── DomainEventMessage.java
│ │ │ │ ├── DomainEventSequenceAware.java
│ │ │ │ ├── ErrorContext.java
│ │ │ │ ├── ErrorHandler.java
│ │ │ │ ├── EventBus.java
│ │ │ │ ├── EventBusSpanFactory.java
│ │ │ │ ├── EventData.java
│ │ │ │ ├── EventHandlerInvoker.java
│ │ │ │ ├── EventHandler.java
│ │ │ │ ├── EventMessageHandler.java
│ │ │ │ ├── EventMessage.java
│ │ │ │ ├── EventProcessingException.java
│ │ │ │ ├── EventProcessingStrategy.java
│ │ │ │ ├── EventProcessor.java
│ │ │ │ ├── EventProcessorSpanFactory.java
│ │ │ │ ├── EventTrackerStatusChangeListener.java
│ │ │ │ ├── EventTrackerStatus.java
│ │ │ │ ├── EventUtils.java
│ │ │ │ ├── GapAwareTrackingToken.java
│ │ │ │ ├── gateway
│ │ │ │ │ ├── AbstractEventGateway.java
│ │ │ │ │ ├── DefaultEventGateway.java
│ │ │ │ │ └── EventGateway.java
│ │ │ │ ├── GenericDomainEventEntry.java
│ │ │ │ ├── GenericDomainEventMessage.java
│ │ │ │ ├── GenericEventMessage.java
│ │ │ │ ├── GenericTrackedDomainEventMessage.java
│ │ │ │ ├── GenericTrackedEventMessage.java
│ │ │ │ ├── GlobalSequenceTrackingToken.java
│ │ │ │ ├── interceptors
│ │ │ │ │ └── EventLoggingInterceptor.java
│ │ │ │ ├── ListenerInvocationErrorHandler.java
│ │ │ │ ├── LoggingErrorHandler.java
│ │ │ │ ├── MergedTrackingToken.java
│ │ │ │ ├── MultiEventHandlerInvoker.java
│ │ │ │ ├── MultiSourceTrackingToken.java
│ │ │ │ ├── MultiStreamableMessageSource.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── pooled
│ │ │ │ │ ├── ClaimTask.java
│ │ │ │ │ ├── Coordinator.java
│ │ │ │ │ ├── CoordinatorTask.java
│ │ │ │ │ ├── MergeTask.java
│ │ │ │ │ ├── PooledStreamingEventProcessor.java
│ │ │ │ │ ├── SplitTask.java
│ │ │ │ │ └── WorkPackage.java
│ │ │ │ ├── PropagatingErrorHandler.java
│ │ │ │ ├── RemovedTrackerStatus.java
│ │ │ │ ├── replay
│ │ │ │ │ ├── GenericResetContext.java
│ │ │ │ │ ├── ReplayAwareMessageHandlerWrapper.java
│ │ │ │ │ ├── ReplayContext.java
│ │ │ │ │ ├── ReplayContextParameterResolverFactory.java
│ │ │ │ │ ├── ReplayParameterResolverFactory.java
│ │ │ │ │ └── ResetContext.java
│ │ │ │ ├── ReplayStatus.java
│ │ │ │ ├── ReplayToken.java
│ │ │ │ ├── ResetHandler.java
│ │ │ │ ├── ResetNotSupportedException.java
│ │ │ │ ├── scheduling
│ │ │ │ │ ├── dbscheduler
│ │ │ │ │ │ ├── DbSchedulerBinaryEventData.java
│ │ │ │ │ │ ├── DbSchedulerEventScheduler.java
│ │ │ │ │ │ ├── DbSchedulerEventSchedulerSupplier.java
│ │ │ │ │ │ ├── DbSchedulerHumanReadableEventData.java
│ │ │ │ │ │ ├── DbSchedulerScheduleToken.java
│ │ │ │ │ │ └── EventSchedulerNotSuppliedException.java
│ │ │ │ │ ├── EventScheduler.java
│ │ │ │ │ ├── java
│ │ │ │ │ │ ├── SimpleEventScheduler.java
│ │ │ │ │ │ └── SimpleScheduleToken.java
│ │ │ │ │ ├── jobrunr
│ │ │ │ │ │ ├── JobRunrEventScheduler.java
│ │ │ │ │ │ └── JobRunrScheduleToken.java
│ │ │ │ │ ├── quartz
│ │ │ │ │ │ ├── EventJobDataBinder.java
│ │ │ │ │ │ ├── FireEventJob.java
│ │ │ │ │ │ ├── QuartzEventScheduler.java
│ │ │ │ │ │ └── QuartzScheduleToken.java
│ │ │ │ │ ├── ScheduleToken.java
│ │ │ │ │ └── SchedulingException.java
│ │ │ │ ├── Segment.java
│ │ │ │ ├── SequenceNumber.java
│ │ │ │ ├── SequenceNumberParameterResolverFactory.java
│ │ │ │ ├── SimpleEventBus.java
│ │ │ │ ├── SimpleEventHandlerInvoker.java
│ │ │ │ ├── StreamingEventProcessor.java
│ │ │ │ ├── SubscribingEventProcessor.java
│ │ │ │ ├── Timestamp.java
│ │ │ │ ├── TimestampParameterResolverFactory.java
│ │ │ │ ├── tokenstore
│ │ │ │ │ ├── AbstractTokenEntry.java
│ │ │ │ │ ├── ConfigToken.java
│ │ │ │ │ ├── GenericTokenEntry.java
│ │ │ │ │ ├── inmemory
│ │ │ │ │ │ └── InMemoryTokenStore.java
│ │ │ │ │ ├── jdbc
│ │ │ │ │ │ ├── GenericTokenTableFactory.java
│ │ │ │ │ │ ├── JdbcTokenStore.java
│ │ │ │ │ │ ├── Oracle11TokenTableFactory.java
│ │ │ │ │ │ ├── PostgresTokenTableFactory.java
│ │ │ │ │ │ ├── TokenSchema.java
│ │ │ │ │ │ └── TokenTableFactory.java
│ │ │ │ │ ├── jpa
│ │ │ │ │ │ ├── JpaTokenStore.java
│ │ │ │ │ │ └── TokenEntry.java
│ │ │ │ │ ├── legacyjpa
│ │ │ │ │ │ └── JpaTokenStore.java
│ │ │ │ │ ├── TokenStore.java
│ │ │ │ │ ├── UnableToClaimTokenException.java
│ │ │ │ │ ├── UnableToInitializeTokenException.java
│ │ │ │ │ └── UnableToRetrieveIdentifierException.java
│ │ │ │ ├── TrackedDomainEventData.java
│ │ │ │ ├── TrackedEventData.java
│ │ │ │ ├── TrackedEventMessage.java
│ │ │ │ ├── TrackerStatus.java
│ │ │ │ ├── TrackingEventProcessorConfiguration.java
│ │ │ │ ├── TrackingEventProcessor.java
│ │ │ │ ├── TrackingEventStream.java
│ │ │ │ ├── TrackingToken.java
│ │ │ │ ├── TrackingTokenParameterResolverFactory.java
│ │ │ │ ├── TransactionMethodExecutionException.java
│ │ │ │ ├── WrappedToken.java
│ │ │ │ └── WrappedTrackerStatus.java
│ │ │ ├── lifecycle
│ │ │ │ ├── LifecycleHandlerInvocationException.java
│ │ │ │ ├── Lifecycle.java
│ │ │ │ ├── Phase.java
│ │ │ │ ├── ShutdownHandler.java
│ │ │ │ ├── ShutdownInProgressException.java
│ │ │ │ ├── ShutdownLatch.java
│ │ │ │ └── StartHandler.java
│ │ │ ├── messaging
│ │ │ │ ├── AbstractMessage.java
│ │ │ │ ├── annotation
│ │ │ │ │ ├── AbstractAnnotatedParameterResolverFactory.java
│ │ │ │ │ ├── AggregateType.java
│ │ │ │ │ ├── AggregateTypeParameterResolverFactory.java
│ │ │ │ │ ├── AnnotatedHandlerAttributes.java
│ │ │ │ │ ├── AnnotatedHandlerInspector.java
│ │ │ │ │ ├── AnnotatedMessageHandlingMemberDefinition.java
│ │ │ │ │ ├── AnnotatedMessageHandlingMember.java
│ │ │ │ │ ├── ClasspathHandlerDefinition.java
│ │ │ │ │ ├── ClasspathHandlerEnhancerDefinition.java
│ │ │ │ │ ├── ClasspathParameterResolverFactory.java
│ │ │ │ │ ├── DefaultParameterResolverFactory.java
│ │ │ │ │ ├── FixedValueParameterResolver.java
│ │ │ │ │ ├── HandlerComparator.java
│ │ │ │ │ ├── HandlerDefinition.java
│ │ │ │ │ ├── HandlerEnhancerDefinition.java
│ │ │ │ │ ├── HasHandlerAttributes.java
│ │ │ │ │ ├── InterceptorChainParameterResolverFactory.java
│ │ │ │ │ ├── MessageHandlerInterceptorDefinition.java
│ │ │ │ │ ├── MessageHandlerInterceptorMemberChain.java
│ │ │ │ │ ├── MessageHandlerInvocationException.java
│ │ │ │ │ ├── MessageHandler.java
│ │ │ │ │ ├── MessageHandlingMember.java
│ │ │ │ │ ├── MessageIdentifier.java
│ │ │ │ │ ├── MessageIdentifierParameterResolverFactory.java
│ │ │ │ │ ├── MessageInterceptingMember.java
│ │ │ │ │ ├── MetaDataValue.java
│ │ │ │ │ ├── MultiHandlerDefinition.java
│ │ │ │ │ ├── MultiHandlerEnhancerDefinition.java
│ │ │ │ │ ├── MultiParameterResolverFactory.java
│ │ │ │ │ ├── NoMoreInterceptors.java
│ │ │ │ │ ├── ParameterResolverFactory.java
│ │ │ │ │ ├── ParameterResolver.java
│ │ │ │ │ ├── PayloadParameterResolver.java
│ │ │ │ │ ├── ResultParameterResolverFactory.java
│ │ │ │ │ ├── ScopeDescriptorParameterResolverFactory.java
│ │ │ │ │ ├── SimpleResourceParameterResolverFactory.java
│ │ │ │ │ ├── SourceId.java
│ │ │ │ │ ├── SourceIdParameterResolverFactory.java
│ │ │ │ │ ├── UnsupportedHandlerException.java
│ │ │ │ │ └── WrappedMessageHandlingMember.java
│ │ │ │ ├── correlation
│ │ │ │ │ ├── CorrelationDataProvider.java
│ │ │ │ │ ├── MessageOriginProvider.java
│ │ │ │ │ ├── MultiCorrelationDataProvider.java
│ │ │ │ │ └── SimpleCorrelationDataProvider.java
│ │ │ │ ├── deadletter
│ │ │ │ │ ├── Cause.java
│ │ │ │ │ ├── DeadLetter.java
│ │ │ │ │ ├── DeadLetterParameterResolverFactory.java
│ │ │ │ │ ├── DeadLetterQueueOverflowException.java
│ │ │ │ │ ├── Decisions.java
│ │ │ │ │ ├── DoNotEnqueue.java
│ │ │ │ │ ├── EnqueueDecision.java
│ │ │ │ │ ├── EnqueuePolicy.java
│ │ │ │ │ ├── GenericDeadLetter.java
│ │ │ │ │ ├── Ignore.java
│ │ │ │ │ ├── InMemorySequencedDeadLetterQueue.java
│ │ │ │ │ ├── NoSuchDeadLetterException.java
│ │ │ │ │ ├── SequencedDeadLetterProcessor.java
│ │ │ │ │ ├── SequencedDeadLetterQueue.java
│ │ │ │ │ ├── ShouldEnqueue.java
│ │ │ │ │ ├── ThrowableCause.java
│ │ │ │ │ └── WrongDeadLetterTypeException.java
│ │ │ │ ├── DefaultInterceptorChain.java
│ │ │ │ ├── Distributed.java
│ │ │ │ ├── EventPublicationFailedException.java
│ │ │ │ ├── ExecutionException.java
│ │ │ │ ├── GenericMessage.java
│ │ │ │ ├── GenericResultMessage.java
│ │ │ │ ├── HandlerAttributes.java
│ │ │ │ ├── HandlerExecutionException.java
│ │ │ │ ├── Headers.java
│ │ │ │ ├── IllegalPayloadAccessException.java
│ │ │ │ ├── InterceptorChain.java
│ │ │ │ ├── interceptors
│ │ │ │ │ ├── BeanValidationInterceptor.java
│ │ │ │ │ ├── CorrelationDataInterceptor.java
│ │ │ │ │ ├── ExceptionHandler.java
│ │ │ │ │ ├── JSR303ViolationException.java
│ │ │ │ │ ├── legacyvalidation
│ │ │ │ │ │ ├── BeanValidationInterceptor.java
│ │ │ │ │ │ └── JSR303ViolationException.java
│ │ │ │ │ ├── LoggingInterceptor.java
│ │ │ │ │ ├── MessageHandlerInterceptor.java
│ │ │ │ │ ├── ResultHandler.java
│ │ │ │ │ └── TransactionManagingInterceptor.java
│ │ │ │ ├── MessageDecorator.java
│ │ │ │ ├── MessageDispatchInterceptor.java
│ │ │ │ ├── MessageDispatchInterceptorSupport.java
│ │ │ │ ├── MessageHandlerInterceptor.java
│ │ │ │ ├── MessageHandlerInterceptorSupport.java
│ │ │ │ ├── MessageHandler.java
│ │ │ │ ├── Message.java
│ │ │ │ ├── MetaData.java
│ │ │ │ ├── NoScopeDescriptor.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── RemoteExceptionDescription.java
│ │ │ │ ├── RemoteHandlingException.java
│ │ │ │ ├── RemoteNonTransientHandlingException.java
│ │ │ │ ├── responsetypes
│ │ │ │ │ ├── AbstractResponseType.java
│ │ │ │ │ ├── ConvertingResponseMessage.java
│ │ │ │ │ ├── InstanceResponseType.java
│ │ │ │ │ ├── MultipleInstancesResponseType.java
│ │ │ │ │ ├── OptionalResponseType.java
│ │ │ │ │ ├── PublisherResponseType.java
│ │ │ │ │ ├── ResponseType.java
│ │ │ │ │ └── ResponseTypes.java
│ │ │ │ ├── ResultMessage.java
│ │ │ │ ├── ScopeAware.java
│ │ │ │ ├── ScopeAwareProvider.java
│ │ │ │ ├── ScopeDescriptor.java
│ │ │ │ ├── Scope.java
│ │ │ │ ├── SimpleHandlerAttributes.java
│ │ │ │ ├── StreamableMessageSource.java
│ │ │ │ ├── SubscribableMessageSource.java
│ │ │ │ └── unitofwork
│ │ │ │ ├── AbstractUnitOfWork.java
│ │ │ │ ├── BatchingUnitOfWork.java
│ │ │ │ ├── CurrentUnitOfWork.java
│ │ │ │ ├── DefaultUnitOfWork.java
│ │ │ │ ├── ExecutionResult.java
│ │ │ │ ├── MessageProcessingContext.java
│ │ │ │ ├── RollbackConfiguration.java
│ │ │ │ ├── RollbackConfigurationType.java
│ │ │ │ └── UnitOfWork.java
│ │ │ ├── monitoring
│ │ │ │ ├── MessageMonitor.java
│ │ │ │ ├── MultiMessageMonitor.java
│ │ │ │ ├── NoOpMessageMonitorCallback.java
│ │ │ │ └── NoOpMessageMonitor.java
│ │ │ ├── queryhandling
│ │ │ │ ├── annotation
│ │ │ │ │ ├── AnnotationQueryHandlerAdapter.java
│ │ │ │ │ ├── MethodQueryMessageHandlerDefinition.java
│ │ │ │ │ └── QueryHandlingMember.java
│ │ │ │ ├── CompletedEmitterException.java
│ │ │ │ ├── DefaultQueryBusSpanFactory.java
│ │ │ │ ├── DefaultQueryGateway.java
│ │ │ │ ├── DefaultQueryUpdateEmitterSpanFactory.java
│ │ │ │ ├── DefaultSubscriptionQueryResult.java
│ │ │ │ ├── FluxSinkWrapper.java
│ │ │ │ ├── GenericQueryMessage.java
│ │ │ │ ├── GenericQueryResponseMessage.java
│ │ │ │ ├── GenericStreamingQueryMessage.java
│ │ │ │ ├── GenericSubscriptionQueryMessage.java
│ │ │ │ ├── GenericSubscriptionQueryUpdateMessage.java
│ │ │ │ ├── LoggingQueryInvocationErrorHandler.java
│ │ │ │ ├── MonoSinkWrapper.java
│ │ │ │ ├── NoHandlerForQueryException.java
│ │ │ │ ├── QueryBus.java
│ │ │ │ ├── QueryBusSpanFactory.java
│ │ │ │ ├── QueryExecutionException.java
│ │ │ │ ├── QueryGateway.java
│ │ │ │ ├── QueryHandlerAdapter.java
│ │ │ │ ├── QueryHandler.java
│ │ │ │ ├── QueryInvocationErrorHandler.java
│ │ │ │ ├── QueryMessage.java
│ │ │ │ ├── QueryResponseMessage.java
│ │ │ │ ├── QuerySubscription.java
│ │ │ │ ├── QueryUpdateEmitter.java
│ │ │ │ ├── QueryUpdateEmitterSpanFactory.java
│ │ │ │ ├── registration
│ │ │ │ │ ├── DuplicateQueryHandlerResolution.java
│ │ │ │ │ ├── DuplicateQueryHandlerResolver.java
│ │ │ │ │ ├── DuplicateQueryHandlerSubscriptionException.java
│ │ │ │ │ ├── FailingDuplicateQueryHandlerResolver.java
│ │ │ │ │ └── LoggingDuplicateQueryHandlerResolver.java
│ │ │ │ ├── SimpleQueryBus.java
│ │ │ │ ├── SimpleQueryUpdateEmitter.java
│ │ │ │ ├── SinksManyWrapper.java
│ │ │ │ ├── SinkWrapper.java
│ │ │ │ ├── StreamingQueryMessage.java
│ │ │ │ ├── SubscriptionQueryBackpressure.java
│ │ │ │ ├── SubscriptionQueryMessage.java
│ │ │ │ ├── SubscriptionQueryResult.java
│ │ │ │ ├── SubscriptionQueryUpdateMessage.java
│ │ │ │ └── UpdateHandlerRegistration.java
│ │ │ ├── serialization
│ │ │ │ ├── AbstractXStreamSerializer.java
│ │ │ │ ├── AnnotationRevisionResolver.java
│ │ │ │ ├── CachingSupplier.java
│ │ │ │ ├── CannotConvertBetweenTypesException.java
│ │ │ │ ├── ChainedConverter.java
│ │ │ │ ├── ChainingConverter.java
│ │ │ │ ├── ContentTypeConverter.java
│ │ │ │ ├── Converter.java
│ │ │ │ ├── converters
│ │ │ │ │ ├── BlobToInputStreamConverter.java
│ │ │ │ │ ├── ByteArrayToInputStreamConverter.java
│ │ │ │ │ ├── ByteArrayToStringConverter.java
│ │ │ │ │ ├── InputStreamToByteArrayConverter.java
│ │ │ │ │ └── StringToByteArrayConverter.java
│ │ │ │ ├── FixedValueRevisionResolver.java
│ │ │ │ ├── GapAwareTrackingTokenConverter.java
│ │ │ │ ├── JavaSerializer.java
│ │ │ │ ├── json
│ │ │ │ │ ├── ByteArrayToJsonNodeConverter.java
│ │ │ │ │ ├── JacksonSerializer.java
│ │ │ │ │ ├── JsonNodeToByteArrayConverter.java
│ │ │ │ │ ├── JsonNodeToObjectNodeConverter.java
│ │ │ │ │ ├── MetaDataDeserializer.java
│ │ │ │ │ └── ObjectNodeToJsonNodeConverter.java
│ │ │ │ ├── LazyDeserializingObject.java
│ │ │ │ ├── MavenArtifactRevisionResolver.java
│ │ │ │ ├── package-info.java
│ │ │ │ ├── Revision.java
│ │ │ │ ├── RevisionResolver.java
│ │ │ │ ├── SerializationException.java
│ │ │ │ ├── SerializedMessage.java
│ │ │ │ ├── SerializedMetaData.java
│ │ │ │ ├── SerializedObjectHolder.java
│ │ │ │ ├── SerializedObject.java
│ │ │ │ ├── SerializedType.java
│ │ │ │ ├── Serializer.java
│ │ │ │ ├── SerialVersionUIDRevisionResolver.java
│ │ │ │ ├── SimpleSerializedObject.java
│ │ │ │ ├── SimpleSerializedType.java
│ │ │ │ ├── UnknownSerializedType.java
│ │ │ │ ├── upcasting
│ │ │ │ │ ├── ContextAwareSingleEntryMultiUpcaster.java
│ │ │ │ │ ├── ContextAwareSingleEntryUpcaster.java
│ │ │ │ │ ├── event
│ │ │ │ │ │ ├── ContextAwareEventMultiUpcaster.java
│ │ │ │ │ │ ├── ContextAwareSingleEventUpcaster.java
│ │ │ │ │ │ ├── EventMultiUpcaster.java
│ │ │ │ │ │ ├── EventTypeUpcaster.java
│ │ │ │ │ │ ├── EventUpcasterChain.java
│ │ │ │ │ │ ├── EventUpcaster.java
│ │ │ │ │ │ ├── InitialEventRepresentation.java
│ │ │ │ │ │ ├── IntermediateEventRepresentation.java
│ │ │ │ │ │ ├── NoOpEventUpcaster.java
│ │ │ │ │ │ ├── SingleEventUpcaster.java
│ │ │ │ │ │ └── UpcastedEventRepresentation.java
│ │ │ │ │ ├── GenericUpcasterChain.java
│ │ │ │ │ ├── SingleEntryMultiUpcaster.java
│ │ │ │ │ ├── SingleEntryUpcaster.java
│ │ │ │ │ └── Upcaster.java
│ │ │ │ └── xml
│ │ │ │ ├── CompactDriver.java
│ │ │ │ ├── Dom4JToByteArrayConverter.java
│ │ │ │ ├── InputStreamToDom4jConverter.java
│ │ │ │ ├── InputStreamToXomConverter.java
│ │ │ │ ├── XomToStringConverter.java
│ │ │ │ └── XStreamSerializer.java
│ │ │ ├── tracing
│ │ │ │ ├── attributes
│ │ │ │ │ ├── AggregateIdentifierSpanAttributesProvider.java
│ │ │ │ │ ├── MessageIdSpanAttributesProvider.java
│ │ │ │ │ ├── MessageNameSpanAttributesProvider.java
│ │ │ │ │ ├── MessageTypeSpanAttributesProvider.java
│ │ │ │ │ ├── MetadataSpanAttributesProvider.java
│ │ │ │ │ └── PayloadTypeSpanAttributesProvider.java
│ │ │ │ ├── HandlerSpanFactory.java
│ │ │ │ ├── LoggingSpanFactory.java
│ │ │ │ ├── MultiSpanFactory.java
│ │ │ │ ├── NestingSpanFactory.java
│ │ │ │ ├── NoOpSpanFactory.java
│ │ │ │ ├── SpanAttributesProvider.java
│ │ │ │ ├── SpanFactory.java
│ │ │ │ ├── Span.java
│ │ │ │ ├── SpanScope.java
│ │ │ │ ├── SpanUtils.java
│ │ │ │ └── TracingHandlerEnhancerDefinition.java
│ │ │ └── util
│ │ │ ├── ClasspathResolver.java
│ │ │ ├── HandlerTypeResolver.java
│ │ │ └── MavenArtifactVersionResolver.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ ├── org.axonframework.common.property.PropertyAccessStrategy
│ │ ├── org.axonframework.messaging.annotation.HandlerDefinition
│ │ ├── org.axonframework.messaging.annotation.HandlerEnhancerDefinition
│ │ ├── org.axonframework.messaging.annotation.ParameterResolverFactory
│ │ └── org.axonframework.serialization.ContentTypeConverter
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── commandhandling
│ │ │ ├── AnnotationCommandHandlerAdapterTest.java
│ │ │ ├── AsynchronousCommandBusTest.java
│ │ │ ├── callbacks
│ │ │ │ └── FutureCallbackTest.java
│ │ │ ├── CurrentUnitOfWorkParameterResolverFactoryTest.java
│ │ │ ├── DefaultCommandBusSpanFactoryTest.java
│ │ │ ├── distributed
│ │ │ │ ├── AnnotationRoutingStrategyTest.java
│ │ │ │ ├── CommandCallbackRepositoryTest.java
│ │ │ │ ├── commandfilter
│ │ │ │ │ ├── AcceptAllSerializationTest.java
│ │ │ │ │ ├── AndCommandMessageFilterSerializationTest.java
│ │ │ │ │ ├── CommandFilterTest.java
│ │ │ │ │ ├── CommandNameFilterSerializationTest.java
│ │ │ │ │ ├── DenyAllSerializationTest.java
│ │ │ │ │ ├── DenyCommandNameFilterSerializationTest.java
│ │ │ │ │ ├── NegateCommandMessageFilterSerializationTest.java
│ │ │ │ │ └── OrCommandMessageFilterSerializationTest.java
│ │ │ │ ├── ConsistentHashTest.java
│ │ │ │ ├── DistributedCommandBusTest.java
│ │ │ │ ├── MetaDataRoutingStrategyTest.java
│ │ │ │ ├── ReplyMessageSerializationTest.java
│ │ │ │ └── UnresolvedRoutingKeyPolicyTest.java
│ │ │ ├── DuplicateCommandHandlerResolutionTest.java
│ │ │ ├── gateway
│ │ │ │ ├── AbstractRetrySchedulerTest.java
│ │ │ │ ├── CommandGatewayFactoryTest.java
│ │ │ │ ├── DefaultCommandGatewayTest.java
│ │ │ │ ├── ExponentialBackOffIntervalRetrySchedulerTest.java
│ │ │ │ └── IntervalRetrySchedulerTest.java
│ │ │ ├── GenericCommandMessageTest.java
│ │ │ ├── SimpleCommandBusTest.java
│ │ │ └── WrappedCommandCallbackTest.java
│ │ ├── common
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationUtilsTest.java
│ │ │ │ └── PriorityAnnotationComparatorTest.java
│ │ │ ├── AssertTest.java
│ │ │ ├── AxonThreadFactoryTest.java
│ │ │ ├── BuilderUtilsTest.java
│ │ │ ├── caching
│ │ │ │ ├── AbstractCacheAdapterTest.java
│ │ │ │ ├── EhCache3AdapterTest.java
│ │ │ │ ├── EhCacheAdapterTest.java
│ │ │ │ ├── JCacheAdapterTest.java
│ │ │ │ ├── NoCacheTest.java
│ │ │ │ └── WeakReferenceCacheTest.java
│ │ │ ├── CollectionUtilsTest.java
│ │ │ ├── DateTimeUtilsTest.java
│ │ │ ├── ExceptionUtilsTest.java
│ │ │ ├── IdentifierValidatorTest.java
│ │ │ ├── jdbc
│ │ │ │ ├── ConnectionWrapperFactoryTest.java
│ │ │ │ ├── JdbcUtilsTest.java
│ │ │ │ ├── PagingJdbcIterableTest.java
│ │ │ │ └── UnitOfWorkAwareConnectionProviderWrapperTest.java
│ │ │ ├── legacyjpa
│ │ │ │ ├── PagingJpaQueryIterableTest.java
│ │ │ │ └── TestJpaEntry.java
│ │ │ ├── lock
│ │ │ │ ├── LockFactoryTest.java
│ │ │ │ ├── NoOpLockTest.java
│ │ │ │ ├── NullLockFactoryTest.java
│ │ │ │ └── PessimisticLockFactoryTest.java
│ │ │ ├── ObjectUtilsTest.java
│ │ │ ├── ProcessUtilsTest.java
│ │ │ ├── property
│ │ │ │ ├── AbstractPropertyAccessStrategyTest.java
│ │ │ │ ├── BeanPropertyAccessStrategyTest.java
│ │ │ │ ├── DirectPropertyAccessStrategyTest.java
│ │ │ │ ├── PropertyAccessStrategyTest.java
│ │ │ │ └── UniformPropertyAccessStrategyTest.java
│ │ │ ├── ReflectionUtilsTest.java
│ │ │ ├── StringUtilsTest.java
│ │ │ └── transaction
│ │ │ └── NoOpTransactionManager.java
│ │ ├── deadline
│ │ │ ├── annotation
│ │ │ │ └── DeadlineMethodMessageHandlerDefinitionTest.java
│ │ │ ├── dbscheduler
│ │ │ │ ├── DbScheduledDeadlineTokenTest.java
│ │ │ │ ├── DbSchedulerBinaryDeadlineDetailsTest.java
│ │ │ │ ├── DbSchedulerDeadlineManagerBuilderTest.java
│ │ │ │ ├── DbSchedulerDeadlineManagerTest.java
│ │ │ │ └── DbSchedulerHumanReadableDeadlineDetailsTest.java
│ │ │ ├── DefaultDeadlineManagerSpanFactoryTest.java
│ │ │ ├── jobrunr
│ │ │ │ ├── DeadlineDetailsSerializationTest.java
│ │ │ │ ├── JobRunrDeadlineManagerBuilderTest.java
│ │ │ │ └── LabelUtilsTest.java
│ │ │ ├── quartz
│ │ │ │ └── DeadlineJobDataBinderTest.java
│ │ │ └── TestScopeDescriptor.java
│ │ ├── eventhandling
│ │ │ ├── AbstractEventBusTest.java
│ │ │ ├── AbstractEventProcessorTest.java
│ │ │ ├── AddedTrackerStatusTest.java
│ │ │ ├── AnnotatedParameterResolverFactoryTest.java
│ │ │ ├── AnnotationEventHandlerAdapterTest.java
│ │ │ ├── async
│ │ │ │ ├── AsynchronousEventProcessingStrategyTest.java
│ │ │ │ ├── AsynchronousEventProcessorConcurrencyTest.java
│ │ │ │ ├── FullConcurrencyPolicyTest.java
│ │ │ │ ├── PropertySequencingPolicyTest.java
│ │ │ │ ├── SequentialPerAggregatePolicyTest.java
│ │ │ │ └── SequentialPolicyTest.java
│ │ │ ├── ConcludesBatchParameterResolverFactoryTest.java
│ │ │ ├── deadletter
│ │ │ │ ├── DeadLetteredEventProcessingTaskTest.java
│ │ │ │ ├── DeadLetteringEventHandlerInvokerTest.java
│ │ │ │ ├── DeadLetteringEventIntegrationTest.java
│ │ │ │ ├── InMemoryDeadLetteringIntegrationTest.java
│ │ │ │ ├── InMemoryWithCacheDeadLetteringIntegrationTest.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── DeadLetterSchemaTest.java
│ │ │ │ │ ├── DefaultDeadLetterJdbcConverterTest.java
│ │ │ │ │ ├── DefaultDeadLetterStatementFactoryTest.java
│ │ │ │ │ ├── JdbcDeadLetteringEventIntegrationTest.java
│ │ │ │ │ └── JdbcSequencedDeadLetterQueueTest.java
│ │ │ │ ├── jpa
│ │ │ │ │ └── EventMessageDeadLetterJpaConverterTest.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaSequencedDeadLetterQueueTest.java
│ │ │ │ └── SequenceIdentifierCacheTest.java
│ │ │ ├── DefaultEventBusSpanFactoryTest.java
│ │ │ ├── DefaultEventProcessorSpanFactoryTest.java
│ │ │ ├── DirectEventProcessingStrategyTest.java
│ │ │ ├── EventHandlerInvokerTest.java
│ │ │ ├── EventMessageHandlerTest.java
│ │ │ ├── EventTrackerStatusChangeListenerTest.java
│ │ │ ├── EventTrackerStatusTest.java
│ │ │ ├── FakeEventTrackerStatus.java
│ │ │ ├── GapAwareTrackingTokenSerializationTest.java
│ │ │ ├── GapAwareTrackingTokenTest.java
│ │ │ ├── gateway
│ │ │ │ └── DefaultEventGatewayTest.java
│ │ │ ├── GenericDomainEventMessageTest.java
│ │ │ ├── GenericEventMessageTest.java
│ │ │ ├── GlobalSequenceTrackingTokenSerializationTest.java
│ │ │ ├── GlobalSequenceTrackingTokenTest.java
│ │ │ ├── MergedTrackingTokenSerializationTest.java
│ │ │ ├── MergedTrackingTokenTest.java
│ │ │ ├── MultiEventHandlerInvokerTest.java
│ │ │ ├── MultiSourceTrackingTokenSerializationTest.java
│ │ │ ├── MultiSourceTrackingTokenTest.java
│ │ │ ├── pooled
│ │ │ │ ├── CoordinatorTest.java
│ │ │ │ ├── MergeTaskTest.java
│ │ │ │ ├── PooledStreamingEventProcessorTest.java
│ │ │ │ ├── SplitTaskTest.java
│ │ │ │ └── WorkPackageTest.java
│ │ │ ├── PropagatingErrorHandlerTest.java
│ │ │ ├── RemovedTrackerStatusTest.java
│ │ │ ├── replay
│ │ │ │ ├── GenericResetContextTest.java
│ │ │ │ ├── ReplayAwareMessageHandlerWrapperTest.java
│ │ │ │ ├── ReplayAwareMessageHandlerWrapperWithDisallowReplayTest.java
│ │ │ │ ├── ReplayContextParameterResolverFactoryTest.java
│ │ │ │ └── ReplayParameterResolverFactoryTest.java
│ │ │ ├── ReplayTokenSerializationTest.java
│ │ │ ├── ReplayTokenTest.java
│ │ │ ├── scheduling
│ │ │ │ ├── dbscheduler
│ │ │ │ │ ├── AbstractDbSchedulerEventSchedulerTest.java
│ │ │ │ │ ├── BinaryDbSchedulerEventSchedulerTest.java
│ │ │ │ │ ├── DbScheduledScheduleTokenTest.java
│ │ │ │ │ ├── DbSchedulerBinaryEventDataTest.java
│ │ │ │ │ ├── DbSchedulerEventSchedulerBuilderTest.java
│ │ │ │ │ ├── DbSchedulerHumanReadableEventDataTest.java
│ │ │ │ │ └── HumanReadableDbSchedulerEventSchedulerTest.java
│ │ │ │ ├── java
│ │ │ │ │ ├── SimpleEventSchedulerTest.java
│ │ │ │ │ └── SimpleScheduleTokenSerializationTest.java
│ │ │ │ ├── jobrunr
│ │ │ │ │ ├── JobRunrEventSchedulerBuilderTest.java
│ │ │ │ │ ├── JobRunrEventSchedulerTest.java
│ │ │ │ │ └── JobRunrScheduleTokenTest.java
│ │ │ │ └── quartz
│ │ │ │ ├── DirectEventJobDataBinderTest.java
│ │ │ │ ├── QuartzEventSchedulerTest.java
│ │ │ │ └── QuartzScheduleTokenSerializationTest.java
│ │ │ ├── SegmentTest.java
│ │ │ ├── SimpleEventBusTest.java
│ │ │ ├── SimpleEventHandlerInvokerTest.java
│ │ │ ├── TimestampParameterResolverFactoryTest.java
│ │ │ ├── tokenstore
│ │ │ │ ├── ConfigTokenTest.java
│ │ │ │ ├── inmemory
│ │ │ │ │ └── InMemoryTokenStoreTest.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── JdbcTokenStoreTest.java
│ │ │ │ │ └── TokenSchemaTest.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaTokenStoreTest.java
│ │ │ │ └── TokenStoreTest.java
│ │ │ ├── TrackingEventProcessorConfigurationTest.java
│ │ │ └── TrackingTokenParameterResolverFactoryTest.java
│ │ ├── lifecycle
│ │ │ └── ShutdownLatchTest.java
│ │ ├── messaging
│ │ │ ├── annotation
│ │ │ │ ├── AggregateTypeParameterResolverFactoryTest.java
│ │ │ │ ├── AnnotatedHandlerAttributesTest.java
│ │ │ │ ├── AnnotatedHandlerInspectorTest.java
│ │ │ │ ├── AnnotatedMessageHandlingMemberTest.java
│ │ │ │ ├── HandlerComparatorTest.java
│ │ │ │ ├── HandlerHierarchyTest.java
│ │ │ │ ├── MessageIdentifierParameterResolverFactoryTest.java
│ │ │ │ ├── MultiParameterResolverFactoryTest.java
│ │ │ │ ├── ScopeDescriptorParameterResolverFactoryTest.java
│ │ │ │ ├── SimpleResourceParameterResolverFactoryTest.java
│ │ │ │ ├── SourceIdParameterResolverFactoryTest.java
│ │ │ │ └── WrappedMessageHandlingMemberTest.java
│ │ │ ├── correlation
│ │ │ │ ├── MetaDataValueTest.java
│ │ │ │ ├── SimpleCorrelationDataProviderTest.java
│ │ │ │ └── ThrowingCorrelationDataProvider.java
│ │ │ ├── deadletter
│ │ │ │ ├── DeadLetterParameterResolverFactoryTest.java
│ │ │ │ ├── DoNotEnqueueTest.java
│ │ │ │ ├── GenericDeadLetterTest.java
│ │ │ │ ├── IgnoreTest.java
│ │ │ │ ├── InMemorySequencedDeadLetterQueueTest.java
│ │ │ │ ├── SequencedDeadLetterQueueTest.java
│ │ │ │ ├── ShouldEnqueueTest.java
│ │ │ │ └── ThrowableCauseTest.java
│ │ │ ├── DefaultInterceptorChainTest.java
│ │ │ ├── GenericMessageTest.java
│ │ │ ├── GenericResultMessageTest.java
│ │ │ ├── HandlerExecutionExceptionTest.java
│ │ │ ├── HeadersTests.java
│ │ │ ├── interceptors
│ │ │ │ ├── CorrelationDataInterceptorTest.java
│ │ │ │ ├── ExceptionHandlerTest.java
│ │ │ │ ├── legacyvalidation
│ │ │ │ │ └── BeanValidationInterceptorTest.java
│ │ │ │ ├── LoggingInterceptorTest.java
│ │ │ │ └── TransactionManagingInterceptorTest.java
│ │ │ ├── MetaDataTest.java
│ │ │ ├── RemoteExceptionDescriptionSerializationTest.java
│ │ │ ├── responsetypes
│ │ │ │ ├── AbstractResponseTypeTest.java
│ │ │ │ ├── ConvertingResponseMessageTest.java
│ │ │ │ ├── InstanceResponseTypeSerializationTest.java
│ │ │ │ ├── InstanceResponseTypeTest.java
│ │ │ │ ├── MultipleInstancesResponseTypeSerializationTest.java
│ │ │ │ ├── MultipleInstancesResponseTypeTest.java
│ │ │ │ ├── OptionalResponseTypeSerializationTest.java
│ │ │ │ └── OptionalResponseTypeTest.java
│ │ │ ├── SimpleHandlerAttributesTest.java
│ │ │ └── unitofwork
│ │ │ ├── AbstractUnitOfWorkTest.java
│ │ │ ├── BatchingUnitOfWorkTest.java
│ │ │ ├── CurrentUnitOfWorkTest.java
│ │ │ ├── ExecutionResultTest.java
│ │ │ ├── RollbackConfigurationTypeTest.java
│ │ │ └── UnitOfWorkNestingTest.java
│ │ ├── monitoring
│ │ │ └── MultiMessageMonitorTest.java
│ │ ├── queryhandling
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationQueryHandlerAdapterTest.java
│ │ │ │ └── MethodQueryMessageHandlerDefinitionTest.java
│ │ │ ├── DefaultQueryBusSpanFactoryTest.java
│ │ │ ├── DefaultQueryGatewayTest.java
│ │ │ ├── DefaultQueryUpdateEmitterSpanFactoryTest.java
│ │ │ ├── FutureAsResponseTypeToQueryHandlersTest.java
│ │ │ ├── GenericQueryMessageTest.java
│ │ │ ├── GenericSubscriptionQueryUpdateMessageTest.java
│ │ │ ├── PrimitiveQueryHandlerResponseTypeTest.java
│ │ │ ├── registration
│ │ │ │ ├── FailingDuplicateQueryHandlerResolverTest.java
│ │ │ │ └── LoggingDuplicateQueryHandlerResolverTest.java
│ │ │ ├── SimpleQueryBusTest.java
│ │ │ ├── SimpleQueryUpdateEmitterTest.java
│ │ │ ├── StreamingQueryTest.java
│ │ │ └── UpdateHandlerRegistrationTest.java
│ │ ├── serialization
│ │ │ ├── AnnotationRevisionResolverTest.java
│ │ │ ├── ChainedConverterTest.java
│ │ │ ├── converters
│ │ │ │ ├── ByteArrayToStringConverterTest.java
│ │ │ │ ├── InputStreamToByteArrayConverterTest.java
│ │ │ │ └── StringToByteArrayConverterTest.java
│ │ │ ├── FixedValueRevisionResolverTest.java
│ │ │ ├── JavaSerializerTest.java
│ │ │ ├── json
│ │ │ │ ├── ByteArrayToJsonNodeConverterTest.java
│ │ │ │ ├── JacksonSerializerTest.java
│ │ │ │ ├── JsonNodeToByteArrayConverterTest.java
│ │ │ │ ├── JsonNodeToObjectNodeConverterTest.java
│ │ │ │ ├── MetaDataDeserializerTest.java
│ │ │ │ └── ObjectNodeToJsonNodeConverterTest.java
│ │ │ ├── LazyDeserializingObjectTest.java
│ │ │ ├── MavenArtifactRevisionResolverTest.java
│ │ │ ├── SerializationAwareTest.java
│ │ │ ├── SerializedMessageTest.java
│ │ │ ├── SerializedMetaDataValueTest.java
│ │ │ ├── SerialVersionUIDRevisionResolverTest.java
│ │ │ ├── TestSerializer.java
│ │ │ ├── upcasting
│ │ │ │ ├── event
│ │ │ │ │ ├── ContextAwareEventMultiUpcasterTest.java
│ │ │ │ │ ├── ContextAwareSingleEventUpcasterTest.java
│ │ │ │ │ ├── EventMultiUpcasterTest.java
│ │ │ │ │ ├── EventTypeUpcasterTest.java
│ │ │ │ │ ├── EventUpcasterChainTest.java
│ │ │ │ │ ├── InitialEventRepresentationTest.java
│ │ │ │ │ ├── IntermediateRepresentationTest.java
│ │ │ │ │ ├── SingleEventUpcasterTest.java
│ │ │ │ │ └── UpcastedEventRepresentationTest.java
│ │ │ │ └── GenericUpcasterChainTest.java
│ │ │ └── xml
│ │ │ ├── Dom4JToByteArrayConverterTest.java
│ │ │ ├── GapAwareTrackingTokenConverterTest.java
│ │ │ ├── InputStreamToDom4jConverterTest.java
│ │ │ ├── InputStreamToXomConverterTest.java
│ │ │ ├── XomToStringConverterTest.java
│ │ │ └── XStreamSerializerTest.java
│ │ ├── tracing
│ │ │ ├── attributes
│ │ │ │ ├── AggregateIdentifierSpanAttributesProviderTest.java
│ │ │ │ ├── MessageIdSpanAttributesProviderTest.java
│ │ │ │ ├── MessageNameSpanAttributesProviderTest.java
│ │ │ │ ├── MessageTypeSpanAttributesProviderTest.java
│ │ │ │ ├── MetadataSpanAttributesProviderTest.java
│ │ │ │ └── PayloadTypeSpanAttributesProviderTest.java
│ │ │ ├── IntermediateSpanFactoryTest.java
│ │ │ ├── LoggingSpanFactoryTest.java
│ │ │ ├── MultiSpanFactoryTest.java
│ │ │ ├── NestingSpanFactoryTest.java
│ │ │ ├── NoOpSpanFactoryTest.java
│ │ │ ├── SpanTest.java
│ │ │ ├── SpanUtilsTest.java
│ │ │ ├── TestSpanFactory.java
│ │ │ └── TracingHandlerEnhancerDefinitionTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── DbSchedulerTestUtil.java
│ │ ├── DelegateScheduledExecutorService.java
│ │ ├── EventTestUtils.java
│ │ ├── InMemoryStreamableEventSource.java
│ │ ├── MockException.java
│ │ ├── SecondStubEvent.java
│ │ ├── StubDomainEvent.java
│ │ ├── TestDomainEventEntry.java
│ │ └── ThirdStubEvent.java
│ └── resources
│ ├── ehcache.xml
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ └── META-INF
│ ├── maven
│ │ └── org.axonframework
│ │ └── axon-modelling
│ │ └── pom.properties
│ └── persistence.xml
├── metrics
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── metrics
│ │ ├── CapacityMonitor.java
│ │ ├── EventProcessorLatencyMonitor.java
│ │ ├── GlobalMetricRegistry.java
│ │ ├── MessageCountingMonitor.java
│ │ ├── MessageTimerMonitor.java
│ │ ├── MetricsConfigurerModule.java
│ │ └── PayloadTypeMessageMonitorWrapper.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── metrics
│ │ ├── CapacityMonitorTest.java
│ │ ├── EventProcessorLatencyMonitorTest.java
│ │ ├── GlobalMetricRegistryTest.java
│ │ ├── MessageCountingMonitorTest.java
│ │ ├── MessageTimerMonitorTest.java
│ │ ├── MetricsConfigurerModuleTest.java
│ │ ├── PayloadTypeMessageMonitorWrapperTest.java
│ │ └── TestClock.java
│ └── resources
│ └── log4j2.properties
├── metrics-micrometer
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── micrometer
│ │ ├── CapacityMonitor.java
│ │ ├── EventProcessorLatencyMonitor.java
│ │ ├── GlobalMetricRegistry.java
│ │ ├── MessageCountingMonitor.java
│ │ ├── MessageTimerMonitor.java
│ │ ├── MetricsConfigurerModule.java
│ │ ├── PayloadTypeMessageMonitorWrapper.java
│ │ ├── reservoir
│ │ │ └── SlidingTimeWindowReservoir.java
│ │ └── TagsUtil.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── micrometer
│ │ ├── CapacityMonitorTest.java
│ │ ├── EventProcessorLatencyMonitorTest.java
│ │ ├── GlobalMetricRegistryTest.java
│ │ ├── MessageCountingMonitorTest.java
│ │ ├── MessageTimerMonitorTest.java
│ │ ├── MetricsConfigurerModuleTest.java
│ │ ├── PayloadTypeMessageMonitorWrapperTest.java
│ │ └── reservoir
│ │ └── SlidingTimeWindowReservoirTest.java
│ └── resources
│ └── log4j2.properties
├── migration
│ ├── pom.xml
│ ├── README.md
│ └── src
│ ├── main
│ │ └── resources
│ │ └── META-INF
│ │ └── rewrite
│ │ ├── axon-jakarta-4.yml
│ │ └── axon-javax-4.yml
│ └── test
│ └── java
│ └── org
│ └── axonframework
│ └── migration
│ ├── AxonJakartaTest.java
│ └── AxonJavaxTest.java
├── modelling
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── modelling
│ │ │ ├── command
│ │ │ │ ├── AbstractRepository.java
│ │ │ │ ├── AggregateAnnotationCommandHandler.java
│ │ │ │ ├── AggregateCreationPolicy.java
│ │ │ │ ├── AggregateEntityNotFoundException.java
│ │ │ │ ├── AggregateIdentifier.java
│ │ │ │ ├── AggregateInvocationException.java
│ │ │ │ ├── Aggregate.java
│ │ │ │ ├── AggregateLifecycle.java
│ │ │ │ ├── AggregateMember.java
│ │ │ │ ├── AggregateNotFoundException.java
│ │ │ │ ├── AggregateRolledBackException.java
│ │ │ │ ├── AggregateRoot.java
│ │ │ │ ├── AggregateScopeDescriptor.java
│ │ │ │ ├── AggregateStreamCreationException.java
│ │ │ │ ├── AggregateVersion.java
│ │ │ │ ├── AnnotationCommandTargetResolver.java
│ │ │ │ ├── ApplyMore.java
│ │ │ │ ├── CommandHandlerInterceptor.java
│ │ │ │ ├── CommandTargetResolver.java
│ │ │ │ ├── ConcurrencyException.java
│ │ │ │ ├── ConflictingAggregateVersionException.java
│ │ │ │ ├── ConflictingModificationException.java
│ │ │ │ ├── CreationPolicyAggregateFactory.java
│ │ │ │ ├── CreationPolicy.java
│ │ │ │ ├── DefaultRepositorySpanFactory.java
│ │ │ │ ├── EntityId.java
│ │ │ │ ├── ForwardingMode.java
│ │ │ │ ├── ForwardMatchingInstances.java
│ │ │ │ ├── ForwardNone.java
│ │ │ │ ├── ForwardToAll.java
│ │ │ │ ├── GenericJpaRepository.java
│ │ │ │ ├── IdentifierMissingException.java
│ │ │ │ ├── inspection
│ │ │ │ │ ├── AbstractChildEntityDefinition.java
│ │ │ │ │ ├── AggregateMemberAnnotatedChildEntityCollectionDefinition.java
│ │ │ │ │ ├── AggregateMemberAnnotatedChildEntityDefinition.java
│ │ │ │ │ ├── AggregateMemberAnnotatedChildEntityMapDefinition.java
│ │ │ │ │ ├── AggregateMetaModelFactory.java
│ │ │ │ │ ├── AggregateModel.java
│ │ │ │ │ ├── AggregateModellingException.java
│ │ │ │ │ ├── AnnotatedAggregate.java
│ │ │ │ │ ├── AnnotatedAggregateMetaModelFactory.java
│ │ │ │ │ ├── AnnotatedChildEntity.java
│ │ │ │ │ ├── AnnotatedCommandHandlerInterceptor.java
│ │ │ │ │ ├── ChildEntityDefinition.java
│ │ │ │ │ ├── ChildEntity.java
│ │ │ │ │ ├── ChildForwardingCommandMessageHandlingMember.java
│ │ │ │ │ ├── CommandHandlerInterceptorHandlingMember.java
│ │ │ │ │ ├── CreationPolicyMember.java
│ │ │ │ │ ├── EntityModel.java
│ │ │ │ │ ├── ForwardingCommandMessageHandlingMember.java
│ │ │ │ │ ├── MethodCommandHandlerInterceptorDefinition.java
│ │ │ │ │ └── MethodCreationPolicyDefinition.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── GenericJpaRepository.java
│ │ │ │ ├── LockAwareAggregate.java
│ │ │ │ ├── LockingRepository.java
│ │ │ │ ├── MetaDataCommandTargetResolver.java
│ │ │ │ ├── NoArgumentConstructorCreationPolicyAggregateFactory.java
│ │ │ │ ├── Repository.java
│ │ │ │ ├── RepositoryProvider.java
│ │ │ │ ├── RepositorySpanFactory.java
│ │ │ │ ├── TargetAggregateIdentifier.java
│ │ │ │ ├── TargetAggregateVersion.java
│ │ │ │ └── VersionedAggregateIdentifier.java
│ │ │ └── saga
│ │ │ ├── AbstractResourceInjector.java
│ │ │ ├── AbstractSagaManager.java
│ │ │ ├── AnnotatedSaga.java
│ │ │ ├── AnnotatedSagaManager.java
│ │ │ ├── AssociationResolver.java
│ │ │ ├── AssociationValue.java
│ │ │ ├── AssociationValuesImpl.java
│ │ │ ├── AssociationValues.java
│ │ │ ├── DefaultSagaManagerSpanFactory.java
│ │ │ ├── EndSaga.java
│ │ │ ├── EndSagaMessageHandlerDefinition.java
│ │ │ ├── MetaDataAssociationResolver.java
│ │ │ ├── metamodel
│ │ │ │ ├── AnnotationSagaMetaModelFactory.java
│ │ │ │ ├── SagaMetaModelFactory.java
│ │ │ │ └── SagaModel.java
│ │ │ ├── PayloadAssociationResolver.java
│ │ │ ├── repository
│ │ │ │ ├── AnnotatedSagaRepository.java
│ │ │ │ ├── AssociationValueMap.java
│ │ │ │ ├── CachingSagaStore.java
│ │ │ │ ├── inmemory
│ │ │ │ │ └── InMemorySagaStore.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── GenericSagaSqlSchema.java
│ │ │ │ │ ├── HsqlSagaSqlSchema.java
│ │ │ │ │ ├── JdbcSagaStore.java
│ │ │ │ │ ├── Oracle11SagaSqlSchema.java
│ │ │ │ │ ├── PostgresSagaSqlSchema.java
│ │ │ │ │ ├── SagaSchema.java
│ │ │ │ │ └── SagaSqlSchema.java
│ │ │ │ ├── jpa
│ │ │ │ │ ├── AbstractSagaEntry.java
│ │ │ │ │ ├── AssociationValueEntry.java
│ │ │ │ │ ├── JpaSagaStore.java
│ │ │ │ │ ├── SagaEntry.java
│ │ │ │ │ └── SerializedSaga.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaSagaStore.java
│ │ │ │ ├── LockingSagaRepository.java
│ │ │ │ ├── NoResourceInjector.java
│ │ │ │ ├── SagaCreationException.java
│ │ │ │ └── SagaStore.java
│ │ │ ├── ResourceInjector.java
│ │ │ ├── SagaCreationPolicy.java
│ │ │ ├── SagaEventHandler.java
│ │ │ ├── SagaExecutionException.java
│ │ │ ├── SagaInitializationPolicy.java
│ │ │ ├── SagaInstantiationException.java
│ │ │ ├── Saga.java
│ │ │ ├── SagaLifecycle.java
│ │ │ ├── SagaManagerSpanFactory.java
│ │ │ ├── SagaMethodMessageHandlerDefinition.java
│ │ │ ├── SagaMethodMessageHandlingMember.java
│ │ │ ├── SagaRepository.java
│ │ │ ├── SagaScopeDescriptor.java
│ │ │ ├── SagaStorageException.java
│ │ │ ├── SimpleResourceInjector.java
│ │ │ └── StartSaga.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ ├── org.axonframework.messaging.annotation.HandlerEnhancerDefinition
│ │ └── org.axonframework.modelling.command.inspection.ChildEntityDefinition
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── modelling
│ │ ├── command
│ │ │ ├── AbstractRepositoryTest.java
│ │ │ ├── AggregateAnnotationCommandHandlerTest.java
│ │ │ ├── AggregateScopeDescriptorSerializationTest.java
│ │ │ ├── AnnotatedAggregateTest.java
│ │ │ ├── AnnotationCommandTargetResolverTest.java
│ │ │ ├── EntityEventForwardingModelInspectorTest.java
│ │ │ ├── GenericJpaRepositoryTest.java
│ │ │ ├── inspection
│ │ │ │ ├── AnnotatedAggregateAggregateMemberMetaModelFactoryTest.java
│ │ │ │ ├── AnnotatedAggregateMetaModelFactoryTest.java
│ │ │ │ ├── AnnotatedPolymorphicAggregateMetaModelFactoryTest.java
│ │ │ │ ├── AnnotatedRootMessageHandlingMemberAggregateMetaModelFactoryTest.java
│ │ │ │ ├── ChildForwardingCommandMessageHandlingMemberTest.java
│ │ │ │ └── legacyvalidation
│ │ │ │ └── AnnotatedAggregateMetaModelFactoryTest.java
│ │ │ ├── JpaAggregate.java
│ │ │ ├── LegacyGenericJpaRepositoryTest.java
│ │ │ ├── LockAwareAggregateTest.java
│ │ │ ├── LockingRepositoryTest.java
│ │ │ └── StubAggregate.java
│ │ ├── OnlyAcceptConstructorPropertiesAnnotation.java
│ │ ├── saga
│ │ │ ├── AnnotatedSagaManagerTest.java
│ │ │ ├── AnnotatedSagaTest.java
│ │ │ ├── AssociationValuesImplTest.java
│ │ │ ├── CustomEndingSagaEventHandler.java
│ │ │ ├── CustomStartingSagaEventHandler.java
│ │ │ ├── metamodel
│ │ │ │ └── AnnotationSagaMetaModelFactoryTest.java
│ │ │ ├── PayLoadAssociationResolverTest.java
│ │ │ ├── repository
│ │ │ │ ├── AnnotatedSagaRepositoryTest.java
│ │ │ │ ├── AssociationValueMapTest.java
│ │ │ │ ├── CachingSagaStoreTest.java
│ │ │ │ ├── concurrent
│ │ │ │ │ ├── AbstractTestSaga.java
│ │ │ │ │ ├── ConcurrentSaga.java
│ │ │ │ │ ├── CreateEvent.java
│ │ │ │ │ ├── DeleteEvent.java
│ │ │ │ │ ├── NonConcurrentSaga.java
│ │ │ │ │ └── UpdateEvent.java
│ │ │ │ ├── EhCache3SagaStoreTest.java
│ │ │ │ ├── EhCachingSagaStoreTest.java
│ │ │ │ ├── jdbc
│ │ │ │ │ ├── JdbcSagaStoreTest.java
│ │ │ │ │ └── SagaSchemaTest.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ └── JpaSagaStoreTest.java
│ │ │ │ ├── LockingSagaRepositoryTest.java
│ │ │ │ ├── StubSaga.java
│ │ │ │ └── WeakReferenceCachingSagaStoreTest.java
│ │ │ ├── SagaManagerTest.java
│ │ │ ├── SagaMethodMessageHandlerDefinitionTest.java
│ │ │ ├── SagaScopeDescriptorSerializationTest.java
│ │ │ └── SimpleResourceInjectorTest.java
│ │ └── utils
│ │ ├── ConcurrencyUtils.java
│ │ ├── EventTestUtils.java
│ │ ├── MockException.java
│ │ ├── StubDomainEvent.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ └── META-INF
│ └── persistence.xml
├── mvnw
├── mvnw.cmd
├── pom.xml
├── reactorless-test
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── reactorlesstest
│ │ └── ReactorlessStartup.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── reactorlesstest
│ │ └── ReactorlessStartupTest.java
│ └── resources
│ ├── application.properties
│ └── log4j2.properties
├── README.md
├── spring
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── org
│ │ └── axonframework
│ │ └── spring
│ │ ├── config
│ │ │ ├── AbstractAnnotationHandlerBeanPostProcessor.java
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationCommandHandlerBeanPostProcessor.java
│ │ │ │ ├── AnnotationQueryHandlerBeanPostProcessor.java
│ │ │ │ ├── HandlerDefinitionFactoryBean.java
│ │ │ │ ├── SpringBeanDependencyResolverFactory.java
│ │ │ │ ├── SpringBeanParameterResolverFactory.java
│ │ │ │ ├── SpringContextHandlerDefinitionBuilder.java
│ │ │ │ ├── SpringContextParameterResolverFactoryBuilder.java
│ │ │ │ ├── SpringHandlerDefinitionBean.java
│ │ │ │ ├── SpringHandlerEnhancerDefinitionBean.java
│ │ │ │ └── SpringParameterResolverFactoryBean.java
│ │ │ ├── AnnotationDriven.java
│ │ │ ├── AnnotationDrivenRegistrar.java
│ │ │ ├── ApplicationContextLookupParameterResolverFactory.java
│ │ │ ├── AxonConfiguration.java
│ │ │ ├── BeanHelper.java
│ │ │ ├── CommandHandlerSubscriber.java
│ │ │ ├── ConfigurerFactoryBean.java
│ │ │ ├── EventHandlerRegistrar.java
│ │ │ ├── MessageHandlerConfigurer.java
│ │ │ ├── MessageHandlerLookup.java
│ │ │ ├── NoBeanOfType.java
│ │ │ ├── QueryHandlerSubscriber.java
│ │ │ ├── RepositoryFactoryBean.java
│ │ │ ├── SpringAggregateConfigurer.java
│ │ │ ├── SpringAggregateLookup.java
│ │ │ ├── SpringAxonAutoConfigurer.java
│ │ │ ├── SpringAxonConfiguration.java
│ │ │ ├── SpringConfigurer.java
│ │ │ ├── SpringSagaConfigurer.java
│ │ │ ├── SpringSagaLookup.java
│ │ │ └── TransactionManagerFactoryBean.java
│ │ ├── event
│ │ │ └── AxonStartedEvent.java
│ │ ├── eventhandling
│ │ │ └── scheduling
│ │ │ ├── java
│ │ │ │ └── SimpleEventSchedulerFactoryBean.java
│ │ │ └── quartz
│ │ │ └── QuartzEventSchedulerFactoryBean.java
│ │ ├── eventsourcing
│ │ │ ├── SpringAggregateSnapshotterFactoryBean.java
│ │ │ ├── SpringAggregateSnapshotter.java
│ │ │ └── SpringPrototypeAggregateFactory.java
│ │ ├── jdbc
│ │ │ └── SpringDataSourceConnectionProvider.java
│ │ ├── messaging
│ │ │ ├── ApplicationContextEventPublisher.java
│ │ │ ├── DefaultEventMessageConverter.java
│ │ │ ├── EventMessageConverter.java
│ │ │ ├── InboundEventMessageChannelAdapter.java
│ │ │ ├── OutboundEventMessageChannelAdapter.java
│ │ │ ├── package-info.java
│ │ │ └── unitofwork
│ │ │ └── SpringTransactionManager.java
│ │ ├── modelling
│ │ │ └── SpringRepositoryFactoryBean.java
│ │ ├── saga
│ │ │ └── SpringResourceInjector.java
│ │ ├── SpringUtils.java
│ │ └── stereotype
│ │ ├── Aggregate.java
│ │ └── Saga.java
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── integrationtests
│ │ │ └── deadline
│ │ │ └── AbstractDeadlineManagerTestSuite.java
│ │ └── spring
│ │ ├── AggregatePolymorphismTest.java
│ │ ├── config
│ │ │ ├── annotation
│ │ │ │ ├── AnnotationCommandHandlerBeanPostProcessorTest.java
│ │ │ │ ├── AnnotationQueryHandlerBeanPostProcessorTest.java
│ │ │ │ ├── SomeCommandHandlerInterface.java
│ │ │ │ ├── SomeMeaninglessInterface.java
│ │ │ │ ├── SpringBeanResolverFactoryTest.java
│ │ │ │ ├── StubAggregate.java
│ │ │ │ ├── TransactionalCommandHandler.java
│ │ │ │ ├── TransactionalCommandHandlerSuperClass.java
│ │ │ │ └── TransactionalListener.java
│ │ │ ├── AnnotationDrivenConfigurationTest_CustomValues.java
│ │ │ ├── AnnotationDrivenConfigurationTest_DefaultValues.java
│ │ │ ├── AutoWiredEventSourcedAggregateTest.java
│ │ │ ├── AutoWiredStateStoredAggregateTest.java
│ │ │ ├── BeanHelperTest.java
│ │ │ ├── EventHandlerRegistrarTest.java
│ │ │ ├── EventProcessingModuleConfigTest.java
│ │ │ ├── EventProcessingModuleWithInterceptorsTest.java
│ │ │ ├── SpringAxonAutoConfigurerTest_CustomEventHandlerConfiguration.java
│ │ │ ├── SpringAxonAutoConfigurerTest.java
│ │ │ ├── SpringAxonConfigurationTest.java
│ │ │ ├── SpringConfigurerTest.java
│ │ │ ├── StubDomainEvent.java
│ │ │ └── UpcasterOrderingTest.java
│ │ ├── eventhandling
│ │ │ ├── deadletter
│ │ │ │ └── SpringJpaDeadLetteringIntegrationTest.java
│ │ │ ├── scheduling
│ │ │ │ ├── java
│ │ │ │ │ └── ResultStoringScheduledExecutorService.java
│ │ │ │ ├── MySagaExpiredEvent.java
│ │ │ │ ├── quartz
│ │ │ │ │ └── QuartzTableMaker.java
│ │ │ │ ├── SimpleTimingSaga.java
│ │ │ │ └── StartingEvent.java
│ │ │ └── tokenstore
│ │ │ └── jpa
│ │ │ └── JpaTokenStoreTest.java
│ │ ├── eventsourcing
│ │ │ ├── benchmark
│ │ │ │ └── JpaStorageEngineInsertionReadOrderTest.java
│ │ │ ├── context
│ │ │ │ └── SpringWiredAggregate.java
│ │ │ ├── SpringAggregateSnapshotterFactoryBeanTest.java
│ │ │ └── SpringPrototypeAggregateFactoryTest.java
│ │ ├── jdbc
│ │ │ └── SpringDataSourceConnectionProviderTest.java
│ │ ├── messaging
│ │ │ ├── ApplicationContextEventPublisherTest.java
│ │ │ ├── DefaultEventMessageConverterTest.java
│ │ │ ├── InboundEventMessageChannelAdapterTest.java
│ │ │ ├── OutboundEventMessageChannelAdapterTest.java
│ │ │ └── unitofwork
│ │ │ └── SpringTransactionManagerTest.java
│ │ ├── modeling
│ │ │ └── command
│ │ │ ├── GenericJpaRepositoryIntegrationTest.java
│ │ │ └── JpaAggregate.java
│ │ ├── saga
│ │ │ └── SpringResourceInjectorTest.java
│ │ ├── trial
│ │ │ ├── MyOtherSaga.java
│ │ │ └── MySaga.java
│ │ └── utils
│ │ ├── MysqlTestContainerExtension.java
│ │ └── StubDomainEvent.java
│ └── resources
│ ├── hsqldb.database.properties
│ ├── log4j2.properties
│ ├── META-INF
│ │ └── persistence.xml
│ ├── quartz.test.properties
│ ├── tables_hsqldb.sql
│ └── tables_mysql_innodb.sql
├── spring-boot3-dummy
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── org
│ └── springframework
│ └── boot
│ ├── autoconfigure
│ │ └── service
│ │ └── connection
│ │ └── ConnectionDetails.java
│ ├── docker
│ │ └── compose
│ │ ├── core
│ │ │ ├── ConnectionPorts.java
│ │ │ ├── ImageReference.java
│ │ │ └── RunningService.java
│ │ └── service
│ │ └── connection
│ │ ├── DockerComposeConnectionDetailsFactory.java
│ │ └── DockerComposeConnectionSource.java
│ └── testcontainers
│ └── service
│ └── connection
│ ├── ContainerConnectionDetailsFactory.java
│ └── ContainerConnectionSource.java
├── spring-boot-3-integrationtests
│ ├── pom.xml
│ ├── src
│ │ └── test
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ ├── eventhandling
│ │ │ │ └── deadletter
│ │ │ │ └── DeadLetteringEventIntegrationTest.java
│ │ │ ├── integrationtests
│ │ │ │ └── eventsourcing
│ │ │ │ └── eventstore
│ │ │ │ ├── EmbeddedEventStoreTest.java
│ │ │ │ └── jpa
│ │ │ │ └── JpaEmbeddedEventStoreTest.java
│ │ │ ├── spring
│ │ │ │ ├── eventhandling
│ │ │ │ │ ├── deadletter
│ │ │ │ │ │ └── SpringJpaDeadLetteringIntegrationTest.java
│ │ │ │ │ └── tokenstore
│ │ │ │ │ └── jpa
│ │ │ │ │ └── JpaTokenStoreTest.java
│ │ │ │ ├── eventsourcing
│ │ │ │ │ └── benchmark
│ │ │ │ │ └── JpaStorageEngineInsertionReadOrderTest.java
│ │ │ │ └── modeling
│ │ │ │ └── command
│ │ │ │ ├── GenericJpaRepositoryIntegrationTest.java
│ │ │ │ └── JpaAggregate.java
│ │ │ └── springboot
│ │ │ ├── autoconfig
│ │ │ │ ├── AggregatePolymorphismAutoConfigurationTest.java
│ │ │ │ ├── AggregateStereotypeAutoConfigurationTest.java
│ │ │ │ └── context
│ │ │ │ ├── Animal.java
│ │ │ │ ├── AnimalRenamedEvent.java
│ │ │ │ ├── CatCreatedEvent.java
│ │ │ │ ├── Cat.java
│ │ │ │ ├── CreateCatCommand.java
│ │ │ │ ├── CreateDogCommand.java
│ │ │ │ ├── DogCreatedEvent.java
│ │ │ │ ├── Dog.java
│ │ │ │ └── RenameAnimalCommand.java
│ │ │ ├── AxonAutoConfigurationWithEventSerializerPropertiesTest.java
│ │ │ ├── AxonAutoConfigurationWithEventSerializerTest.java
│ │ │ ├── AxonAutoConfigurationWithHibernateTest.java
│ │ │ ├── JpaAutoConfigurationLazySagaStoreTest.java
│ │ │ ├── JpaAutoConfigurationTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithoutAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithSnapshottingTest.java
│ │ │ ├── RepositoryWiringTest.java
│ │ │ ├── service
│ │ │ │ └── connection
│ │ │ │ ├── SpringBootApplication.java
│ │ │ │ ├── SpringBootDockerComposeIntegrationTest.java
│ │ │ │ └── SpringBootTestContainerIntegrationTest.java
│ │ │ ├── TrackingEventProcessorIntegrationTest.java
│ │ │ ├── util
│ │ │ │ └── XStreamSecurityTypeUtilityTest.java
│ │ │ └── utils
│ │ │ ├── ControlChannelStub.java
│ │ │ ├── GrpcServerStub.java
│ │ │ └── TcpUtils.java
│ │ └── resources
│ │ ├── application.serializertest.properties
│ │ ├── hsqldb.database.properties
│ │ ├── log4j2.properties
│ │ ├── logback-test.xml
│ │ └── META-INF
│ │ └── persistence.xml
│ └── test-docker-compose.yml
├── spring-boot-autoconfigure
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ ├── actuator
│ │ │ │ ├── axonserver
│ │ │ │ │ ├── AxonServerHealthIndicator.java
│ │ │ │ │ └── AxonServerStatusAggregator.java
│ │ │ │ └── HealthStatus.java
│ │ │ └── springboot
│ │ │ ├── autoconfig
│ │ │ │ ├── AxonAutoConfiguration.java
│ │ │ │ ├── AxonDbSchedulerAutoConfiguration.java
│ │ │ │ ├── AxonJobRunrAutoConfiguration.java
│ │ │ │ ├── AxonServerActuatorAutoConfiguration.java
│ │ │ │ ├── AxonServerAutoConfiguration.java
│ │ │ │ ├── AxonServerBusAutoConfiguration.java
│ │ │ │ ├── AxonTracingAutoConfiguration.java
│ │ │ │ ├── CBORMapperAutoConfiguration.java
│ │ │ │ ├── EventProcessingAutoConfiguration.java
│ │ │ │ ├── InfraConfiguration.java
│ │ │ │ ├── JdbcAutoConfiguration.java
│ │ │ │ ├── JpaAutoConfiguration.java
│ │ │ │ ├── JpaEventStoreAutoConfiguration.java
│ │ │ │ ├── legacyjpa
│ │ │ │ │ ├── JpaJavaxAutoConfiguration.java
│ │ │ │ │ └── JpaJavaxEventStoreAutoConfiguration.java
│ │ │ │ ├── MetricsAutoConfiguration.java
│ │ │ │ ├── MicrometerMetricsAutoConfiguration.java
│ │ │ │ ├── NoOpTransactionAutoConfiguration.java
│ │ │ │ ├── ObjectMapperAutoConfiguration.java
│ │ │ │ ├── OpenTelemetryAutoConfiguration.java
│ │ │ │ ├── TransactionAutoConfiguration.java
│ │ │ │ └── XStreamAutoConfiguration.java
│ │ │ ├── DistributedCommandBusProperties.java
│ │ │ ├── EventProcessorProperties.java
│ │ │ ├── MetricsProperties.java
│ │ │ ├── SerializerProperties.java
│ │ │ ├── service
│ │ │ │ └── connection
│ │ │ │ ├── AxonServerConnectionDetails.java
│ │ │ │ ├── AxonServerDockerComposeConnectionDetailsFactory.java
│ │ │ │ └── AxonServerTestContainerConnectionDetailsFactory.java
│ │ │ ├── TagsConfigurationProperties.java
│ │ │ ├── TokenStoreProperties.java
│ │ │ ├── TracingProperties.java
│ │ │ └── util
│ │ │ ├── AbstractQualifiedBeanCondition.java
│ │ │ ├── ConditionalOnMissingQualifiedBean.java
│ │ │ ├── ConditionalOnQualifiedBean.java
│ │ │ ├── DeadLetterQueueProviderConfigurerModule.java
│ │ │ ├── DefaultEntityRegistrar.java
│ │ │ ├── jpa
│ │ │ │ └── ContainerManagedEntityManagerProvider.java
│ │ │ ├── legacyjpa
│ │ │ │ └── ContainerManagedEntityManagerProvider.java
│ │ │ ├── OnMissingQualifiedBeanCondition.java
│ │ │ ├── OnQualifiedBeanCondition.java
│ │ │ ├── RegisterDefaultEntities.java
│ │ │ └── XStreamSecurityTypeUtility.java
│ │ └── resources
│ │ └── META-INF
│ │ ├── spring
│ │ │ └── org.springframework.boot.autoconfigure.AutoConfiguration.imports
│ │ └── spring.factories
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ ├── actuator
│ │ │ └── axonserver
│ │ │ └── AxonServerHealthIndicatorTest.java
│ │ └── springboot
│ │ ├── autoconfig
│ │ │ ├── AxonServerActuatorAutoConfigurationTest.java
│ │ │ ├── AxonServerAutoConfigurationLoadFactorTest.java
│ │ │ ├── AxonServerAutoConfigurationTest.java
│ │ │ ├── CBORMapperAutoConfigurationTest.java
│ │ │ ├── InfraConfigurationTest.java
│ │ │ ├── LoadBalancingStrategyAutoConfigurationTest.java
│ │ │ ├── ObjectMapperAutoConfigurationTest.java
│ │ │ └── XStreamAutoConfigurationTest.java
│ │ ├── AxonAutoConfigurationTest.java
│ │ ├── AxonAutoConfigurationWithDisruptorTest.java
│ │ ├── AxonAutoConfigurationWithMetricsTest.java
│ │ ├── AxonAutoConfigurationWithMetricsWithoutConfigurerTest.java
│ │ ├── AxonAutoConfigurationWithMicrometerMetricsTest.java
│ │ ├── AxonAutoConfigurationWithMicrometerMetricsWithoutConfigurerTest.java
│ │ ├── AxonAutoConfigurationWithOnlyEventSerializerTest.java
│ │ ├── AxonAutoConfigurationWithOpenTelemetryTest.java
│ │ ├── AxonAutoConfigurationWithoutObjectMapperTest.java
│ │ ├── AxonAutoConfigurationWithTagsTest.java
│ │ ├── AxonAutoConfigurationWithTracingTest.java
│ │ ├── AxonHandlerConfigurationTest.java
│ │ ├── DbSchedulerAutoConfigurationTest.java
│ │ ├── EventProcessorConfigurationTest.java
│ │ ├── HandlerEnhancerDefinitionConfigurationTest.java
│ │ ├── JdbcAutoConfigurationTest.java
│ │ ├── JobRunrAutoConfigurationTest.java
│ │ ├── legacyjpa
│ │ │ ├── JpaEventStoreAutoConfigurationWithAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithoutAxonServerTest.java
│ │ │ ├── JpaEventStoreAutoConfigurationWithSnapshottingTest.java
│ │ │ ├── JpaJavaxAutoConfigurationLazySagaStoreTest.java
│ │ │ └── JpaJavaxAutoConfigurationTest.java
│ │ ├── PooledStreamingEventProcessorIntegrationTest.java
│ │ ├── RepositoryWiringTest.java
│ │ ├── SagaCustomizeIntegrationTest.java
│ │ └── utils
│ │ ├── AssertUtils.java
│ │ ├── ControlChannelStub.java
│ │ ├── GrpcServerStub.java
│ │ ├── TcpUtils.java
│ │ └── TestSerializer.java
│ └── resources
│ ├── application.serializertest.properties
│ ├── application.serializer-without-jackson.test.properties
│ ├── log4j2.properties
│ ├── test.jgroups.application.properties
│ ├── test.metrics.application.properties
│ └── test.springcloud.application.properties
├── spring-boot-starter
│ └── pom.xml
├── test
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── org
│ │ │ └── axonframework
│ │ │ └── test
│ │ │ ├── aggregate
│ │ │ │ ├── AggregateTestFixture.java
│ │ │ │ ├── FixtureConfiguration.java
│ │ │ │ ├── Reporter.java
│ │ │ │ ├── ResultValidatorImpl.java
│ │ │ │ ├── ResultValidator.java
│ │ │ │ ├── StubAggregateLifecycleExtension.java
│ │ │ │ ├── StubAggregateLifecycle.java
│ │ │ │ ├── StubAggregateLifecycleRule.java
│ │ │ │ └── TestExecutor.java
│ │ │ ├── AxonAssertionError.java
│ │ │ ├── deadline
│ │ │ │ ├── DeadlineConsumer.java
│ │ │ │ ├── DeadlineManagerValidator.java
│ │ │ │ ├── ScheduledDeadlineInfo.java
│ │ │ │ └── StubDeadlineManager.java
│ │ │ ├── eventscheduler
│ │ │ │ ├── EventConsumer.java
│ │ │ │ ├── EventSchedulerValidator.java
│ │ │ │ ├── ScheduledItem.java
│ │ │ │ ├── StubEventScheduler.java
│ │ │ │ └── StubScheduleToken.java
│ │ │ ├── FixtureExecutionException.java
│ │ │ ├── FixtureResourceParameterResolverFactory.java
│ │ │ ├── matchers
│ │ │ │ ├── AllFieldsFilter.java
│ │ │ │ ├── DeepEqualsMatcher.java
│ │ │ │ ├── EmptyCollectionMatcher.java
│ │ │ │ ├── EqualFieldsMatcher.java
│ │ │ │ ├── EqualsMatcher.java
│ │ │ │ ├── ExactClassMatcher.java
│ │ │ │ ├── ExactSequenceMatcher.java
│ │ │ │ ├── FieldFilter.java
│ │ │ │ ├── IgnoreField.java
│ │ │ │ ├── ListMatcher.java
│ │ │ │ ├── ListWithAllOfMatcher.java
│ │ │ │ ├── ListWithAnyOfMatcher.java
│ │ │ │ ├── MapEntryMatcher.java
│ │ │ │ ├── MatchAllFieldFilter.java
│ │ │ │ ├── MatcherExecutionException.java
│ │ │ │ ├── Matchers.java
│ │ │ │ ├── NonStaticFieldsFilter.java
│ │ │ │ ├── NonTransientFieldsFilter.java
│ │ │ │ ├── NullOrVoidMatcher.java
│ │ │ │ ├── PayloadMatcher.java
│ │ │ │ ├── PayloadsMatcher.java
│ │ │ │ ├── PredicateMatcher.java
│ │ │ │ └── SequenceMatcher.java
│ │ │ ├── package-info.java
│ │ │ ├── saga
│ │ │ │ ├── CommandValidator.java
│ │ │ │ ├── ContinuedGivenState.java
│ │ │ │ ├── DescriptionUtils.java
│ │ │ │ ├── EventValidator.java
│ │ │ │ ├── FixtureConfiguration.java
│ │ │ │ ├── FixtureExecutionResultImpl.java
│ │ │ │ ├── FixtureExecutionResult.java
│ │ │ │ ├── GivenAggregateEventPublisher.java
│ │ │ │ ├── RecordingListenerInvocationErrorHandler.java
│ │ │ │ ├── RepositoryContentValidator.java
│ │ │ │ ├── SagaTestFixture.java
│ │ │ │ ├── WhenAggregateEventPublisher.java
│ │ │ │ └── WhenState.java
│ │ │ ├── server
│ │ │ │ ├── AxonServerContainer.java
│ │ │ │ ├── AxonServerContainerUtils.java
│ │ │ │ ├── AxonServerEEContainer.java
│ │ │ │ └── AxonServerSEContainer.java
│ │ │ └── utils
│ │ │ ├── AutowiredResourceInjector.java
│ │ │ ├── CallbackBehavior.java
│ │ │ ├── DefaultCallbackBehavior.java
│ │ │ ├── package-info.java
│ │ │ └── RecordingCommandBus.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ └── org.axonframework.messaging.annotation.ParameterResolverFactory
│ └── test
│ ├── java
│ │ └── org
│ │ └── axonframework
│ │ └── test
│ │ ├── aggregate
│ │ │ ├── AnnotatedAggregateInterface.java
│ │ │ ├── AnnotatedAggregate.java
│ │ │ ├── CreateAggregateCommand.java
│ │ │ ├── DeleteCommand.java
│ │ │ ├── FixtureRepositoryRegistrationTest.java
│ │ │ ├── FixtureTest_Annotated.java
│ │ │ ├── FixtureTest_CommandInterceptors.java
│ │ │ ├── FixtureTest_CreationPolicy.java
│ │ │ ├── FixtureTest_Deadlines.java
│ │ │ ├── FixtureTest_ExceptionHandling.java
│ │ │ ├── FixtureTest_Generic.java
│ │ │ ├── FixtureTest_Hierarchy.java
│ │ │ ├── FixtureTest_MarkDeleted.java
│ │ │ ├── FixtureTest_MatcherParams.java
│ │ │ ├── FixtureTest_Polymorphism.java
│ │ │ ├── FixtureTest_RegisteringMethodEnhancements.java
│ │ │ ├── FixtureTest_RegularParams.java
│ │ │ ├── FixtureTest_Resources.java
│ │ │ ├── FixtureTest_ScopeDescriptor.java
│ │ │ ├── FixtureTest_SpawningNewAggregate.java
│ │ │ ├── FixtureTest_StateStorage.java
│ │ │ ├── FixtureWhenPhaseAggregateInvocationTest.java
│ │ │ ├── HardToCreateResource.java
│ │ │ ├── IllegalStateChangeCommand.java
│ │ │ ├── MyAggregateDeletedEvent.java
│ │ │ ├── MyApplicationEvent.java
│ │ │ ├── MyCommandHandler.java
│ │ │ ├── MyEntity.java
│ │ │ ├── MyEvent.java
│ │ │ ├── MyOtherEvent.java
│ │ │ ├── ParameterResolvedEvent.java
│ │ │ ├── PublishEventCommand.java
│ │ │ ├── ResolveParameterCommand.java
│ │ │ ├── ResultValidatorImplTest.java
│ │ │ ├── StandardAggregate.java
│ │ │ ├── StrangeCommand.java
│ │ │ ├── StrangeCommandReceivedException.java
│ │ │ ├── StubAggregateLifecycleExtensionTest.java
│ │ │ ├── StubAggregateLifecycleRuleTest.java
│ │ │ ├── StubAggregateLifecycleTest.java
│ │ │ ├── TestCommand.java
│ │ │ └── TestEvent.java
│ │ ├── deadline
│ │ │ └── StubDeadlineManagerTest.java
│ │ ├── eventscheduler
│ │ │ └── StubEventSchedulerTest.java
│ │ ├── matchers
│ │ │ ├── DeepEqualsMatcherTest.java
│ │ │ ├── EqualFieldsMatcherTest.java
│ │ │ ├── ExactClassMatcherTest.java
│ │ │ ├── ExactSequenceOfEventsMatcherTest.java
│ │ │ ├── IgnoreFieldTest.java
│ │ │ ├── ListWithAllOfMatcherTest.java
│ │ │ ├── ListWithAnyOfMatcherTest.java
│ │ │ ├── MapEntryMatcherTest.java
│ │ │ ├── MatchAllFieldFilterTest.java
│ │ │ ├── NonStaticFieldsFilterTest.java
│ │ │ ├── NonTransientFieldsFilterTest.java
│ │ │ ├── NullOrVoidMatcherTest.java
│ │ │ ├── SequenceOfEventsMatcherTest.java
│ │ │ └── StubEvent.java
│ │ ├── saga
│ │ │ ├── AnnotatedSagaTest.java
│ │ │ ├── CommandValidatorTest.java
│ │ │ ├── EventValidatorTest.java
│ │ │ ├── FixtureExecutionResultImplTest.java
│ │ │ ├── FixtureMessageHandlerInterceptorTest.java
│ │ │ ├── FixtureTest_Deadlines.java
│ │ │ ├── FixtureTest_RegisteringMethodEnhancements.java
│ │ │ ├── FixtureTest_RegisteringSagaEnhancements.java
│ │ │ ├── FixtureTest_ScheduledEvents.java
│ │ │ ├── FixtureTest_ScopeDescriptor.java
│ │ │ ├── ForceTriggerSagaStartEvent.java
│ │ │ ├── NonTransientResource.java
│ │ │ ├── ParameterResolvedEvent.java
│ │ │ ├── RecordingListenerInvocationErrorHandlerTest.java
│ │ │ ├── ResetTriggerEvent.java
│ │ │ ├── ResolveParameterCommand.java
│ │ │ ├── SagaWasTriggeredEvent.java
│ │ │ ├── StubGateway.java
│ │ │ ├── StubSaga.java
│ │ │ ├── TimerTriggeredEvent.java
│ │ │ ├── TriggerExceptionWhileHandlingEvent.java
│ │ │ ├── TriggerExistingSagaEvent.java
│ │ │ ├── TriggerSagaEndEvent.java
│ │ │ └── TriggerSagaStartEvent.java
│ │ ├── server
│ │ │ ├── AxonServerContainerTest.java
│ │ │ ├── AxonServerEEContainerTest.java
│ │ │ └── AxonServerSEContainerTest.java
│ │ └── utils
│ │ └── RecordingCommandBusTest.java
│ └── resources
│ └── log4j2.properties
└── tracing-opentelemetry
├── pom.xml
└── src
├── main
│ └── java
│ └── org
│ └── axonframework
│ └── tracing
│ └── opentelemetry
│ ├── MetadataContextGetter.java
│ ├── MetadataContextSetter.java
│ ├── OpenTelemetrySpanFactory.java
│ └── OpenTelemetrySpan.java
└── test
└── java
└── org
└── axonframework
└── tracing
└── opentelemetry
├── MetadataContextGetterTest.java
├── MetadataContextSetterTest.java
├── OpenTelemetrySpanFactoryTest.java
└── OpenTelemetrySpanTest.java
674 directories, 2089 files
标签：
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论