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)	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(@Nonnull
 io.axoniq.axonserver.connector.ResultStream<io.axoniq.axonserver.grpc.query.QueryUpdate> stream)

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.

Method Details

buildResponseMessage

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

Specified by:

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

createAxonException

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

Specified by:

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

isError

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

Specified by:

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