Uses of Interface
org.axonframework.messaging.queryhandling.QueryMessage
Packages that use QueryMessage
Package
Description
Part of the Axon Server Connector module.
Part of the Axon Extension module.
Part of the Axon Extension module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Package for query handling components in Axon Framework.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
-
Uses of QueryMessage in org.axonframework.axonserver.connector.query
Methods in org.axonframework.axonserver.connector.query that return QueryMessageModifier and TypeMethodDescriptionstatic QueryMessageQueryConverter.convertSubscriptionQueryMessage(io.axoniq.axonserver.grpc.query.SubscriptionQuery query, @Nullable Converter converter) 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, @Nullable ProcessingContext context) AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize) -
Uses of QueryMessage in org.axonframework.extension.reactor.messaging.core.interception
Methods in org.axonframework.extension.reactor.messaging.core.interception that return types with arguments of type QueryMessageModifier and TypeMethodDescriptionDefaultReactorDispatchInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) ReactorDispatchInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) Returns the list ofReactorMessageDispatchInterceptorsregistered forQueryMessagesfor a specificcomponentTypeandcomponentName.Method parameters in org.axonframework.extension.reactor.messaging.core.interception with type arguments of type QueryMessageModifier and TypeMethodDescriptionDefaultReactorDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) DefaultReactorDispatchInterceptorRegistry.registerQueryInterceptor(ReactorDispatchInterceptorFactory<? super QueryMessage> interceptorFactory) ReactorDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) Registers the giveninterceptorBuilderfor aQueryMessage-specificReactorMessageDispatchInterceptor.ReactorDispatchInterceptorRegistry.registerQueryInterceptor(ReactorDispatchInterceptorFactory<? super QueryMessage> interceptorFactory) Registers the given component-awareinterceptorFactoryfor aQueryMessage-specificReactorMessageDispatchInterceptor. -
Uses of QueryMessage in org.axonframework.extension.reactor.messaging.queryhandling.gateway
Constructor parameters in org.axonframework.extension.reactor.messaging.queryhandling.gateway with type arguments of type QueryMessageModifierConstructorDescriptionDefaultReactorQueryGateway(QueryGateway queryGateway, MessageTypeResolver messageTypeResolver, List<ReactorMessageDispatchInterceptor<? super QueryMessage>> dispatchInterceptors) Instantiate aDefaultReactorQueryGateway. -
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>> monitorBuilder) Registers a query monitor using the specifiedmonitorBuilder.MessagingConfigurer.registerQueryMonitor(MessageMonitorFactory<? super QueryMessage> monitorFactory) Registers amessage monitor factoryforquery-specificinfrastructure components in this configuration. -
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, Class<?> componentType, @Nullable String componentName) List<MessageHandlerInterceptor<? super QueryMessage>> DefaultHandlerInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) List<MessageDispatchInterceptor<? super QueryMessage>> DispatchInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) Returns the list ofQueryMessage-specificMessageDispatchInterceptorsregistered in this registry for a specificcomponentTypeandcomponentName.List<MessageHandlerInterceptor<? super QueryMessage>> HandlerInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) Returns the list ofQueryMessage-specificMessageHandlerInterceptorsregistered in this registry for acomponentTypeandcomponentName.Method parameters in org.axonframework.messaging.core.interception with type arguments of type QueryMessageModifier and TypeMethodDescriptionDefaultDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) DefaultDispatchInterceptorRegistry.registerQueryInterceptor(DispatchInterceptorFactory<? super QueryMessage> interceptorFactory) DefaultHandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder) DefaultHandlerInterceptorRegistry.registerQueryInterceptor(HandlerInterceptorFactory<? super QueryMessage> interceptorFactory) DispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder) DispatchInterceptorRegistry.registerQueryInterceptor(DispatchInterceptorFactory<? super QueryMessage> interceptorFactory) Registers the given component-awareinterceptorFactoryfor aQueryMessage-specificMessageDispatchInterceptor.HandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder) Registers the giveninterceptorBuilderfor aQueryMessageMessageHandlerInterceptorfor all query handling infrastructure componentsHandlerInterceptorRegistry.registerQueryInterceptor(HandlerInterceptorFactory<? super QueryMessage> interceptorFactory) Registers the given component-awareinterceptorFactoryfor 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, Class<?> componentType, @Nullable String componentName) MessageMonitor<? super QueryMessage> MessageMonitorRegistry.queryMonitor(Configuration config, Class<?> componentType, @Nullable String componentName) Retrieves aMessageMonitorfor monitoring the processing ofQueryMessageinstances for a specificcomponentTypeandcomponentName.Method parameters in org.axonframework.messaging.monitoring.configuration with type arguments of type QueryMessageModifier and TypeMethodDescriptionDefaultMessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder) DefaultMessageMonitorRegistry.registerQueryMonitor(MessageMonitorFactory<? super QueryMessage> monitorFactory) MessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder) MessageMonitorRegistry.registerQueryMonitor(MessageMonitorFactory<? super QueryMessage> monitorFactory) Registers a component-awareMessageMonitorspecifically for monitoring the processing ofQueryMessageinstances using the givenmonitorFactory. -
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, @Nullable String> metadata) QueryMessage.andMetadata(Map<String, @Nullable 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, @Nullable ProcessingContext context) Dispatch the givenqueryto aQueryHandlersubscribedto the givenquery'squery name, returning aMessageStreamofresponsesto the givenquery.SimpleQueryBus.query(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context, int updateBufferSize) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName/initialResponseType/updateResponseType.SimpleQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize) Method parameters in org.axonframework.messaging.queryhandling with type arguments of type QueryMessageModifier and TypeMethodDescriptionQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, @Nullable ProcessingContext context) Completessubscription queriesmatching the givenfilter.SimpleQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, @Nullable ProcessingContext context) QueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context) SimpleQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context) QueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable ProcessingContext context) Emits the outcome of theupdateSuppliertosubscription queriesmatching the givenqueryNameand givenfilter.SimpleQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable 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, @Nullable ProcessingContext context) DistributedQueryBus.query(QueryMessage query, @Nullable ProcessingContext context) PayloadConvertingQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context) QueryBusConnector.Handler.query(QueryMessage query) Handles the incoming query message.QueryBusConnector.query(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context, int updateBufferSize) DistributedQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize) PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize) QueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context) DistributedQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context) DistributedQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable 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, @Nullable ProcessingContext context) InterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) InterceptingQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize) Method parameters in org.axonframework.messaging.queryhandling.interception with type arguments of type QueryMessageModifier and TypeMethodDescriptionInterceptingQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, @Nullable ProcessingContext context) InterceptingQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context) InterceptingQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable 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.