Uses of Interface
org.axonframework.queryhandling.QueryResponseMessage
Packages that use QueryResponseMessage
-
Uses of QueryResponseMessage in org.axonframework.messaging.responsetypes
Classes in org.axonframework.messaging.responsetypes that implement QueryResponseMessageModifier and TypeClassDescriptionclassImplementation of a QueryResponseMessage that is aware of the requested response type and performs a just-in-time conversion to ensure the response is formatted as requested.Methods in org.axonframework.messaging.responsetypes that return QueryResponseMessageModifier and TypeMethodDescriptionConvertingResponseMessage.andMetaData(Map<String, ?> additionalMetaData) ConvertingResponseMessage.withMetaData(Map<String, ?> metaData) Constructors in org.axonframework.messaging.responsetypes with parameters of type QueryResponseMessageModifierConstructorDescriptionConvertingResponseMessage(ResponseType<R> expectedResponseType, QueryResponseMessage<?> responseMessage) Initialize a response message, usingexpectedResponseTypeto convert the payload from theresponseMessage, if necessary. -
Uses of QueryResponseMessage in org.axonframework.queryhandling
Classes in org.axonframework.queryhandling that implement QueryResponseMessageModifier and TypeClassDescriptionclassQueryResponseMessage implementation that takes all properties as constructor parameters.Methods in org.axonframework.queryhandling that return QueryResponseMessageModifier and TypeMethodDescriptionQueryResponseMessage.andMetaData(Map<String, ?> additionalMetaData) Returns a copy of this QueryResponseMessage with its MetaData merged with givenmetaData.static <R> QueryResponseMessage<R>GenericQueryResponseMessage.asNullableResponseMessage(Class<R> declaredType, Object result) Creates a QueryResponseMessage for the givenresultwith adeclaredTypeas the result type.static <R> QueryResponseMessage<R>GenericQueryResponseMessage.asResponseMessage(Class<R> declaredType, Throwable exception) Creates a Query Response Message with givendeclaredTypeandexception.static <R> QueryResponseMessage<R>GenericQueryResponseMessage.asResponseMessage(Object result) Creates a QueryResponseMessage for the givenresult.QueryResponseMessage.withMetaData(Map<String, ?> metaData) Returns a copy of this QueryResponseMessage with the givenmetaData.Methods in org.axonframework.queryhandling that return types with arguments of type QueryResponseMessageModifier and TypeMethodDescription<Q,R> CompletableFuture<QueryResponseMessage<R>> QueryBus.query(QueryMessage<Q, R> query) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName and responseType.<Q,R> CompletableFuture<QueryResponseMessage<R>> SimpleQueryBus.query(QueryMessage<Q, R> query) <Q,R> Stream<QueryResponseMessage<R>> QueryBus.scatterGather(QueryMessage<Q, R> query, long timeout, TimeUnit unit) Dispatch the givenqueryto all QueryHandlers subscribed to the givenquery's queryName/responseType.<Q,R> Stream<QueryResponseMessage<R>> SimpleQueryBus.scatterGather(QueryMessage<Q, R> query, long timeout, TimeUnit unit) default <Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>> QueryBus.streamingQuery(StreamingQueryMessage<Q, R> query) Builds aPublisherof responses to the givenquery.<Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>> SimpleQueryBus.streamingQuery(StreamingQueryMessage<Q, R> query) default <Q,I, U> SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName/initialResponseType/updateResponseType.default <Q,I, U> SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query, int updateBufferSize) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName/initialResponseType/updateResponseType.default <Q,I, U> SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated.<Q,I, U> SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query, int updateBufferSize) <Q,I, U> SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated.in favor use of {SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)
QueryBus.subscriptionQuery(SubscriptionQueryMessage, int)}