imyaman

package com.saasovation.agilepm.domain.model.product;

@Value
class BacklogItemCommitted implements DomainEvent {
    Date occurredOn;
    BacklogItemId backlogItemId;
    SpringId committedToSprintId;
    TenantId tenantId;
}

package com.saasovation.agilepm.domain.model;

interface DomainEvent {
    Date occurredOn();
}

class BacklogItem extends AbstractAggregateRoot<BacklogItem> {
    void commitTo(Sprint spint) {
        // Some domain logic
        super.registerEvent(new BacklogItemCommitted(
                this.tenantId(),
                this.backlogItemId(),
                this.sprintId()
        ));
    }
}

class BacklogItemService {  // Application Service
     @TransactionalEventListener
    void commitBacklogItem(...) {
        backlogItem.commitTo(sprint);   // Publish BacklogItemCommitted event
    }
}

class BacklogItemService {  // Application Service
     @TransactionalEventListener
    void handleBacklogItemCommitted(BacklogItemCommitted event) {
        // BacklogItemCommitted 구독 후 처리
    }
}

@Aspect
class IdentityAccessEventProcessor {
    @Before("execution(* com.saasovation.identityaccess.application.*.**..))")
    public void listen() {
        DomainEventPublisher.instance()
            .subscribe(new DomainEventSubscriber<DomainEvent>() {
                public void handleEvent(DomainEvent aDomainEvent) {
                    store(aDomainEvent);
                }

                public Class<DomainEvent> subscribedToEventType() {
                    return DomainEvent.class;   // 모든 도메인 이벤트
                }
            });
    }
    private void store(DomainEvent aDomainEvent) {
        EventStore.instance().append(aDomainEvent);
    }
}

class StoreEvent {
    void append(DomainEvent aDomainEvent) {
        String eventSerializatoin = 
            EventStore.objectSerializer().serialize(aDomainEvent);
        StoredEvent storedEvent = 
            new StoredEvent(
                aDomainEvent.getClass().getName(),
                aDomainEvent.occuredOn(),
                eventSerialization);
        this.session().save(storedEvent);
        this.setStoredEvent(storedEvent);
    }
}

CREATE TABLE tbl_stored_event (
    event_id int(11) NOT NULL auto_increment,
    event_body varchar(65000) NOT NULL,
    occurred_on datetime NOT NULL,
    type_name varchar(100) NOT NULL,
    PRIMARY KEY (event_id)
)