Modifier and Type | Class and Description |
---|---|
class |
GrpcBackedQueryMessage<Q,R>
Wrapper that allows clients to access a gRPC
QueryRequest as a QueryMessage . |
Modifier and Type | Method and Description |
---|---|
<Q,R> QueryMessage<Q,R> |
QuerySerializer.deserializeRequest(io.axoniq.axonserver.grpc.query.QueryRequest queryRequest)
Convert a
QueryRequest into a QueryMessage . |
Modifier and Type | Method and Description |
---|---|
int |
QueryPriorityCalculator.determinePriority(QueryMessage<?,?> query)
Determines the priority of the given
query . |
<Q,R> CompletableFuture<QueryResponseMessage<R>> |
AxonServerQueryBus.query(QueryMessage<Q,R> queryMessage) |
<Q,R> Stream<QueryResponseMessage<R>> |
AxonServerQueryBus.scatterGather(QueryMessage<Q,R> queryMessage,
long timeout,
TimeUnit timeUnit) |
<Q,R> io.axoniq.axonserver.grpc.query.QueryRequest |
QuerySerializer.serializeRequest(QueryMessage<Q,R> queryMessage,
int nrResults,
long timeout,
int priority)
Convert a
QueryMessage into a QueryRequest . |
<Q,R> io.axoniq.axonserver.grpc.query.QueryRequest |
QuerySerializer.serializeRequest(QueryMessage<Q,R> queryMessage,
int nrResults,
long timeout,
int priority,
boolean stream)
Convert a
QueryMessage into a QueryRequest . |
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) |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.targetContextResolver(TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)
Sets the
TargetContextResolver used to resolve the target (bounded) context of an ingested
QueryMessage . |
Modifier and Type | Class and Description |
---|---|
class |
GrpcBackedSubscriptionQueryMessage<Q,I,U>
Wrapper that allows clients to access a gRPC
SubscriptionQuery message as a SubscriptionQueryMessage . |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String queryBusName)
Registers new metrics to the registry to monitor a
QueryBus . |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String queryBusName)
Registers new metrics to the registry to monitor a
QueryBus . |
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String queryBusName,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)
Registers new metrics to the registry to monitor a
QueryBus using Tag s through the given tagsBuilder . |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamingQueryMessage<Q,R>
A special type of
QueryMessage used for initiating streaming queries. |
interface |
SubscriptionQueryMessage<Q,I,U>
Message type that carries a Subscription Query: a request for information.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryMessage<T,R>
Generic implementation of the QueryMessage.
|
class |
GenericStreamingQueryMessage<Q,R>
Generic implementation of the
StreamingQueryMessage . |
class |
GenericSubscriptionQueryMessage<Q,I,U>
Generic implementation of the
SubscriptionQueryMessage . |
Modifier and Type | Method and Description |
---|---|
QueryMessage<T,R> |
QueryMessage.andMetaData(Map<String,?> additionalMetaData)
Returns a copy of this QueryMessage with its MetaData merged with given
metaData . |
QueryMessage<T,R> |
GenericQueryMessage.andMetaData(Map<String,?> metaData) |
QueryMessage<T,R> |
QueryMessage.withMetaData(Map<String,?> metaData)
Returns a copy of this QueryMessage with the given
metaData . |
QueryMessage<T,R> |
GenericQueryMessage.withMetaData(Map<String,?> metaData) |
Modifier and Type | Method and Description |
---|---|
MessageHandler<? super QueryMessage<?,R>> |
QuerySubscription.getQueryHandler()
Retrieve the query handler of this subscription as a
MessageHandler . |
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<QueryResponseMessage<R>> |
SimpleQueryBus.query(QueryMessage<Q,R> query) |
<Q,R> CompletableFuture<QueryResponseMessage<R>> |
QueryBus.query(QueryMessage<Q,R> query)
Dispatch the given
query to a single QueryHandler subscribed to the given query 's queryName and
responseType. |
<Q,R> Stream<QueryResponseMessage<R>> |
SimpleQueryBus.scatterGather(QueryMessage<Q,R> query,
long timeout,
TimeUnit unit) |
<Q,R> Stream<QueryResponseMessage<R>> |
QueryBus.scatterGather(QueryMessage<Q,R> query,
long timeout,
TimeUnit unit)
Dispatch the given
query to all QueryHandlers subscribed to the given query 's
queryName/responseType. |
Modifier and Type | Method and Description |
---|---|
DefaultQueryGateway.Builder |
DefaultQueryGateway.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<? super QueryMessage<?,?>>> dispatchInterceptors)
|
SimpleQueryBus.Builder |
SimpleQueryBus.Builder.messageMonitor(MessageMonitor<? super QueryMessage<?,?>> messageMonitor)
Sets the
MessageMonitor used to monitor query messages. |
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 |
SimpleQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super 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,
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 |
---|
NoHandlerForQueryException(QueryMessage<?,?> query)
Initialize this exception with a message describing the given
QueryMessage . |
Constructor and Description |
---|
QuerySubscription(Type responseType,
MessageHandler<? super QueryMessage<?,R>> queryHandler)
|
Modifier and Type | Method and Description |
---|---|
boolean |
AnnotationQueryHandlerAdapter.canHandle(QueryMessage<?,?> message) |
Object |
AnnotationQueryHandlerAdapter.handle(QueryMessage<?,?> message) |
Modifier and Type | Method and Description |
---|---|
AxonServerQueryBus |
AxonServerBusAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
Configuration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) |
Copyright © 2010–2023. All rights reserved.