org.axonframework.queryhandling.registration

Class FailingDuplicateQueryHandlerResolver

java.lang.Object

org.axonframework.queryhandling.registration.FailingDuplicateQueryHandlerResolver

All Implemented Interfaces:

DuplicateQueryHandlerResolver

public class FailingDuplicateQueryHandlerResolver
extends Object
implements DuplicateQueryHandlerResolver

Implementation of DuplicateQueryHandlerResolver that throws a DuplicateQueryHandlerSubscriptionException when a duplicate registration is detected.

Since:

4.6.0

Author:

Mitchell Herrijgers

Method Summary

Modifier and Type	Method and Description
static FailingDuplicateQueryHandlerResolver	instance() Returns a DuplicateQueryHandlerResolver that throws an exception when a duplicate registration is detected
List<QuerySubscription<?>>	resolve(String queryName, Type responseType, List<QuerySubscription<?>> registeredHandlers, QuerySubscription<?> candidateHandler) Chooses what to do when a duplicate handler is registered, returning the handlers that should be selected for query handling, or otherwise throwing an exception to reject registration altogether.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

instance

public static FailingDuplicateQueryHandlerResolver instance()

Returns a DuplicateQueryHandlerResolver that throws an exception when a duplicate registration is detected

Returns:

a DuplicateQueryHandlerResolver that throws an exception when a duplicate registration is detected

resolve

public List<QuerySubscription<?>> resolve(String queryName,
                                          Type responseType,
                                          List<QuerySubscription<?>> registeredHandlers,
                                          QuerySubscription<?> candidateHandler)

Description copied from interface: DuplicateQueryHandlerResolver

Chooses what to do when a duplicate handler is registered, returning the handlers that should be selected for query handling, or otherwise throwing an exception to reject registration altogether.

Specified by:

resolve in interface DuplicateQueryHandlerResolver

Parameters:

queryName - The name of the query for which the duplicate was detected

registeredHandlers - the MessageHandler instances already registered with the Query Bus

candidateHandler - the MessageHandler that is newly registered and conflicts with the existing registrations

Returns:

the resolved MessageHandler instances. It is up to the implementation to discard implementations already in the list