InMemoryCommandBus.java

package org.sanmibuh.ddd.infrastructure;

import java.util.List;

import lombok.extern.slf4j.Slf4j;

import org.sanmibuh.ddd.port.Command;

import org.sanmibuh.ddd.port.CommandBus;

import org.sanmibuh.ddd.port.CommandHandler;

import org.sanmibuh.ddd.port.EventBus;

@Slf4j

public final class InMemoryCommandBus implements CommandBus {

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

  private final EventBus eventBus;

  public InMemoryCommandBus(final List<CommandHandler<?, ?>> handlers, final EventBus eventBus) {

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

    this.eventBus = eventBus;

  }

  @Override

  @SuppressWarnings("unchecked")

  public void dispatch(final Command command) {

    log.info("Dispatching command {}", command);

    final CommandHandler<Command, ?> handler =

        (CommandHandler<Command, ?>) lookup.find(command.getClass());

    handler.handle(command).forEach(eventBus::publish);

  }

}

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.InMemoryCommandBusTest.[engine:junit-jupiter]/[class:org.sanmibuh.ddd.infrastructure.InMemoryCommandBusTest]/[method:should_publishRecordedEvents_whenHandlerIsRegistered()] (6 ms)
• org.sanmibuh.ddd.infrastructure.InMemoryCommandBusTest.[engine:junit-jupiter]/[class:org.sanmibuh.ddd.infrastructure.InMemoryCommandBusTest]/[method:should_logDispatchedCommand_whenHandlerIsRegistered()] (47 ms)