org.axonframework.queryhandling

Interface QueryUpdateEmitter

All Known Implementing Classes:

SimpleQueryBus

public interface QueryUpdateEmitter

Component which informs subscription queries about updates, errors and when there are no more updates.

If any of the emitter functions in this interface are called from a message handling function (e.g. an EventHandler annotated function), then that call will automatically be tied into the lifecycle of the current UnitOfWork to ensure correct order of execution.

Added, implementations of this class should thus respect any current UnitOfWork in the UnitOfWork.Phase.STARTED phase for any of the emitting functions. If this is the case then the emitter call action should be performed during the UnitOfWork.Phase.AFTER_COMMIT. Otherwise the operation can be executed immediately.

Since:

3.3

Author:

Milan Savic

Method Summary

Modifier and Type	Method and Description
default <Q> void	complete(Class<Q> queryType, Predicate<? super Q> filter) Completes subscription queries matching given query type and filter.
void	complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter) Completes subscription queries matching given filter.
default <Q> void	completeExceptionally(Class<Q> queryType, Predicate<? super Q> filter, Throwable cause) Completes with an error subscription queries matching given query type and filter
void	completeExceptionally(Predicate<SubscriptionQueryMessage<?,?,?>> filter, Throwable cause) Completes with an error subscription queries matching given filter.
default <Q,U> void	emit(Class<Q> queryType, Predicate<? super Q> filter, SubscriptionQueryUpdateMessage<U> update) Emits given incremental update to subscription queries matching given query type and filter.
default <Q,U> void	emit(Class<Q> queryType, Predicate<? super Q> filter, U update) Emits given incremental update to subscription queries matching given query type and filter.
<U> void	emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, SubscriptionQueryUpdateMessage<U> update) Emits incremental update (as return value of provided update function) to subscription queries matching given filter.
default <U> void	emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, U update) Emits given incremental update to subscription queries matching given filter.

Method Detail

emit

<U> void emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter,
              SubscriptionQueryUpdateMessage<U> update)

Emits incremental update (as return value of provided update function) to subscription queries matching given filter.

Type Parameters:

U - the type of the update

Parameters:

filter - predicate on subscription query message used to filter subscription queries

update - incremental update message

emit

default <U> void emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter,
                      U update)

Emits given incremental update to subscription queries matching given filter. If an update is null, emit will be skipped. In order to send nullable updates, use emit(Class, Predicate, SubscriptionQueryUpdateMessage) or emit(Predicate, SubscriptionQueryUpdateMessage) methods.

Type Parameters:

U - the type of the update

Parameters:

filter - predicate on subscription query message used to filter subscription queries

update - incremental update

emit

default <Q,U> void emit(Class<Q> queryType,
                        Predicate<? super Q> filter,
                        SubscriptionQueryUpdateMessage<U> update)

Emits given incremental update to subscription queries matching given query type and filter.

Type Parameters:

Q - the type of the query

U - the type of the update

Parameters:

queryType - the type of the query

filter - predicate on query payload used to filter subscription queries

update - incremental update message

emit

default <Q,U> void emit(Class<Q> queryType,
                        Predicate<? super Q> filter,
                        U update)

Emits given incremental update to subscription queries matching given query type and filter. If an update is null, emit will be skipped. In order to send nullable updates, use emit(Class, Predicate, SubscriptionQueryUpdateMessage) or emit(Predicate, SubscriptionQueryUpdateMessage) methods.

Type Parameters:

Q - the type of the query

U - the type of the update

Parameters:

queryType - the type of the query

filter - predicate on query payload used to filter subscription queries

update - incremental update

complete

void complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter)

Completes subscription queries matching given filter.

Parameters:

filter - predicate on subscription query message used to filter subscription queries

complete

default <Q> void complete(Class<Q> queryType,
                          Predicate<? super Q> filter)

Completes subscription queries matching given query type and filter.

Type Parameters:

Q - the type of the query

Parameters:

queryType - the type of the query

filter - predicate on query payload used to filter subscription queries

completeExceptionally

void completeExceptionally(Predicate<SubscriptionQueryMessage<?,?,?>> filter,
                           Throwable cause)

Completes with an error subscription queries matching given filter.

Parameters:

filter - predicate on subscription query message used to filter subscription queries

cause - the cause of an error

completeExceptionally

default <Q> void completeExceptionally(Class<Q> queryType,
                                       Predicate<? super Q> filter,
                                       Throwable cause)

Completes with an error subscription queries matching given query type and filter

Type Parameters:

Q - the type of the query

Parameters:

queryType - the type of the query

filter - predicate on query payload used to filter subscription queries

cause - the cause of an error