Package | Description |
---|---|
org.axonframework.amqp.eventhandling.spring | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.commandhandling.distributed | |
org.axonframework.common.caching |
Package containing a Caching abstraction, while waiting for the JSR 107 to be fully specified and implemented.
|
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.jgroups.commandhandling | |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.queryhandling | |
org.axonframework.queryhandling.annotation | |
org.axonframework.spring.messaging |
Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.
|
org.axonframework.springcloud.commandhandling | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Method and Description |
---|---|
Registration |
SpringAMQPMessageSource.subscribe(Consumer<List<? extends EventMessage<?>>> messageProcessor) |
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleCommandBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor)
Registers the given list of dispatch interceptors to the command bus.
|
Registration |
SimpleCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor)
Registers the given interceptor to the command bus.
|
Registration |
AnnotationCommandHandlerAdapter.subscribe(CommandBus commandBus)
Subscribe this command handler to the given
commandBus . |
Registration |
AggregateAnnotationCommandHandler.subscribe(CommandBus commandBus)
Subscribe this command handler to the given
commandBus . |
Registration |
SimpleCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with given commandName . |
Registration |
CommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with the given commandName . |
Modifier and Type | Method and Description |
---|---|
Registration |
DisruptorCommandBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor) |
Registration |
DisruptorCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Registration |
DisruptorCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Modifier and Type | Method and Description |
---|---|
Registration |
DistributedCommandBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor)
Registers the given list of dispatch interceptors to the command bus.
|
Registration |
DistributedCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Registration |
DistributedCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with the given commandName . |
Registration |
CommandBusConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribes a command message handler for commands with given
commandName . |
Modifier and Type | Method and Description |
---|---|
protected Registration |
JCacheAdapter.doRegisterListener(javax.cache.configuration.CacheEntryListenerConfiguration listenerAdapter) |
protected Registration |
EhCacheAdapter.doRegisterListener(net.sf.ehcache.event.CacheEventListener listenerAdapter) |
protected abstract Registration |
AbstractCacheAdapter.doRegisterListener(L listenerAdapter)
Registers the given listener with the cache implementation
|
Registration |
WeakReferenceCache.registerCacheEntryListener(Cache.EntryListener entryListener) |
Registration |
NoCache.registerCacheEntryListener(Cache.EntryListener cacheEntryListener) |
Registration |
Cache.registerCacheEntryListener(Cache.EntryListener cacheEntryListener)
Registers the given
cacheEntryListener to listen for Cache changes. |
Registration |
AbstractCacheAdapter.registerCacheEntryListener(Cache.EntryListener entryListener) |
Modifier and Type | Method and Description |
---|---|
Registration |
EventBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor)
Register the given
interceptor with this bus. |
Registration |
AbstractEventBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor)
Register the given
interceptor with this bus. |
Registration |
EventProcessor.registerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)
Registers the given
interceptor to this event processor. |
Registration |
AbstractEventProcessor.registerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor) |
Registration |
AbstractEventBus.subscribe(Consumer<List<? extends EventMessage<?>>> eventProcessor) |
Modifier and Type | Method and Description |
---|---|
Registration |
JGroupsConnector.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Registration |
JGroupsConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Modifier and Type | Method and Description |
---|---|
Registration |
MessageDispatchInterceptorSupport.registerDispatchInterceptor(MessageDispatchInterceptor<? super T> dispatchInterceptor)
Register the given DispatchInterceptor.
|
Registration |
MessageHandlerInterceptorSupport.registerHandlerInterceptor(MessageHandlerInterceptor<? super T> handlerInterceptor)
Register the given
handlerInterceptor . |
Registration |
SubscribableMessageSource.subscribe(Consumer<List<? extends M>> messageProcessor)
Subscribe the given
messageProcessor to this message source. |
Modifier and Type | Interface and Description |
---|---|
interface |
SubscriptionQueryResult<I,U>
Result of the subscription query.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultSubscriptionQueryResult<I,U>
Default implementation of
SubscriptionQueryResult . |
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor)
Registers an interceptor that intercepts Queries as they are sent.
|
Registration |
SimpleQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?,?>> interceptor)
Registers an interceptor that is used to intercept Queries before they are passed to their
respective handlers.
|
Registration |
QueryHandlerAdapter.subscribe(QueryBus queryBus)
Subscribes query handlers to the given query bus
|
<R> Registration |
SimpleQueryBus.subscribe(String queryName,
Type responseType,
MessageHandler<? super QueryMessage<?,R>> handler) |
<R> Registration |
QueryBus.subscribe(String queryName,
Type responseType,
MessageHandler<? super QueryMessage<?,R>> handler)
Subscribe the given
handler to queries with the given queryName and responseType . |
Constructor and Description |
---|
DefaultSubscriptionQueryResult(reactor.core.publisher.Mono<I> initialResult,
reactor.core.publisher.Flux<U> updates,
Registration registrationDelegate)
Initializes the result with mono and flux used for result retrieval.
|
Modifier and Type | Method and Description |
---|---|
Registration |
AnnotationQueryHandlerAdapter.subscribe(QueryBus queryBus) |
Modifier and Type | Method and Description |
---|---|
Registration |
InboundEventMessageChannelAdapter.subscribe(Consumer<List<? extends EventMessage<?>>> messageProcessor) |
Modifier and Type | Method and Description |
---|---|
Registration |
SpringHttpCommandBusConnector.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Registration |
SpringHttpCommandBusConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Modifier and Type | Method and Description |
---|---|
Registration |
RecordingCommandBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor) |
Registration |
RecordingCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Registration |
RecordingCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Copyright © 2010–2018. All rights reserved.