Uses of Interface
org.axonframework.messaging.responsetypes.ResponseType

Packages that use ResponseType

Package	Description
org.axonframework.commandhandling.gateway
org.axonframework.messaging.responsetypes
org.axonframework.queryhandling

Uses of ResponseType in org.axonframework.commandhandling.gateway

Methods in org.axonframework.commandhandling.gateway with parameters of type ResponseType

Modifier and Type	Method	Description
<C, R> CommandGatewayFactory	CommandGatewayFactory.registerCommandCallback(CommandCallback<C,R> callback, ResponseType<R> responseType)	Registers the callback, which is invoked for each sent command, unless Axon is able to detect that the result of the command does not match the type accepted by the callback.

Uses of ResponseType in org.axonframework.messaging.responsetypes

Classes in org.axonframework.messaging.responsetypes that implement ResponseType

Modifier and Type	Class	Description
class	AbstractResponseType<R>	Abstract implementation of the ResponseType which contains match functions for the majority of the Type options available.
class	InstanceResponseType<R>	A ResponseType implementation that will match with query handlers which return a single instance of the expected response type.
class	MultipleInstancesResponseType<R>	A ResponseType implementation that will match with query handlers which return a multiple instances of the expected response type.
class	OptionalResponseType<R>	A ResponseType implementation that will match with query handlers which return a single instance of the expected response type, but returns that as an Optional containing the result.
class	PublisherResponseType<R>	A ResponseType implementation that will match with query handlers that return a Publisher stream of the expected response type.

Methods in org.axonframework.messaging.responsetypes that return ResponseType

Modifier and Type	Method	Description
ResponseType<?>	OptionalResponseType.forSerialization()
ResponseType<?>	PublisherResponseType.forSerialization()
default ResponseType<?>	ResponseType.forSerialization()	Returns the ResponseType instance that should be used when serializing responses.
static <R> ResponseType<R>	ResponseTypes.instanceOf(Class<R> type)	Specify the desire to retrieve a single instance of type R when performing a query.
static <R> ResponseType<List<R>>	ResponseTypes.multipleInstancesOf(Class<R> type)	Specify the desire to retrieve a collection of instances of type R when performing a query.
static <R> ResponseType<Optional<R>>	ResponseTypes.optionalInstanceOf(Class<R> type)	Specify the desire to retrieve an Optional<R> when performing a query.
static <R> ResponseType<org.reactivestreams.Publisher<R>>	ResponseTypes.publisherOf(Class<R> type)	Specify the desire to retrieve a Publisher (reactive stream) of instances of type R when performing a query.

Constructors in org.axonframework.messaging.responsetypes with parameters of type ResponseType

Modifier	Constructor	Description
	ConvertingResponseMessage(ResponseType<R> expectedResponseType, QueryResponseMessage<?> responseMessage)	Initialize a response message, using expectedResponseType to convert the payload from the responseMessage, if necessary.

Uses of ResponseType in org.axonframework.queryhandling

Methods in org.axonframework.queryhandling that return ResponseType

Modifier and Type	Method	Description
ResponseType<R>	GenericQueryMessage.getResponseType()
ResponseType<R>	QueryMessage.getResponseType()	The type of response expected by the sender of the query
ResponseType<org.reactivestreams.Publisher<R>>	StreamingQueryMessage.getResponseType()
ResponseType<U>	GenericSubscriptionQueryMessage.getUpdateResponseType()
ResponseType<U>	SubscriptionQueryMessage.getUpdateResponseType()	Returns the type of incremental responses.

Methods in org.axonframework.queryhandling with parameters of type ResponseType

Modifier and Type	Method	Description
boolean	QuerySubscription.canHandle(ResponseType<?> queryResponseType)	Check if this QuerySubscription can handle the given queryResponseType, by calling the matches(Type) function on it and providing the set responseType of this subscription.
<R, Q> CompletableFuture<R>	DefaultQueryGateway.query(String queryName, Q query, ResponseType<R> responseType)
<R, Q> CompletableFuture<R>	QueryGateway.query(String queryName, Q query, ResponseType<R> responseType)	Sends given query over the QueryBus, expecting a response in the form of responseType from a single source.
default <R, Q> CompletableFuture<R>	QueryGateway.query(Q query, ResponseType<R> responseType)	Sends given query over the QueryBus, expecting a response in the form of responseType from a single source.
<R, Q> Stream<R>	DefaultQueryGateway.scatterGather(String queryName, Q query, ResponseType<R> responseType, long timeout, TimeUnit timeUnit)
<R, Q> Stream<R>	QueryGateway.scatterGather(String queryName, Q query, ResponseType<R> responseType, long timeout, TimeUnit timeUnit)	Sends given query over the QueryBus, expecting a response in the form of responseType from several sources.
default <R, Q> Stream<R>	QueryGateway.scatterGather(Q query, ResponseType<R> responseType, long timeout, TimeUnit timeUnit)	Sends given query over the QueryBus, expecting a response in the form of responseType from several sources.
<Q, I, U> SubscriptionQueryResult<I,U>	DefaultQueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, int updateBufferSize)
<Q, I, U> SubscriptionQueryResult<I,U>	DefaultQueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure, int updateBufferSize)	Deprecated. in favour of the {DefaultQueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, int)}
default <Q, I, U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType)	Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
<Q, I, U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, int updateBufferSize)	Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
default <Q, I, U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure)	Deprecated. in favour of using {QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType)}.
<Q, I, U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure, int updateBufferSize)	Deprecated. in favour of using {QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, int)}.
default <Q, I, U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType)	Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).

Constructors in org.axonframework.queryhandling with parameters of type ResponseType

Modifier	Constructor	Description
	GenericQueryMessage(Message<T> delegate, String queryName, ResponseType<R> responseType)	Initialize the Query Message, using given delegate as the carrier of payload and metadata and given queryName and expecting the given responseType.
	GenericQueryMessage(T payload, String queryName, ResponseType<R> responseType)	Initializes the message with the given payload, queryName and expected responseType.
	GenericQueryMessage(T payload, ResponseType<R> responseType)	Initializes the message with the given payload and expected responseType.
	GenericStreamingQueryMessage(Message<Q> delegate, String queryName, ResponseType<org.reactivestreams.Publisher<R>> responseType)	Initialize the Query Message, using given delegate as the carrier of payload and metadata and given queryName and expecting the given responseType.
	GenericStreamingQueryMessage(Q payload, String queryName, ResponseType<org.reactivestreams.Publisher<R>> responseType)	Initializes the message with the given payload, queryName and expected responseType.
	GenericStreamingQueryMessage(Q payload, ResponseType<org.reactivestreams.Publisher<R>> responseType)	Initializes the message with the given payload and expected responseType.
	GenericSubscriptionQueryMessage(Message<Q> delegate, String queryName, ResponseType<I> responseType, ResponseType<U> updateResponseType)	Initializes the message, using given delegate as the carrier of payload and metadata and given queryName, expected responseType and expected updateResponseType.
	GenericSubscriptionQueryMessage(Q payload, String queryName, ResponseType<I> responseType, ResponseType<U> updateResponseType)	Initializes the message with the given payload, queryName, expected responseType and expected updateResponseType.
	GenericSubscriptionQueryMessage(Q payload, ResponseType<I> responseType, ResponseType<U> updateResponseType)	Initializes the message with the given payload, expected responseType and expected updateResponseType.