Package org.axonframework.axonserver.connector.query

Class QueryUpdateMessageStream

java.lang.Object

org.axonframework.axonserver.connector.query.AbstractQueryResponseMessageStream<io.axoniq.axonserver.grpc.query.QueryUpdate>

org.axonframework.axonserver.connector.query.QueryUpdateMessageStream

All Implemented Interfaces:

MessageStream<QueryResponseMessage>

public class QueryUpdateMessageStream
extends AbstractQueryResponseMessageStream<io.axoniq.axonserver.grpc.query.QueryUpdate>

A specialized implementation of AbstractQueryResponseMessageStream that processes a stream of QueryUpdate objects and transforms them into QueryResponseMessage instances. This class is used to handle query update, including error handling and response message creation.

This class relies on its abstract superclass to manage the underlying ResultStream, implementing functionality specific to QueryUpdate to determine whether a message represents an error and to transform such update into structured responses or exceptions.

Nested Class Summary

Nested classes/interfaces inherited from interface org.axonframework.messaging.core.MessageStream

MessageStream.Empty<M extends Message>, MessageStream.Entry<M extends Message>, MessageStream.Single<M extends Message>

Constructor Summary

Constructors

Constructor	Description
QueryUpdateMessageStream(io.axoniq.axonserver.connector.ResultStream<io.axoniq.axonserver.grpc.query.QueryUpdate> stream, @Nullable MessageConverter converter)	Initializes a new instance of the QueryResponseMessageStream which wraps a ResultStream of QueryUpdate objects.

Method Summary

Modifier and Type	Method	Description
protected QueryResponseMessage	buildResponseMessage(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)
protected AxonException	createAxonException(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)
protected boolean	isError(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)

Methods inherited from class org.axonframework.axonserver.connector.query.AbstractQueryResponseMessageStream

close, error, hasNextAvailable, isCompleted, next, peek, setCallback

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.axonframework.messaging.core.MessageStream

cast, concatWith, filter, first, ignoreEntries, map, mapMessage, onClose, onComplete, onErrorContinue, onNext, reduce

Constructor Details

QueryUpdateMessageStream

public QueryUpdateMessageStream(io.axoniq.axonserver.connector.ResultStream<io.axoniq.axonserver.grpc.query.QueryUpdate> stream,
 @Nullable MessageConverter converter)

Initializes a new instance of the QueryResponseMessageStream which wraps a ResultStream of QueryUpdate objects.

Parameters:

stream - the ResultStream of QueryUpdate instances to be wrapped; must not be null. If null, a NullPointerException will be thrown.

converter - the converter used for QueryResponseMessage inline payload conversion

Method Details

buildResponseMessage

protected QueryResponseMessage buildResponseMessage(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)

createAxonException

protected AxonException createAxonException(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)

isError

protected boolean isError(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)

Specified by:

isError in class AbstractQueryResponseMessageStream<io.axoniq.axonserver.grpc.query.QueryUpdate>