Package io.axoniq.framework.axonserver.connector.query

@NullMarked package io.axoniq.framework.axonserver.connector.query

Part of the Axon Server Connector module. Contains classes related to query.

Classes

Class	Description
AbstractQueryResponseMessageStream<T>	An abstract implementation of the MessageStream interface that wraps a ResultStream.
AxonServerQueryBusConnector	AxonServerQueryBusConnector is an implementation of QueryBusConnector that connects to AxonServer to enable the dispatching and receiving of queries.
QueryConverter	Utility class to convert queries during dispatching and handling of subscribed query handlers in the AxonServerQueryBusConnector.
QueryResponseMessageStream	A MessageStream implementation that wraps an ResultStream of QueryResponses, using QueryConverter.
QueryUpdateMessageStream	A specialized implementation of AbstractQueryResponseMessageStream that processes a stream of QueryUpdate objects and transforms them into QueryResponseMessage instances.