View Source Commanded.Commands.Handler behaviour (Commanded v1.4.6)

Defines the behaviour a command handler module must implement to support command dispatch.

Example

An open account handler that delegates to a bank account aggregate:

defmodule OpenAccountHandler do
  @behaviour Commanded.Commands.Handler

  def handle(%BankAccount{} = aggregate, %OpenAccount{} = command) do
    %OpenAccount{account_number: account_number, initial_balance: initial_balance} = command

    BankAccount.open_account(aggregate, account_number, initial_balance)
  end
end

Summary

Types

aggregate()
command()
domain_event()
reason()

Callbacks

handle(aggregate, command)

Apply the given command to the event sourced aggregate.

Types

Link to this type

aggregate()

View Source 
@type aggregate() :: struct()
Link to this type

command()

View Source 
@type command() :: struct()
Link to this type

domain_event()

View Source 
@type domain_event() :: struct()
Link to this type

reason()

View Source 
@type reason() :: any()

Callbacks

Link to this callback

handle(aggregate, command)

View Source 
@callback handle(aggregate(), command()) ::
  domain_event()
  | [domain_event()]
  | {:ok, domain_event()}
  | {:ok, [domain_event()]}
  | :ok
  | nil
  | {:error, reason()}

Apply the given command to the event sourced aggregate.

You must return a single domain event, a list containing the pending events, or nil, [], or :ok when no events are produced.

You should return {:error, reason} on failure.