| Interface | Description |
|---|---|
| QueryBus |
The mechanism that dispatches Query objects to their appropriate QueryHandlers.
|
| QueryGateway |
Interface towards the Query Handling components of an application.
|
| QueryHandlerAdapter |
Describes a class capable of subscribing to the query bus.
|
| QueryInvocationErrorHandler |
Interface describing a mechanism for the QueryMessage components to report errors.
|
| QueryMessage<T,R> |
Message type that carries a Query: a request for information.
|
| QueryResponseMessage<T> |
Message that contains the results of a Query.
|
| QueryUpdateEmitter |
Component which informs subscription queries about updates, errors and when there are no more updates.
|
| SinkWrapper<T> |
Abstraction interface to bridge old
FluxSink and Sinks.Many API with a common
API. |
| StreamingQueryMessage<Q,R> |
A special type of
QueryMessage used for initiating streaming queries. |
| SubscriptionQueryMessage<Q,I,U> |
Message type that carries a Subscription Query: a request for information.
|
| SubscriptionQueryResult<I,U> |
Result of the subscription query.
|
| SubscriptionQueryUpdateMessage<U> |
Message which holds incremental update of an subscription query.
|
| Class | Description |
|---|---|
| DefaultQueryGateway |
Implementation of the QueryGateway interface that allows the registration of dispatchInterceptors.
|
| DefaultQueryGateway.Builder |
Builder class to instantiate a
DefaultQueryGateway. |
| DefaultSubscriptionQueryResult<I,U> |
Default implementation of
SubscriptionQueryResult. |
| GenericQueryMessage<T,R> |
Generic implementation of the QueryMessage.
|
| GenericQueryResponseMessage<R> |
QueryResponseMessage implementation that takes all properties as constructor parameters.
|
| GenericStreamingQueryMessage<Q,R> |
Generic implementation of the
StreamingQueryMessage. |
| GenericSubscriptionQueryMessage<Q,I,U> |
Generic implementation of the
SubscriptionQueryMessage. |
| GenericSubscriptionQueryUpdateMessage<U> |
Generic
SubscriptionQueryUpdateMessage which holds incremental update of an subscription query. |
| LoggingQueryInvocationErrorHandler |
Implementation of the QueryInvocationErrorHandler that logs all errors to a given
Logger. |
| LoggingQueryInvocationErrorHandler.Builder |
Builder class to instantiate a
LoggingQueryInvocationErrorHandler. |
| QuerySubscription<R> |
Encapsulates the identifying fields of a Query Handler when one is subscribed to the
QueryBus. |
| SimpleQueryBus |
Implementation of the QueryBus that dispatches queries to the handlers within the JVM.
|
| SimpleQueryBus.Builder |
Builder class to instantiate a
SimpleQueryBus. |
| SimpleQueryUpdateEmitter |
Implementation of
QueryUpdateEmitter that uses Project Reactor to implement Update Handlers. |
| SimpleQueryUpdateEmitter.Builder |
Builder class to instantiate a
SimpleQueryUpdateEmitter. |
| SubscriptionQueryBackpressure | Deprecated
since 3.4.0 Reactor version, Sinks API does not use FluxSink.OverflowStrategy
|
| UpdateHandlerRegistration<U> |
Result of registering an Update Handler.
|
| Exception | Description |
|---|---|
| CompletedEmitterException |
Exception indicating that
QueryUpdateEmitter is completed, thus cannot be used to emit messages and report
errors. |
| NoHandlerForQueryException |
Exception indicating a query for a single result was executed, but no handlers were found that could provide an
answer.
|
| QueryExecutionException |
Exception indicating that the execution of a Query Handler has resulted in an exception.
|
| Annotation Type | Description |
|---|---|
| QueryHandler |
Marker annotation to mark any method on an object as being a QueryHandler.
|
Copyright © 2010–2023. All rights reserved.