Modifier and Type | Method and Description |
---|---|
Registration |
DispatchInterceptors.registerDispatchInterceptor(MessageDispatchInterceptor<? super M> dispatchInterceptor) |
Modifier and Type | Class and Description |
---|---|
class |
AxonServerRegistration
Wrapper around standard Axon Framework
Registration . |
Modifier and Type | Method and Description |
---|---|
Registration |
AxonServerCommandBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor) |
Registration |
AxonServerCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Registration |
AxonServerCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> messageHandler) |
Constructor and Description |
---|
AxonServerRegistration(Registration wrappedRegistration,
Runnable closeCallback)
Instantiate an
AxonServerRegistration , which wraps the given wrappedRegistration and runs the
provided closeCallback on a close() and AxonServerRegistration.cancel() call |
Modifier and Type | Method and Description |
---|---|
Registration |
PersistentStreamMessageSource.subscribe(Consumer<List<? extends EventMessage<?>>> consumer) |
Modifier and Type | Method and Description |
---|---|
Registration |
AxonServerQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> dispatchInterceptor) |
Registration |
AxonServerQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?,?>> interceptor) |
<R> Registration |
AxonServerQueryBus.subscribe(String queryName,
Type responseType,
MessageHandler<? super QueryMessage<?,R>> handler) |
Modifier and Type | Class and Description |
---|---|
class |
AxonServerSubscriptionQueryResult<I,U>
A
SubscriptionQueryResult that emits initial response and update when subscription query response message is
received. |
class |
DeserializedResult<I,U>
Deprecated.
in through use of the AxonServer java
connector
|
class |
DisposableResult<I,U>
Deprecated.
in through use of the AxonServer java
connector
|
Constructor and Description |
---|
DisposableResult(SubscriptionQueryResult<I,U> delegate,
Registration registration)
Deprecated.
Instantiate a
DisposableResult wrapping the delegate , opening up the capability to DisposableResult.cancel() it. |
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 |
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 |
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 |
---|---|
Registration |
DefaultCommandGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> dispatchInterceptor) |
protected Registration |
AbstractCommandGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>> interceptor)
Registers a command dispatch interceptor within a
CommandGateway . |
Modifier and Type | Method and Description |
---|---|
protected Registration |
JCacheAdapter.doRegisterListener(javax.cache.configuration.CacheEntryListenerConfiguration<Object,Object> listenerAdapter) |
protected Registration |
EhCacheAdapter.doRegisterListener(net.sf.ehcache.event.CacheEventListener listenerAdapter)
Deprecated.
|
protected Registration |
EhCache3Adapter.doRegisterListener(org.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) |
Constructor and Description |
---|
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 | Method and Description |
---|---|
Registration |
AbstractDeadlineManager.registerDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> dispatchInterceptor) |
Registration |
AbstractDeadlineManager.registerHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> handlerInterceptor) |
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 |
AbstractEventBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor)
Register the given DispatchInterceptor.
|
Registration |
AbstractEventProcessor.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor) |
Registration |
AbstractEventBus.subscribe(Consumer<List<? extends EventMessage<?>>> eventProcessor) |
Modifier and Type | Method and Description |
---|---|
Registration |
DeadLetteringEventHandlerInvoker.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
AbstractEventGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> interceptor)
Registers an event dispatch interceptor within an
EventGateway . |
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 | Method and Description |
---|---|
Registration |
AggregateAnnotationCommandHandler.subscribe(CommandBus commandBus)
Subscribe this command handler to the given
commandBus . |
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 |
UpdateHandlerRegistration.getRegistration()
Gets the registration.
|
Registration |
SimpleQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor)
Registers an interceptor that intercepts Queries as they are sent.
|
Registration |
DefaultQueryGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor) |
Registration |
SimpleQueryUpdateEmitter.registerDispatchInterceptor(MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage<?>> interceptor) |
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 the query handlers of this
QueryHandlerAdapter to the given QueryBus . |
<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.
|
UpdateHandlerRegistration(Registration registration,
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates,
Runnable completeHandler)
|
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 |
StubDeadlineManager.registerDispatchInterceptor(MessageDispatchInterceptor<? super DeadlineMessage<?>> dispatchInterceptor) |
Registration |
StubDeadlineManager.registerHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> handlerInterceptor) |
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–2024. All rights reserved.