Modifier and Type | Method and Description |
---|---|
SequencingPolicy<EventMessage<?>> |
PersistentStreamSequencingPolicyProvider.apply(Configuration configuration) |
PersistentStreamMessageSource |
PersistentStreamMessageSourceFactory.build(String name,
io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
ScheduledExecutorService scheduler,
int batchSize,
String context,
Configuration configuration)
Builds a new instance of
PersistentStreamMessageSource with the specified parameters. |
SubscribableMessageSource<EventMessage<?>> |
PersistentStreamMessageSourceDefinition.create(Configuration configuration) |
void |
EventProcessorInfoConfiguration.initialize(Configuration config) |
Constructor and Description |
---|
PersistentStreamConnection(String streamId,
Configuration configuration,
io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
ScheduledExecutorService scheduler,
int batchSize)
Instantiates a connection for a persistent stream.
|
PersistentStreamConnection(String streamId,
Configuration configuration,
io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
ScheduledExecutorService scheduler,
int batchSize,
String defaultContext)
Instantiates a connection for a persistent stream.
|
PersistentStreamMessageSource(String name,
Configuration configuration,
io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
ScheduledExecutorService scheduler,
int batchSize)
Instantiates a
PersistentStreamMessageSource . |
PersistentStreamMessageSource(String name,
Configuration configuration,
io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
ScheduledExecutorService scheduler,
int batchSize,
String context)
Instantiates a
PersistentStreamMessageSource . |
Modifier and Type | Method and Description |
---|---|
void |
HeartbeatConfiguration.initialize(Configuration config)
Deprecated.
Initializes the
GrpcHeartbeatSource component, needed to send heartbeats to AxonServer, any time the
client will receive an heartbeat from the server. |
Constructor and Description |
---|
HeartbeatConfiguration(Function<Configuration,AxonServerConnectionManager> connectionManagerSupplier,
Function<Configuration,AxonServerConfiguration> axonServerConfigurationSupplier)
Deprecated.
Creates a
HeartbeatConfiguration using the provided functions to retrieve the AxonServerConnectionManager and AxonServerConfiguration . |
HeartbeatConfiguration(Function<Configuration,AxonServerConnectionManager> connectionManagerSupplier,
Function<Configuration,AxonServerConfiguration> axonServerConfigurationSupplier)
Deprecated.
Creates a
HeartbeatConfiguration using the provided functions to retrieve the AxonServerConnectionManager and AxonServerConfiguration . |
Modifier and Type | Field and Description |
---|---|
protected Configuration |
EventProcessingModule.configuration |
Modifier and Type | Field and Description |
---|---|
protected Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> |
EventProcessingModule.deadLetterQueueProvider |
protected List<BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>>> |
EventProcessingModule.defaultHandlerInterceptors |
protected Map<String,List<Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>>>> |
EventProcessingModule.handlerInterceptorsBuilders |
Modifier and Type | Method and Description |
---|---|
Configuration |
DefaultConfigurer.buildConfiguration() |
Configuration |
Configurer.buildConfiguration()
Returns the completely initialized Configuration built using this configurer.
|
protected Configuration |
DefaultConfigurer.getConfig()
Returns the current Configuration object being built by this Configurer, without initializing it.
|
default Configuration |
Configurer.start()
Builds the configuration and starts it immediately.
|
Modifier and Type | Method and Description |
---|---|
EventProcessor |
EventProcessingConfigurer.EventProcessorBuilder.build(String name,
Configuration configuration,
EventHandlerInvoker eventHandlerInvoker)
|
SubscribableMessageSource<M> |
SubscribableMessageSourceDefinition.create(Configuration configuration)
Creates a
SubscribableMessageSource based on this definition and the provided configuration. |
MessageMonitor<Message<?>> |
MessageMonitorFactory.create(Configuration configuration,
Class<?> componentType,
String componentName)
Function to create a Message Monitor based on the given configuration, component type and component name.
|
protected CommandBus |
DefaultConfigurer.defaultCommandBus(Configuration config)
Provides the default CommandBus implementation.
|
protected CommandBusSpanFactory |
DefaultConfigurer.defaultCommandBusSpanFactory(Configuration config)
Returns the default
CommandBusSpanFactory , or a DefaultCommandBusSpanFactory backed by the
configured SpanFactory if none it set. |
protected CommandGateway |
DefaultConfigurer.defaultCommandGateway(Configuration config)
Returns a
DefaultCommandGateway that will use the configuration's CommandBus to dispatch
commands. |
protected <T> Optional<T> |
DefaultConfigurer.defaultComponent(Class<T> type,
Configuration configuration)
Method returning a default component to use for given
type for given configuration , or an empty
Optional if no default can be provided. |
protected DeadlineManager |
DefaultConfigurer.defaultDeadlineManager(Configuration config)
Provides the default
DeadlineManager implementation. |
protected DeadlineManagerSpanFactory |
DefaultConfigurer.defaultDeadlineManagerSpanFactory(Configuration config)
Returns the default
DeadlineManagerSpanFactory , or a
DefaultDeadlineManagerSpanFactory backed by the configured SpanFactory if none it set. |
protected EventBus |
DefaultConfigurer.defaultEventBus(Configuration config)
Provides the default EventBus implementation.
|
protected EventBusSpanFactory |
DefaultConfigurer.defaultEventBusSpanFactory(Configuration config)
Returns the default
EventBusSpanFactory , or a DefaultEventBusSpanFactory backed by the configured
SpanFactory if none it set. |
protected EventGateway |
DefaultConfigurer.defaultEventGateway(Configuration config)
Returns a
DefaultEventGateway that will use the configuration's EventBus to publish events. |
protected EventProcessorSpanFactory |
DefaultConfigurer.defaultEventProcessorSpanFactory(Configuration config)
Returns the default
EventProcessorSpanFactory , or a
DefaultEventProcessorSpanFactory backed by the configured SpanFactory if none it set. |
protected ParameterResolverFactory |
DefaultConfigurer.defaultParameterResolverFactory(Configuration config)
Provides the default ParameterResolverFactory.
|
protected QueryBus |
DefaultConfigurer.defaultQueryBus(Configuration config)
Provides the default QueryBus implementations.
|
protected QueryBusSpanFactory |
DefaultConfigurer.defaultQueryBusSpanFactory(Configuration config)
Returns the default
QueryBusSpanFactory , or a DefaultQueryBusSpanFactory backed by the configured
SpanFactory if none it set. |
protected QueryGateway |
DefaultConfigurer.defaultQueryGateway(Configuration config)
Returns a
DefaultQueryGateway that will use the configuration's QueryBus to dispatch queries. |
protected QueryUpdateEmitter |
DefaultConfigurer.defaultQueryUpdateEmitter(Configuration config)
Provides the default QueryUpdateEmitter implementation.
|
protected QueryUpdateEmitterSpanFactory |
DefaultConfigurer.defaultQueryUpdateEmitterSpanFactory(Configuration config)
Returns the default
QueryUpdateEmitterSpanFactory , or a DefaultQueryUpdateEmitterSpanFactory
backed by the configured SpanFactory if none it set. |
protected RepositorySpanFactory |
DefaultConfigurer.defaultRepositorySpanFactory(Configuration config)
Returns the default
RepositorySpanFactory , or a
DefaultRepositorySpanFactory backed by the configured SpanFactory if none it set. |
protected ResourceInjector |
DefaultConfigurer.defaultResourceInjector(Configuration config)
Returns a
ConfigurationResourceInjector that injects resources defined in the given
config Configuration . |
protected SagaManagerSpanFactory |
DefaultConfigurer.defaultSagaManagerSpanFactory(Configuration config)
Returns the default
SagaManagerSpanFactory , or a
DefaultSagaManagerSpanFactory backed by the configured SpanFactory if none it set. |
protected ScopeAwareProvider |
DefaultConfigurer.defaultScopeAwareProvider(Configuration config)
|
protected Serializer |
DefaultConfigurer.defaultSerializer(Configuration config)
Provides the default Serializer implementation.
|
protected Snapshotter |
DefaultConfigurer.defaultSnapshotter(Configuration config)
Provides the default
Snapshotter implementation, defaulting to a AggregateSnapshotter . |
protected SnapshotterSpanFactory |
DefaultConfigurer.defaultSnapshotterSpanFactory(Configuration config)
Returns the default
SnapshotterSpanFactory , or a DefaultSnapshotterSpanFactory backed by the
configured SpanFactory if none it set. |
protected SpanFactory |
DefaultConfigurer.defaultSpanFactory(Configuration config)
Returns the default
SpanFactory , or a NoOpSpanFactory if none it set. |
protected EventUpcasterChain |
DefaultConfigurer.defaultUpcasterChain(Configuration config)
Provides the default
EventUpcasterChain implementation, looping through all
registered EventUpcasters to collect them for a
fresh EventUpcasterChain . |
SagaConfiguration<T> |
SagaConfigurer.initialize(Configuration configuration)
Initializes Saga Configuration by using the main
Configuration . |
void |
ModuleConfiguration.initialize(Configuration config)
Initialize the module configuration using the given global
config . |
void |
EventProcessingModule.initialize(Configuration configuration) |
void |
AxonIQConsoleModule.initialize(Configuration config) |
void |
AggregateConfigurer.initialize(Configuration config) |
protected EventProcessor |
EventProcessingModule.pooledStreamingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
Configuration config,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)
Default
PooledStreamingEventProcessor configuration based on this configure module. |
static void |
LifecycleHandlerInspector.registerLifecycleHandlers(Configuration configuration,
Object component)
Register any lifecycle handlers found on given
component with given configuration . |
Modifier and Type | Method and Description |
---|---|
AggregateConfigurer<A> |
AggregateConfigurer.configureAggregateFactory(Function<Configuration,AggregateFactory<A>> aggregateFactoryBuilder)
Defines the factory to use to create new Aggregates instances of the type under configuration.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureCache(Function<Configuration,Cache> cache)
Configures the Cache to use for the repository created for this Aggregate type.
|
default Configurer |
Configurer.configureCommandBus(Function<Configuration,CommandBus> commandBusBuilder)
Configures the given Command Bus to use in this configuration.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureCommandHandler(Function<Configuration,AggregateAnnotationCommandHandler<A>> aggregateCommandHandlerBuilder)
Defines the AggregateAnnotationCommandHandler instance to use.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureCommandTargetResolver(Function<Configuration,CommandTargetResolver> commandTargetResolverBuilder)
Defines the CommandTargetResolver to use for the Aggregate type under configuration.
|
Configurer |
DefaultConfigurer.configureCorrelationDataProviders(Function<Configuration,List<CorrelationDataProvider>> correlationDataProviderBuilder) |
Configurer |
Configurer.configureCorrelationDataProviders(Function<Configuration,List<CorrelationDataProvider>> correlationDataProviderBuilder)
Configures the CorrelationDataProviders that Message processing components should use to attach correlation data
to outgoing messages.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureCreationPolicyAggregateFactory(Function<Configuration,CreationPolicyAggregateFactory<A>> creationPolicyAggregateFactoryBuilder)
Defines the factory to create new Aggregates instances of the type under configuration when initializing those
instances from non constructor Command handlers annotated with
CreationPolicy . |
default Configurer |
Configurer.configureDeadlineManager(Function<Configuration,DeadlineManager> deadlineManagerBuilder)
Registers a
DeadlineManager instance with this Configurer . |
EventProcessingConfigurer |
EventProcessingModule.configureDefaultStreamableMessageSource(Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> defaultSource) |
EventProcessingConfigurer |
EventProcessingConfigurer.configureDefaultStreamableMessageSource(Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> defaultSource)
Configures which
StreamableMessageSource to use for Tracking Event Processors if none was explicitly
provided. |
EventProcessingConfigurer |
EventProcessingModule.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource) |
EventProcessingConfigurer |
EventProcessingConfigurer.configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)
Configures which
SubscribableMessageSource to use for Subscribing Event Processors if none was explicitly
provided. |
Configurer |
DefaultConfigurer.configureEmbeddedEventStore(Function<Configuration,EventStorageEngine> storageEngineBuilder) |
Configurer |
Configurer.configureEmbeddedEventStore(Function<Configuration,EventStorageEngine> storageEngineBuilder)
Configures an Embedded Event Store which uses the given Event Storage Engine to store its events.
|
default Configurer |
Configurer.configureEventBus(Function<Configuration,EventBus> eventBusBuilder)
Configures the given Event Bus to use in this configuration.
|
Configurer |
DefaultConfigurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder) |
Configurer |
Configurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder)
Configures the given event Serializer to use in this configuration.
|
default Configurer |
Configurer.configureEventStore(Function<Configuration,EventStore> eventStoreBuilder)
Configures the given Event Store to use in this configuration.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureEventStreamFilter(Function<Configuration,Predicate<? super DomainEventMessage<?>>> filterBuilder)
Configures an event stream filter for the EventSourcingRepository for the Aggregate type under configuration.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureFilterEventsByType(Function<Configuration,Boolean> filterConfigurationPredicate)
Configures a function that determines whether or not the EventSourcingRepository for the Aggregate type under
configuration should filter out events with non-matching types.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureLockFactory(Function<Configuration,LockFactory> lockFactory)
Defines the
LockFactory to use in the Repository for the aggregate under configuration. |
default Configurer |
Configurer.configureMessageMonitor(Class<?> componentType,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the Message processing components in this
configuration that match the given componentType, unless more specific configuration based on both type and name
is available.
|
default Configurer |
Configurer.configureMessageMonitor(Class<?> componentType,
String componentName,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the Message processing components in this
configuration that match the given class and name.
|
Configurer |
DefaultConfigurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> builder) |
Configurer |
Configurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> messageMonitorFactoryBuilder)
Configures the Message Monitor to use for the Message processing components in this configuration, unless more
specific configuration based on the component's type, or type and name is available.
|
Configurer |
DefaultConfigurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder) |
Configurer |
Configurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder)
Configures the given event Serializer to use in this configuration.
|
default Configurer |
Configurer.configureQueryBus(Function<Configuration,QueryBus> queryBusBuilder)
Configures the given Query Bus to use in this configuration.
|
default Configurer |
Configurer.configureQueryUpdateEmitter(Function<Configuration,QueryUpdateEmitter> queryUpdateEmitterBuilder)
Configures the given Query Update Emitter to use in this configuration.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureRepository(Function<Configuration,Repository<A>> repositoryBuilder)
Defines the repository to use to load and store Aggregates of this type.
|
SagaConfigurer<T> |
SagaConfigurer.configureRepository(Function<Configuration,SagaRepository<T>> repositoryBuilder)
Configures a
SagaRepository for this Saga. |
default Configurer |
Configurer.configureResourceInjector(Function<Configuration,ResourceInjector> resourceInjectorBuilder)
Configures the given Resource Injector to use for Sagas in this configuration.
|
SagaConfigurer<T> |
SagaConfigurer.configureSagaManager(Function<Configuration,AbstractSagaManager<T>> managerBuilder)
Configures a Saga Manager for this Saga.
|
SagaConfigurer<T> |
SagaConfigurer.configureSagaStore(Function<Configuration,SagaStore<? super T>> storeBuilder)
Configures a
SagaStore for this Saga. |
default Configurer |
Configurer.configureSerializer(Function<Configuration,Serializer> serializerBuilder)
Configures the given Serializer to use in this configuration.
|
AggregateConfigurer<A> |
AggregateConfigurer.configureSnapshotFilter(Function<Configuration,SnapshotFilter> snapshotFilter)
Configure a
SnapshotFilter for the Aggregate type under configuration. |
default Configurer |
Configurer.configureSnapshotter(Function<Configuration,Snapshotter> snapshotterBuilder)
Registers a
Snapshotter instance with this Configurer . |
AggregateConfigurer<A> |
AggregateConfigurer.configureSnapshotTrigger(Function<Configuration,SnapshotTriggerDefinition> snapshotTriggerDefinition)
Configures snapshotting for the Aggregate type under configuration.
|
default Configurer |
Configurer.configureSpanFactory(Function<Configuration,SpanFactory> spanFactory)
Registers a
SpanFactory instance with this Configurer . |
default Configurer |
Configurer.configureTags(Function<Configuration,TagsConfiguration> tagsBuilder)
Configures the given Tags Configuration to use in this configuration.
|
default Configurer |
Configurer.configureTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Configures the given Transaction Manager to use in this configuration.
|
default void |
Configurer.onInitialize(Consumer<Configuration> initHandler)
Register an initialization handler which should be invoked prior to starting this
Configurer . |
Configurer |
DefaultConfigurer.registerCommandHandler(Function<Configuration,Object> commandHandlerBuilder) |
Configurer |
Configurer.registerCommandHandler(Function<Configuration,Object> commandHandlerBuilder)
Registers a command handler bean with this
Configurer . |
default Configurer |
Configurer.registerCommandHandler(int phase,
Function<Configuration,Object> commandHandlerBuilder)
Deprecated.
in favor of
Configurer.registerCommandHandler(Function) , since the phase of an annotated
handler should be defined through the StartHandler /ShutdownHandler annotation. |
<C> Configurer |
DefaultConfigurer.registerComponent(Class<C> componentType,
Function<Configuration,? extends C> componentBuilder) |
<C> Configurer |
Configurer.registerComponent(Class<C> componentType,
Function<Configuration,? extends C> componentBuilder)
Registers a component which should be made available to other components or modules in this Configuration.
|
EventProcessingConfigurer |
EventProcessingModule.registerDeadLetterPolicy(String processingGroup,
Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerDeadLetterPolicy(String processingGroup,
Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerDeadLetterQueue(String processingGroup,
Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerDeadLetterQueue(String processingGroup,
Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder)
Register a
SequencedDeadLetterQueue for the given processingGroup . |
EventProcessingConfigurer |
EventProcessingModule.registerDeadLetterQueueProvider(Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerDeadLetterQueueProvider(Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)
Register the given
deadLetterProvider as a default to build a SequencedDeadLetterQueue for
EventProcessor s created in this configuration. |
EventProcessingConfigurer |
EventProcessingModule.registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)
Register a default
dead letter policy for any processing group using a
dead letter queue . |
EventProcessingConfigurer |
EventProcessingModule.registerDefaultErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder)
Registers a
Function that builds the default ErrorHandler . |
EventProcessingConfigurer |
EventProcessingModule.registerDefaultHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
Register the given
interceptorBuilder as a default to build a MessageHandlerInterceptor for
EventProcessor s created in this configuration. |
EventProcessingConfigurer |
EventProcessingModule.registerDefaultListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)
Registers a
Function that builds the default ListenerInvocationErrorHandler . |
EventProcessingConfigurer |
EventProcessingModule.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
Registers the
SequencingPolicy created by given policyBuilder to the processing groups for which
no explicit policy is defined (using EventProcessingConfigurer.registerSequencingPolicy(String, Function) ). |
EventProcessingConfigurer |
EventProcessingModule.registerDefaultTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Registers a default
TransactionManager for all EventProcessor s. |
EventProcessingConfigurer |
EventProcessingModule.registerErrorHandler(String eventProcessorName,
Function<Configuration,ErrorHandler> errorHandlerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerErrorHandler(String eventProcessorName,
Function<Configuration,ErrorHandler> errorHandlerBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerEventHandler(Function<Configuration,Object> eventHandlerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)
Registers a
Function that builds an Event Handler instance. |
default Configurer |
Configurer.registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)
Registers a
Function that builds an Event Handler instance. |
Configurer |
DefaultConfigurer.registerEventUpcaster(Function<Configuration,EventUpcaster> upcasterBuilder) |
Configurer |
Configurer.registerEventUpcaster(Function<Configuration,EventUpcaster> upcasterBuilder)
Registers an upcaster to be used to upcast Events to a newer version
|
Configurer |
DefaultConfigurer.registerHandlerDefinition(BiFunction<Configuration,Class,HandlerDefinition> handlerDefinitionClass) |
Configurer |
Configurer.registerHandlerDefinition(BiFunction<Configuration,Class,HandlerDefinition> handlerDefinitionClass)
Registers the definition of a Handler class.
|
Configurer |
DefaultConfigurer.registerHandlerEnhancerDefinition(Function<Configuration,HandlerEnhancerDefinition> handlerEnhancerBuilder) |
Configurer |
Configurer.registerHandlerEnhancerDefinition(Function<Configuration,HandlerEnhancerDefinition> handlerEnhancerBuilder)
Registers a builder function for a
HandlerEnhancerDefinition used during constructing of the default
HandlerDefinition . |
EventProcessingConfigurer |
EventProcessingModule.registerHandlerInterceptor(String processorName,
Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerHandlerInterceptor(String processorName,
Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
Register the given
interceptorBuilder to build a MessageHandlerInterceptor for the
EventProcessor with given processorName . |
EventProcessingConfigurer |
EventProcessingModule.registerListenerInvocationErrorHandler(String processingGroup,
Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerListenerInvocationErrorHandler(String processingGroup,
Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)
|
Configurer |
DefaultConfigurer.registerMessageHandler(Function<Configuration,Object> messageHandlerBuilder) |
Configurer |
Configurer.registerMessageHandler(Function<Configuration,Object> messageHandlerBuilder)
Registers a message handler bean with this configuration.
|
default EventProcessingConfigurer |
EventProcessingConfigurer.registerMessageMonitor(String eventProcessorName,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
|
default EventProcessingConfigurer |
EventProcessingConfigurer.registerPooledStreamingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource)
Registers a
PooledStreamingEventProcessor in this EventProcessingConfigurer . |
EventProcessingConfigurer |
EventProcessingModule.registerPooledStreamingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerPooledStreamingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)
Registers a
PooledStreamingEventProcessor in this EventProcessingConfigurer . |
Configurer |
DefaultConfigurer.registerQueryHandler(Function<Configuration,Object> queryHandlerBuilder) |
Configurer |
Configurer.registerQueryHandler(Function<Configuration,Object> queryHandlerBuilder)
Registers a query handler bean with this
Configurer . |
default Configurer |
Configurer.registerQueryHandler(int phase,
Function<Configuration,Object> queryHandlerBuilder)
Deprecated.
in favor of
Configurer.registerQueryHandler(Function) , since the phase of an annotated handler
should be defined through the StartHandler /ShutdownHandler annotation. |
EventProcessingConfigurer |
EventProcessingModule.registerRollbackConfiguration(String name,
Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerRollbackConfiguration(String name,
Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerSagaStore(Function<Configuration,SagaStore> sagaStoreBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerSagaStore(Function<Configuration,SagaStore> sagaStoreBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerSequencingPolicy(String processingGroup,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerSequencingPolicy(String processingGroup,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
Registers the
SequencingPolicy created by the given policyBuilder to the processing group with
given processingGroup . |
EventProcessingConfigurer |
EventProcessingModule.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)
|
EventProcessingConfigurer |
EventProcessingModule.registerTokenStore(Function<Configuration,TokenStore> tokenStore) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTokenStore(Function<Configuration,TokenStore> tokenStore)
Register a
Function that builds a TokenStore to use as the default in case no explicit token
store was configured for a processor. |
EventProcessingConfigurer |
EventProcessingModule.registerTokenStore(String processorName,
Function<Configuration,TokenStore> tokenStore) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTokenStore(String processorName,
Function<Configuration,TokenStore> tokenStoreBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
|
EventProcessingConfigurer |
EventProcessingModule.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration) |
EventProcessingConfigurer |
EventProcessingModule.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)
Registers a
TrackingEventProcessor with given name , source and processorConfiguration within this Configurer. |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)
Registers a
TrackingEventProcessor with given name , source and processorConfiguration within this Configurer. |
EventProcessingConfigurer |
EventProcessingModule.registerTrackingEventProcessorConfiguration(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessorConfiguration(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)
Register a
Function that builds a TrackingEventProcessorConfiguration to use as the default. |
EventProcessingConfigurer |
EventProcessingModule.registerTrackingEventProcessorConfiguration(String name,
Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessorConfiguration(String name,
Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)
Register a
Function that builds a TrackingEventProcessorConfiguration to be used by the EventProcessor corresponding to the given name . |
EventProcessingConfigurer |
EventProcessingModule.registerTransactionManager(String name,
Function<Configuration,TransactionManager> transactionManagerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTransactionManager(String name,
Function<Configuration,TransactionManager> transactionManagerBuilder)
|
void |
Component.update(Function<Configuration,? extends B> builderFunction)
Updates the builder function for this component.
|
Constructor and Description |
---|
Component(Configuration config,
String name,
Function<Configuration,? extends B> builderFunction)
Creates a component for the given
config with given name created by the given builderFunction . |
ConfigurationParameterResolverFactory(Configuration configuration)
Initialize an instance using given
configuration to supply the value to resolve parameters with |
ConfigurationResourceInjector(Configuration configuration)
Initializes the ResourceInjector to inject the resources found in the given
configuration . |
ConfigurationScopeAwareProvider(Configuration configuration)
Instantiate a lazy
ScopeAwareProvider with the given configuration parameter. |
Constructor and Description |
---|
Component(Configuration config,
String name,
Function<Configuration,? extends B> builderFunction)
Creates a component for the given
config with given name created by the given builderFunction . |
Component(Supplier<Configuration> config,
String name,
Function<Configuration,? extends B> builderFunction)
Creates a component for the given
config with given name created by the given builderFunction . |
Component(Supplier<Configuration> config,
String name,
Function<Configuration,? extends B> builderFunction)
Creates a component for the given
config with given name created by the given builderFunction . |
MessageHandlerRegistrar(Supplier<Configuration> configSupplier,
Function<Configuration,Object> messageHandlerBuilder,
BiFunction<Configuration,Object,Registration> messageHandlerSubscriber)
Instantiate a
MessageHandlerRegistrar , using the provided configSupplier to supply the Configuration needed to build and register the message handler. |
MessageHandlerRegistrar(Supplier<Configuration> configSupplier,
Function<Configuration,Object> messageHandlerBuilder,
BiFunction<Configuration,Object,Registration> messageHandlerSubscriber)
Instantiate a
MessageHandlerRegistrar , using the provided configSupplier to supply the Configuration needed to build and register the message handler. |
MessageHandlerRegistrar(Supplier<Configuration> configSupplier,
Function<Configuration,Object> messageHandlerBuilder,
BiFunction<Configuration,Object,Registration> messageHandlerSubscriber)
Instantiate a
MessageHandlerRegistrar , using the provided configSupplier to supply the Configuration needed to build and register the message handler. |
Modifier and Type | Class and Description |
---|---|
class |
AxonConfiguration
Deprecated.
Replaced by the
SpringConfigurer and SpringAxonConfiguration . |
Modifier and Type | Method and Description |
---|---|
Configuration |
SpringAxonConfiguration.getObject() |
Modifier and Type | Method and Description |
---|---|
protected <T> Optional<T> |
SpringConfigurer.defaultComponent(Class<T> type,
Configuration config) |
static <T> Repository<T> |
BeanHelper.repository(Class<T> aggregateType,
Configuration configuration)
|
Modifier and Type | Method and Description |
---|---|
void |
SpringRepositoryFactoryBean.setConfiguration(Configuration configuration)
Deprecated.
Sets the
Configuration that the Repository will be retrieved from. |
Modifier and Type | Method and Description |
---|---|
SpringAggregateSnapshotter |
AxonAutoConfiguration.aggregateSnapshotter(Configuration configuration,
HandlerDefinition handlerDefinition,
ParameterResolverFactory parameterResolverFactory,
EventStore eventStore,
TransactionManager transactionManager,
SnapshotterSpanFactory spanFactory) |
AxonServerEventStoreFactory |
AxonServerBusAutoConfiguration.axonServerEventStoreFactory(AxonServerConfiguration axonServerConfig,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer,
Configuration config) |
SimpleCommandBus |
AxonAutoConfiguration.commandBus(TransactionManager txManager,
Configuration axonConfiguration,
DuplicateCommandHandlerResolver duplicateCommandHandlerResolver) |
DeadlineManager |
AxonJobRunrAutoConfiguration.deadlineManager(org.jobrunr.scheduling.JobScheduler jobScheduler,
Configuration configuration,
Serializer serializer,
TransactionManager transactionManager,
DeadlineManagerSpanFactory spanFactory) |
DeadlineManager |
AxonDbSchedulerAutoConfiguration.deadlineManager(com.github.kagkarlsson.scheduler.Scheduler scheduler,
Configuration configuration,
Serializer serializer,
TransactionManager transactionManager,
DeadlineManagerSpanFactory spanFactory) |
SimpleEventBus |
AxonAutoConfiguration.eventBus(Configuration configuration) |
EventStorageEngine |
JdbcAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Configuration configuration,
ConnectionProvider connectionProvider,
TransactionManager transactionManager,
EventSchema eventSchema) |
EventStorageEngine |
JpaEventStoreAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Configuration configuration,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager) |
EventStore |
AxonServerBusAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
Configuration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
EmbeddedEventStore |
AxonAutoConfiguration.eventStore(EventStorageEngine storageEngine,
Configuration configuration) |
AxonServerQueryBus |
AxonServerBusAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
Configuration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) |
SimpleQueryBus |
AxonAutoConfiguration.queryBus(Configuration axonConfiguration,
TransactionManager transactionManager) |
QueryUpdateEmitter |
AxonAutoConfiguration.queryUpdateEmitter(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
EventStorageEngine |
JpaJavaxEventStoreAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Configuration configuration,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Deprecated.
|
Constructor and Description |
---|
DeadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties,
Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)
Construct a
DeadLetterQueueProviderConfigurerModule , using the given eventProcessorProperties to
decide which processing groups receive the SequencedDeadLetterQueue from the given
deadLetterQueueProvider . |
Copyright © 2010–2024. All rights reserved.