io.eventuate

Class ReflectiveMutableCommandProcessingAggregate<T extends ReflectiveMutableCommandProcessingAggregate<T,CT>,CT extends Command>

java.lang.Object

io.eventuate.ReflectiveMutableCommandProcessingAggregate<T,CT>

Type Parameters:

T - the aggregate class

CT - the aggregate's command class

All Implemented Interfaces:

Aggregate<T>, CommandProcessingAggregate<T,CT>

public class ReflectiveMutableCommandProcessingAggregate<T extends ReflectiveMutableCommandProcessingAggregate<T,CT>,CT extends Command>
extends java.lang.Object
implements CommandProcessingAggregate<T,CT>

A mutable aggregate that uses reflection to process commands and apply events

See Also:

Event,

Here is an example of an aggregate:

 public class Account extends ReflectiveMutableCommandProcessingAggregate>Account, AccountCommand< {

 private BigDecimal balance;

 public BigDecimal getBalance() {
   return balance;
 }
 
 public List>Event< process(CreateAccountCommand cmd) {
   return EventUtil.events(new AccountCreatedEvent(cmd.getInitialBalance()));
 }

 public void apply(AccountCreatedEvent event) {
   this.balance = event.getInitialBalance();
 }

 public List>Event< process(DebitAccountCommand cmd) {
   return EventUtil.events(new AccountDebitedEvent(cmd.getAmount(), cmd.getTransactionId()));
 }

 public void apply(AccountDebitedEvent event) {
   this.balance = this.balance.subtract(event.getAmount());
 }

 public List>Event< process(NoopAccountCommand cmd) {
  return Collections.emptyList();
 }

 }  

Constructor Summary

Constructors

Constructor and Description
ReflectiveMutableCommandProcessingAggregate()

Method Summary

Modifier and Type	Method and Description
T	applyEvent(Event event) Apply an event by invoking an apply() method whose parameter class matches the event's class
java.util.List<Event>	processCommand(CT cmd) Processes a command by invoking a process() method whose parameter class matches the command's class

Methods inherited from class java.lang.Object

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

Constructor Detail

ReflectiveMutableCommandProcessingAggregate

public ReflectiveMutableCommandProcessingAggregate()

Method Detail

applyEvent

public T applyEvent(Event event)

Apply an event by invoking an apply() method whose parameter class matches the event's class

Specified by:

applyEvent in interface Aggregate<T extends ReflectiveMutableCommandProcessingAggregate<T,CT>>

Parameters:

event - the event representing the state change

Returns:

this

processCommand

public java.util.List<Event> processCommand(CT cmd)

Processes a command by invoking a process() method whose parameter class matches the command's class

Specified by:

processCommand in interface CommandProcessingAggregate<T extends ReflectiveMutableCommandProcessingAggregate<T,CT>,CT extends Command>

Parameters:

cmd - the command to process

Returns:

a list (state changing) events