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, @Nullable MessageConverter converter)	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(io.axoniq.axonserver.connector.ResultStream<io.axoniq.axonserver.grpc.query.QueryResponse> stream,
 @Nullable MessageConverter converter)

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.

converter - the converter to be used for payload conversion

Method Details

buildResponseMessage

protected QueryResponseMessage buildResponseMessage(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse)

createAxonException

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

isError

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

Specified by:

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