Package org.axonframework.messaging.queryhandling
package org.axonframework.messaging.queryhandling
-
ClassDescriptionException indicating that
QueryUpdateEmitteris completed, thus cannot be used to emit messages and report errors.Exception indicating a duplicateQueryHandlerwas subscribed.Generic implementation of theQueryMessageinterface.Generic implementation of theQueryResponseMessageinterface.Generic implementation of theSubscriptionQueryUpdateMessageinterface holding incremental update of a subscription query.Exception indicating this instance has noQueryHandlerfor a givenQueryMessage.The mechanism that dispatchesqueriesto their appropriatequery handler.Exception indicating that the execution of a Query Handler has resulted in an exception.Interface describing a handler ofqueries.QueryHandlerRegistry<S extends QueryHandlerRegistry<S>>Interface describing a registry ofquery handlers.Interface describing a group ofQueryHandlersbelonging to a single component.AMessagetype that carries a Query: a request for information.Calculate the priority ofQueryMessagebased on its content.AResultMessageimplementation that contains the result of query handling.Query-specific component that interacts withsubscription queriesaboutupdate,errors, and when there areno more update.ParameterResolverFactorythat ensures theQueryUpdateEmitteris resolved in the context of the currentProcessingContext.Implementation of theQueryBusthat dispatches queries (throughSimpleQueryBus.query(QueryMessage, ProcessingContext)orSimpleQueryBus.subscriptionQuery(QueryMessage, ProcessingContext, int)) to theQueryHandlerssubscribed to that specific query'snameandresponse typecombination.A simple implementation of theQueryHandlingComponentinterface, allowing for easy registration ofQueryHandlersand otherQueryHandlingComponents.Simple implementation of theQueryUpdateEmitter, delegating operations to aQueryBusfor emitting update, completing subscription queries, and completing subscription queries exceptionally.SinkWrapper<T>Abstraction interface to bridge oldFluxSinkandSinks.ManyAPI with a common API.Exception thrown wheneverQueryBus.subscriptionQuery(SubscriptionQueryMessage, ProcessingContext, int)is invoked multiple times for the same.invalid reference
SubscriptionQueryMessageAResultMessageimplementation that holds incremental update of a subscription query.