InMemoryQueryBus.java

package org.sanmibuh.ddd.infrastructure;

import java.util.List;

import org.sanmibuh.ddd.port.Query;

import org.sanmibuh.ddd.port.QueryBus;

import org.sanmibuh.ddd.port.QueryHandler;

public final class InMemoryQueryBus implements QueryBus {

  private final HandlerLookup<QueryHandler<?, ?>> lookup;

  public InMemoryQueryBus(final List<QueryHandler<?, ?>> handlers) {

    lookup = new HandlerLookup<>(handlers, QueryHandler.class);

  }

  @Override

  @SuppressWarnings("unchecked")

  public <R> R dispatch(final Query<R> query) {

    final QueryHandler<Query<R>, R> handler =

        (QueryHandler<Query<R>, R>) lookup.find(query.getClass());

    return handler.handle(query);

  }

}

Active mutators

• CONDITIONALS_BOUNDARY
• EMPTY_RETURNS
• FALSE_RETURNS
• INCREMENTS
• INVERT_NEGS
• MATH
• NEGATE_CONDITIONALS
• NULL_RETURNS
• PRIMITIVE_RETURNS
• TRUE_RETURNS
• VOID_METHOD_CALLS

Tests examined

• org.sanmibuh.ddd.infrastructure.InMemoryQueryBusTest.[engine:junit-jupiter]/[class:org.sanmibuh.ddd.infrastructure.InMemoryQueryBusTest]/[method:should_returnQueryResult_whenHandlerIsRegistered()] (0 ms)