Uses of Interface
org.axonframework.messaging.queryhandling.QueryMessage
Packages that use QueryMessage
Package
Description
-
Uses of QueryMessage in org.axonframework.axonserver.connector.query
Methods in org.axonframework.axonserver.connector.query that return QueryMessageModifier and TypeMethodDescriptionstatic QueryMessageQueryConverter.convertQueryRequest(io.axoniq.axonserver.grpc.query.QueryRequest queryRequest) Converts aQueryRequestinto aQueryMessage.static QueryMessageQueryConverter.convertSubscriptionQueryMessage(io.axoniq.axonserver.grpc.query.SubscriptionQuery query) Converts aSubscriptionQueryinto aQueryMessage.Methods in org.axonframework.axonserver.connector.query with parameters of type QueryMessageModifier and TypeMethodDescriptionstatic io.axoniq.axonserver.grpc.query.QueryRequestQueryConverter.convertQueryMessage(QueryMessage query, String clientId, String componentName) Converts aQueryMessageinto aQueryRequest.AxonServerQueryBusConnector.query(QueryMessage query, ProcessingContext context) AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) -
Uses of QueryMessage in org.axonframework.extension.metrics.dropwizard
Methods in org.axonframework.extension.metrics.dropwizard that return types with arguments of type QueryMessageModifier and TypeMethodDescriptionMessageMonitor<? super QueryMessage> GlobalMetricRegistry.registerQueryBus(String queryBusName) Registers new metrics to the registry to monitor aQueryBus. -
Uses of QueryMessage in org.axonframework.extension.metrics.micrometer
Methods in org.axonframework.extension.metrics.micrometer that return types with arguments of type QueryMessageModifier and TypeMethodDescriptionMessageMonitor<? super QueryMessage> GlobalMetricRegistry.registerQueryBus(String queryBusName) Registers new metrics to the registry to monitor aQueryBus.MessageMonitor<? super QueryMessage> GlobalMetricRegistry.registerQueryBus(String queryBusName, Function<Message, Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor aQueryBususingTags through the giventagsBuilder. -
Uses of QueryMessage in org.axonframework.messaging.core.configuration
Method parameters in org.axonframework.messaging.core.configuration with type arguments of type QueryMessageModifier and TypeMethodDescriptionMessagingConfigurer.registerQueryDispatchInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) MessagingConfigurer.registerQueryHandlerInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder) MessagingConfigurer.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> messageMonitorBuilder) Registers a query monitor using the specifiedmessageMonitorBuilder. -
Uses of QueryMessage in org.axonframework.messaging.core.interception
Methods in org.axonframework.messaging.core.interception that return types with arguments of type QueryMessageModifier and TypeMethodDescriptionList<MessageDispatchInterceptor<? super QueryMessage>> DefaultDispatchInterceptorRegistry.queryInterceptors(Configuration config) List<MessageHandlerInterceptor<? super QueryMessage>> DefaultHandlerInterceptorRegistry.queryInterceptors(Configuration config) List<MessageDispatchInterceptor<? super QueryMessage>> DispatchInterceptorRegistry.queryInterceptors(Configuration config) Returns the list ofQueryMessage-specificMessageDispatchInterceptorsregistered in this registry.List<MessageHandlerInterceptor<? super QueryMessage>> HandlerInterceptorRegistry.queryInterceptors(Configuration config) Returns the list ofQueryMessage-specificMessageHandlerInterceptorsregistered in this registry.Method parameters in org.axonframework.messaging.core.interception with type arguments of type QueryMessageModifier and TypeMethodDescriptionDefaultDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) DefaultHandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder) DispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) HandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder) Registers the giveninterceptorBuilderfor aQueryMessageMessageHandlerInterceptorfor all query handling infrastructure components -
Uses of QueryMessage in org.axonframework.messaging.core.timeout
Methods in org.axonframework.messaging.core.timeout that return types with arguments of type QueryMessageModifier and TypeMethodDescriptionUnitOfWorkTimeoutInterceptorBuilder.buildQueryInterceptor()Constructs aQueryMessagehandler interceptor, to be registered on (e.g.) theQueryBus. -
Uses of QueryMessage in org.axonframework.messaging.monitoring.configuration
Methods in org.axonframework.messaging.monitoring.configuration that return types with arguments of type QueryMessageModifier and TypeMethodDescriptionMessageMonitor<? super QueryMessage> DefaultMessageMonitorRegistry.queryMonitor(Configuration config) MessageMonitor<? super QueryMessage> MessageMonitorRegistry.queryMonitor(Configuration config) Retrieves aMessageMonitorfor monitoring the processing ofQueryMessageinstances.Method parameters in org.axonframework.messaging.monitoring.configuration with type arguments of type QueryMessageModifier and TypeMethodDescriptionDefaultMessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder) MessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder) -
Uses of QueryMessage in org.axonframework.messaging.monitoring.interception
Methods in org.axonframework.messaging.monitoring.interception with parameters of type QueryMessageModifier and TypeMethodDescriptionMonitoringQueryHandlerInterceptor.interceptOnHandle(QueryMessage message, ProcessingContext context, MessageHandlerInterceptorChain<QueryMessage> interceptorChain) Method parameters in org.axonframework.messaging.monitoring.interception with type arguments of type QueryMessageModifier and TypeMethodDescriptionMonitoringQueryHandlerInterceptor.interceptOnHandle(QueryMessage message, ProcessingContext context, MessageHandlerInterceptorChain<QueryMessage> interceptorChain) Constructor parameters in org.axonframework.messaging.monitoring.interception with type arguments of type QueryMessageModifierConstructorDescriptionMonitoringQueryHandlerInterceptor(MessageMonitor<? super QueryMessage> messageMonitor) Constructs a MonitoringQueryHandlerInterceptor using the givenMessageMonitor. -
Uses of QueryMessage in org.axonframework.messaging.queryhandling
Classes in org.axonframework.messaging.queryhandling that implement QueryMessageMethods in org.axonframework.messaging.queryhandling that return QueryMessageModifier and TypeMethodDescriptionGenericQueryMessage.andMetadata(Map<String, String> metadata) QueryMessage.andMetadata(Map<String, String> additionalMetadata) GenericQueryMessage.withConvertedPayload(Type type, Converter converter) default QueryMessageQueryMessage.withConvertedPayload(Class<?> type, Converter converter) QueryMessage.withConvertedPayload(Type type, Converter converter) default QueryMessageQueryMessage.withConvertedPayload(TypeReference<?> type, Converter converter) GenericQueryMessage.withMetadata(Map<String, String> metadata) QueryMessage.withMetadata(Map<String, String> metadata) Methods in org.axonframework.messaging.queryhandling with parameters of type QueryMessageModifier and TypeMethodDescriptionintQueryPriorityCalculator.determinePriority(QueryMessage query) Determines the priority of the givenquery.static NoHandlerForQueryExceptionNoHandlerForQueryException.forBus(QueryMessage query) Constructs aNoHandlerForQueryExceptionwith a message describing the givenQueryMessage, specific forQueryBuses.static NoHandlerForQueryExceptionNoHandlerForQueryException.forHandlingComponent(QueryMessage query) Constructs aNoHandlerForQueryExceptionwith a message describing the givenQueryMessage, specific forQueryHandlingComponents.QueryHandler.handle(QueryMessage query, ProcessingContext context) Handles the givenquerywithin the givencontext.SimpleQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context) QueryBus.query(QueryMessage query, ProcessingContext context) Dispatch the givenqueryto aQueryHandlersubscribedto the givenquery'squery name, returning aMessageStreamofresponsesto the givenquery.SimpleQueryBus.query(QueryMessage query, ProcessingContext context) QueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) Subscribes the givenquerywith the givenupdateBufferSize, and returns the MessageStream that provides the update of the subscription query.SimpleQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) QueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName/initialResponseType/updateResponseType.SimpleQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) Method parameters in org.axonframework.messaging.queryhandling with type arguments of type QueryMessageModifier and TypeMethodDescriptionQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context) Completessubscription queriesmatching the givenfilter.SimpleQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context) QueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context) SimpleQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context) QueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context) Emits the outcome of theupdateSuppliertosubscription queriesmatching the givenqueryNameand givenfilter.SimpleQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context) -
Uses of QueryMessage in org.axonframework.messaging.queryhandling.annotation
Methods in org.axonframework.messaging.queryhandling.annotation with parameters of type QueryMessageModifier and TypeMethodDescriptionAnnotatedQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context) -
Uses of QueryMessage in org.axonframework.messaging.queryhandling.distributed
Methods in org.axonframework.messaging.queryhandling.distributed with parameters of type QueryMessageModifier and TypeMethodDescriptionDelegatingQueryBusConnector.query(QueryMessage query, ProcessingContext context) DistributedQueryBus.query(QueryMessage query, ProcessingContext context) PayloadConvertingQueryBusConnector.query(QueryMessage query, ProcessingContext context) QueryBusConnector.Handler.query(QueryMessage query) Handles the incoming query message.QueryBusConnector.query(QueryMessage query, ProcessingContext context) Sends the givenqueryto the remote QueryBus.QueryBusConnector.Handler.registerUpdateHandler(QueryMessage subscriptionQueryMessage, QueryBusConnector.UpdateCallback updateCallback) Registers an update handler for a given subscription query message and its associated update sender.DistributedQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) DelegatingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) DistributedQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) QueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) Sends the givenqueryto the remote QueryBus.Method parameters in org.axonframework.messaging.queryhandling.distributed with type arguments of type QueryMessageModifier and TypeMethodDescriptionDistributedQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context) DistributedQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context) DistributedQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context) -
Uses of QueryMessage in org.axonframework.messaging.queryhandling.interception
Methods in org.axonframework.messaging.queryhandling.interception with parameters of type QueryMessageModifier and TypeMethodDescriptionQueryMessageHandlerInterceptorChain.proceed(QueryMessage query, ProcessingContext context) InterceptingQueryBus.query(QueryMessage query, ProcessingContext context) InterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) InterceptingQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize) Method parameters in org.axonframework.messaging.queryhandling.interception with type arguments of type QueryMessageModifier and TypeMethodDescriptionInterceptingQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context) InterceptingQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context) InterceptingQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context) Constructor parameters in org.axonframework.messaging.queryhandling.interception with type arguments of type QueryMessageModifierConstructorDescriptionInterceptingQueryBus(QueryBus delegate, List<MessageHandlerInterceptor<? super QueryMessage>> handlerInterceptors, List<MessageDispatchInterceptor<? super QueryMessage>> dispatchInterceptors, List<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> updateDispatchInterceptors) Constructs aInterceptingQueryBus, delegating dispatching and handling logic to the givendelegate.QueryMessageHandlerInterceptorChain(List<MessageHandlerInterceptor<? super QueryMessage>> interceptors, QueryHandler queryHandler) Constructs a newQueryMessageHandlerInterceptorChainwith a list ofinterceptionand anqueryHandler. -
Uses of QueryMessage in org.axonframework.messaging.queryhandling.tracing
Methods in org.axonframework.messaging.queryhandling.tracing with type parameters of type QueryMessageModifier and TypeMethodDescription<M extends QueryMessage>
MDefaultQueryBusSpanFactory.propagateContext(M queryMessage) <M extends QueryMessage>
MQueryBusSpanFactory.propagateContext(M queryMessage) Propagates the context of the current span to the givenqueryMessage.Methods in org.axonframework.messaging.queryhandling.tracing with parameters of type QueryMessageModifier and TypeMethodDescriptionDefaultQueryBusSpanFactory.createQueryProcessingSpan(QueryMessage queryMessage) QueryBusSpanFactory.createQueryProcessingSpan(QueryMessage queryMessage) Creates a span for processing a query.DefaultQueryBusSpanFactory.createQuerySpan(QueryMessage queryMessage, boolean distributed) QueryBusSpanFactory.createQuerySpan(QueryMessage queryMessage, boolean distributed) Creates a span for a query.DefaultQueryBusSpanFactory.createResponseProcessingSpan(QueryMessage queryMessage) QueryBusSpanFactory.createResponseProcessingSpan(QueryMessage queryMessage) Creates a span for processing a response.DefaultQueryBusSpanFactory.createStreamingQuerySpan(QueryMessage queryMessage, boolean distributed) QueryBusSpanFactory.createStreamingQuerySpan(QueryMessage queryMessage, boolean distributed) Creates a span for a streaming query.DefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage) QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage) Creates a span for processing a subscription query update that has been received from the server.DefaultQueryBusSpanFactory.createSubscriptionQuerySpan(QueryMessage queryMessage, boolean distributed) QueryBusSpanFactory.createSubscriptionQuerySpan(QueryMessage queryMessage, boolean distributed) Creates a span for a subscription query.