Package | Description |
---|---|
org.axonframework.metrics | |
org.axonframework.queryhandling | |
org.axonframework.queryhandling.annotation |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String name)
Registers new metrics to the registry to monitor a
CommandBus . |
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryMessage<T,R>
Generic implementation of the QueryMessage.
|
Modifier and Type | Method and Description |
---|---|
QueryMessage<T,R> |
QueryMessage.andMetaData(Map<String,?> additionalMetaData) |
QueryMessage<T,R> |
GenericQueryMessage.andMetaData(Map<String,?> metaData) |
QueryMessage<T,R> |
QueryMessage.withMetaData(Map<String,?> metaData) |
QueryMessage<T,R> |
GenericQueryMessage.withMetaData(Map<String,?> metaData) |
Modifier and Type | Method and Description |
---|---|
protected Map<org.axonframework.queryhandling.SimpleQueryBus.QueryDefinition,Collection<MessageHandler<? super QueryMessage<?,?>>>> |
SimpleQueryBus.getSubscriptions()
Returns the subscriptions for this query bus.
|
Modifier and Type | Method and Description |
---|---|
void |
QueryInvocationErrorHandler.onError(Throwable error,
QueryMessage<?,?> queryMessage,
MessageHandler messageHandler)
Invoked when an error occurred while invoking a message handler in a scatter-gather query.
|
void |
LoggingQueryInvocationErrorHandler.onError(Throwable error,
QueryMessage<?,?> queryMessage,
MessageHandler messageHandler) |
<Q,R> CompletableFuture<R> |
SimpleQueryBus.query(QueryMessage<Q,R> query) |
<Q,R> CompletableFuture<R> |
QueryBus.query(QueryMessage<Q,R> query)
Dispatch the given
query to all QueryHandlers subscribed to the given query 's queryName/responseName. |
<Q,R> Stream<R> |
SimpleQueryBus.queryAll(QueryMessage<Q,R> query,
long timeout,
TimeUnit unit) |
<Q,R> Stream<R> |
QueryBus.queryAll(QueryMessage<Q,R> query,
long timeout,
TimeUnit unit)
Dispatch the given
query to all QueryHandlers subscribed to the given query 's queryName/responseName. |
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<QueryMessage<?,?>> interceptor)
Registers an interceptor that intercepts Queries as they are sent.
|
Registration |
SimpleQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<QueryMessage<?,?>> interceptor)
Registers an interceptor that is used to intercept Queries before they are passed to their
respective handlers.
|
<R> Registration |
SimpleQueryBus.subscribe(String queryName,
Class<R> responseType,
MessageHandler<? super QueryMessage<?,R>> handler) |
<R> Registration |
QueryBus.subscribe(String queryName,
Class<R> responseType,
MessageHandler<? super QueryMessage<?,R>> handler)
Subscribe the given
handler to queries with the given queryName and responseName . |
Constructor and Description |
---|
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor,
TransactionManager transactionManager,
QueryInvocationErrorHandler errorHandler)
Initialize the query bus with the given
messageMonitor and given errorHandler . |
Modifier and Type | Method and Description |
---|---|
Object |
AnnotationQueryHandlerAdapter.handle(QueryMessage<?,?> message) |
Copyright © 2010–2017. All rights reserved.