HeroesOfDomainDrivenDesign.EventSourcing.Java.Axon.Spring/src/main/java/com/dddheroes/heroesofddd/astrologers/write/Astrologers.java at master · MateuszNaKodach/HeroesOfDomainDrivenDesign.EventSourcing.Java.Axon.Spring · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package com.dddheroes.heroesofddd.astrologers.write;

import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.OnlyOneSymbolPerWeek;
import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.ProclaimWeekSymbol;
import com.dddheroes.heroesofddd.astrologers.events.WeekSymbolProclaimed;
import org.axonframework.commandhandling.CommandHandler;
import org.axonframework.eventsourcing.EventSourcingHandler;
import org.axonframework.modelling.command.AggregateCreationPolicy;
import org.axonframework.modelling.command.AggregateIdentifier;
import org.axonframework.modelling.command.CreationPolicy;
import org.axonframework.spring.stereotype.Aggregate;

import static org.axonframework.modelling.command.AggregateLifecycle.apply;

@Aggregate
class Astrologers {

    @AggregateIdentifier
    private AstrologersId astrologersId;
    private MonthWeek week;

    @CommandHandler
    @CreationPolicy(AggregateCreationPolicy.CREATE_IF_MISSING)
    void decide(ProclaimWeekSymbol command) {
        new OnlyOneSymbolPerWeek(command, week).verify();

        apply(
                WeekSymbolProclaimed.event(
                        command.astrologersId(),
                        command.week(),
                        command.symbol()
                )
        );
    }

    @EventSourcingHandler
    void evolve(WeekSymbolProclaimed event) {
        this.astrologersId = new AstrologersId(event.astrologersId());
        this.week = new MonthWeek(event.month(), event.week());
    }

    Astrologers() {
        // required by Axon
    }
}