Package io.axoniq.framework.springcloud.query
SpringCloudQueryBusConnector rotates each query over the members advertising its name, and either invokes
this application's own handler when the chosen member is the local one, or hands the query to the transport. A query
may be answered any number of times, so it is one request answered by a stream of Server-Sent Events:
QueryDispatchRequest carries it out, QueryDispatchResponse and QueryDispatchFailure carry the
answer back, and ServerSentEventReader reads them without a reactive stack. RemoteQueryDispatcher
sends a query, SpringCloudQueryController receives it, and IncomingQueryInvoker invokes the local
handler with it, writing every response to a QueryResponseSink, which SseQueryResponseSink adapts to
the response stream.
A subscription query reaches every member advertising its name: each one receives a
SubscriptionQueryRequest, registers the subscription, and streams the updates it emits back over the same
kind of response stream. The initial result is asked for as a regular query.
-
ClassDescriptionSends queries to other members over HTTP, reading the responses they stream back as Server-Sent Events.Turns a
QueryDispatchRequestreceived from another member into an invocation of this application's local query handler, writing every response it produces to aQueryResponseSink.Raised when a query could not be sent to a member, or its responses could not be read from one.The wire representation of a failure that ended a query's response stream.The wire representation of a query sent to another member of the cluster.The wire representation of one response to a query, carried by a single event of the response stream.What kind of failure ended a query's response stream, as reported to the member that dispatched the query.Where a member writes the responses to a query it is answering for another member.Sends a query to another member of the cluster and reports the responses it streams back.What a member reports about a subscription besides the updates themselves.Raised when a query's responses can no longer be written to the member that asked for them.A single event read from a Server-Sent Events stream.AQueryBusConnectordistributing queries over the members a Spring Cloud discovery implementation reports.Receives queries sent by other members of the cluster over HTTP, answering them with a stream of responses.Configuration of theSpringCloudQueryController.Writes a query's responses to the member that asked, as events of a Server-Sent Events stream.Raised when the members able to answer a subscription query changed while it was active.A subscription query as one member sends it to another.Raised when a query received from another member cannot be read.