Package org.axonframework.axonserver.connector.query

Class QueryResponseMessageStream

java.lang.Object

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

org.axonframework.axonserver.connector.query.QueryResponseMessageStream

All Implemented Interfaces:

MessageStream<QueryResponseMessage>

@Internal
public class QueryResponseMessageStream
extends AbstractQueryResponseMessageStream<io.axoniq.axonserver.grpc.query.QueryResponse>

A MessageStream implementation that wraps an ResultStream of QueryResponses, using QueryConverter.

Since:

5.0.0

Author:

Steven van Beelen

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
QueryResponseMessageStream(io.axoniq.axonserver.connector.ResultStream<io.axoniq.axonserver.grpc.query.QueryResponse> stream)	Initializes a new instance of the QueryResponseMessageStream which wraps a ResultStream of QueryResponse objects.

Method Summary

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

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

QueryResponseMessageStream

public QueryResponseMessageStream(@Nonnull
 io.axoniq.axonserver.connector.ResultStream<io.axoniq.axonserver.grpc.query.QueryResponse> stream)

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

Parameters:

stream - the ResultStream of QueryResponse 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.QueryResponse queryResponse)

Specified by:

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

createAxonException

@Nonnull
protected AxonException createAxonException(@Nonnull
 io.axoniq.axonserver.grpc.query.QueryResponse queryResponse)

Specified by:

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

isError

protected boolean isError(@Nonnull
 io.axoniq.axonserver.grpc.query.QueryResponse queryResponse)

Specified by:

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