@EventSourcingHandler
protected void on(BuyOrderPlacedEvent event) {
    buyOrders.add(new Order(event.getOrderId(),
                            event.getTransactionId(),
                            event.getItemPrice(),
                            event.getTradeCount(),
                            event.getPortfolioId(),
                            orderCounter++));
}
 

@EventSourcingHandler
protected void on(SellOrderPlacedEvent event) {
    sellOrders.add(new Order(event.getOrderId(),
                             event.getTransactionId(),
                             event.getItemPrice(),
                             event.getTradeCount(),
                             event.getPortfolioId(),
                             orderCounter++));
}
 

@EventSourcingHandler
protected void on(TradeExecutedEvent event) {
    Order highestBuyer = buyOrders.first();
    if (highestBuyer.getItemsRemaining() <= event.getTradeCount()) {
        buyOrders.remove(highestBuyer);
    }

    Order lowestSeller = sellOrders.first();
    if (lowestSeller.getItemsRemaining() <= event.getTradeCount()) {
        sellOrders.remove(lowestSeller);
    }
}
 

@EventSourcingHandler
public void on(ItemsReservedEvent event) {
    long available = obtainCurrentAvailableItems(event.getOrderBookId());
    availableItems.put(event.getOrderBookId(), available - event.getAmountOfItemsReserved());

    long reserved = obtainCurrentReservedItems(event.getOrderBookId());
    reservedItems.put(event.getOrderBookId(), reserved + event.getAmountOfItemsReserved());
}
 

@EventSourcingHandler
public void on(ItemReservationCancelledForPortfolioEvent event) {
    long reserved = obtainCurrentReservedItems(event.getOrderBookId());
    reservedItems.put(event.getOrderBookId(), reserved - event.getAmountOfCancelledItems());

    long available = obtainCurrentAvailableItems(event.getOrderBookId());
    availableItems.put(event.getOrderBookId(), available + event.getAmountOfCancelledItems());
}
 

@EventSourcingHandler
public void on(IssuedEvt evt) {
    log.debug("applying {}", evt);
    id = evt.getId();
    remainingValue = evt.getAmount();
    log.debug("new remaining value: {}", remainingValue);
}
 

@EventSourcingHandler
public void on(AccountCreatedEvent event) {
    logger.log(Level.INFO, "Applying: {0}.", event);

    this.accountId = event.getAccountId();
    this.overdraftLimit = event.getOverdraftLimit();
}
 

@EventSourcingHandler
public void on(CustomerCreatedEvent event) {
  log.info("Caught CustomerCreatedEvent: {}", event);
  this.customerId = event.getCustomerId();
  this.fullName = event.getFullName();
  this.age = event.getAge();
}
 

@EventSourcingHandler
public void on(AccountCreatedEvent event) {
    logger.log(Level.INFO, "Applying: {0}.", event);

    this.accountId = event.getAccountId();
    this.overdraftLimit = event.getOverdraftLimit();
}
 

@EventSourcingHandler
public void on(ProductAddedEvent evnt) {
    LOG.debug("Handling {} event: {}, {}", evnt.getClass().getSimpleName(), evnt.getId(), evnt.getName());
    this.id = evnt.getId();
    this.name = evnt.getName();
    LOG.trace("Done handling {} event: {}, {}", evnt.getClass().getSimpleName(), evnt.getId(), evnt.getName());
}
 

/*** EVENT HANDLERS ***/

    @EventSourcingHandler
    public void onApplicationDirectoryGroupsCreatedEvent(ApplicationDirectoryGroupsCreatedEvent event) {
        log.debug("onApplicationDirectoryGroupsCreatedEvent - id: %s - applicationName: %s - user: %s",
                event.getId(), event.getApplicationDirectoryGroups().getApplicationName(), event.getUser());
        this.id = event.getId();
        this.applicationName = event.getApplicationDirectoryGroups().getApplicationName();
        this.directoryGroupDNs = event.getApplicationDirectoryGroups().getDirectoryGroupDNs();
    }
 

/*** EVENT HANDLERS ***/

    @EventSourcingHandler
    @SuppressWarnings("unused")
    public void onModuleCreatedEvent(ModuleCreatedEvent event) {
        log.debug("onModuleCreatedEvent - moduleId: {} - key: {} - versionId: {} - user: {}",
                event.getModuleId(), event.getModule().getKey(), event.getModule().getVersionId(), event.getUser());
        logAfterEventVersionId(event.getModule().getVersionId());
        this.id = event.getModuleId();
        this.key = event.getModule().getKey();
        this.versionId = event.getModule().getVersionId();
        event.getModule().getTemplates().forEach(template ->
                this.templates.put(template.getName(), template)
        );
    }
 

@EventSourcingHandler
@SuppressWarnings("unused")
public void onModuleTechnosUpdatedEvent(ModuleTechnosUpdatedEvent event) {
    log.debug("onModuleTechnosUpdatedEvent - moduleId: {} - versionId: {} - user: {}",
            event.getModuleId(), event.getVersionId(), event.getUser());
    logAfterEventVersionId(event.getVersionId());
    this.versionId = event.getVersionId();
}
 

@EventSourcingHandler
@SuppressWarnings("unused")
public void onModuleDeletedEvent(ModuleDeletedEvent event) {
    log.debug("onModuleDeletedEvent - moduleId: {} - user: {}",
            event.getModuleId(), event.getUser());
    logAfterEventVersionId();
}
 

@EventSourcingHandler
public void onTemplateCreatedEvent(TemplateCreatedEvent event) {
    log.debug("onTemplateCreatedEvent - moduleId: {} - key: {} - templateName: {} - user: {}",
            event.getModuleId(), event.getModuleKey(), event.getTemplate().getName(), event.getUser());
    logAfterEventVersionId();
    this.templates.put(event.getTemplate().getName(), event.getTemplate());
}
 

@EventSourcingHandler
public void onTemplateUpdatedEvent(TemplateUpdatedEvent event) {
    log.debug("onTemplateCreatedEvent - moduleId: {} - key: {} - templateName: {} - user: {}",
            event.getModuleId(), event.getModuleKey(), event.getTemplate().getName(), event.getUser());
    logAfterEventVersionId();
    this.templates.put(event.getTemplate().getName(), event.getTemplate());
}
 

@EventSourcingHandler
public void onTemplateDeletedEvent(TemplateDeletedEvent event) {
    log.debug("onTemplateCreatedEvent - moduleId: {} - key: {} - templateName: {} - user: {}",
            event.getModuleId(), event.getModuleKey(), event.getTemplateName(), event.getUser());
    logAfterEventVersionId();
    this.templates.remove(event.getTemplateName());
}
 

/*** EVENT HANDLERS ***/

    @EventSourcingHandler
    public void onPlatformCreatedEvent(PlatformCreatedEvent event) {
        log.debug("onPlatformCreatedEvent - platformId: {} - key: {} - versionId: {} - user: {}",
                event.getPlatformId(), event.getPlatform().getKey(), event.getPlatform().getVersionId(), event.getUser());
        logAfterEventVersionId(event.getPlatform().getVersionId());
        this.id = event.getPlatformId();
        this.key = event.getPlatform().getKey();
        this.versionId = event.getPlatform().getVersionId();
    }
 

@EventSourcingHandler
public void onPlatformUpdatedEvent(PlatformUpdatedEvent event) {
    log.debug("onPlatformUpdatedEvent - platformId: {} - key: {} - versionId: {} - user: {}",
            event.getPlatformId(), event.getPlatform().getKey(), event.getPlatform().getVersionId(), event.getUser());
    logAfterEventVersionId(event.getPlatform().getVersionId());
    this.versionId = event.getPlatform().getVersionId();
}
 

@EventSourcingHandler
public void onPlatformModulePropertiesUpdatedEvent(PlatformModulePropertiesUpdatedEvent event) {
    log.debug("onPlatformModulePropertiesUpdatedEvent - platformId: {} - versionId: {} - user: {}",
            event.getPlatformId(), event.getPlatformVersionId(), event.getUser());
    logAfterEventVersionId(event.getPlatformVersionId());
    this.versionId = event.getPlatformVersionId();
}
 

@EventSourcingHandler
public void onPlatformPropertiesUpdatedEvent(PlatformPropertiesUpdatedEvent event) {
    log.debug("onPlatformPropertiesUpdatedEvent - platformId: {} - versionId: {} - user: {}",
            event.getPlatformId(), event.getPlatformVersionId(), event.getUser());
    logAfterEventVersionId(event.getPlatformVersionId());
    this.versionId = event.getPlatformVersionId();
}
 

/*** EVENT HANDLERS ***/

    @EventSourcingHandler
    @SuppressWarnings("unused")
    public void onTechnoCreatedEvent(TechnoCreatedEvent event) {
        this.id = event.getTechnoId();
        this.key = event.getTechno().getKey();
        event.getTechno().getTemplates().forEach(template -> templates.put(template.getName(), template));
        log.debug("Techno created (aggregate is live ? {})", isLive());
    }
 

@EventSourcingHandler
public void on(UserCreatedEvent event) {
    this.userId = event.getUserId();
    this.passwordHash = event.getPassword();
}
 

@EventSourcingHandler
public void on(CompanyCreatedEvent event) {
    companyId = event.getCompanyId();
}
 

@EventSourcingHandler
protected void on(OrderBookCreatedEvent event) {
    this.orderBookId = event.getOrderBookId();
    buyOrders = new TreeSet<>(BUY_ORDER_COMPARATOR);
    sellOrders = new TreeSet<>(SELL_ORDER_COMPARATOR);
}
 

@EventSourcingHandler
protected void onTradeExecuted(TradeExecutedEvent event) {
    recordTraded(event.getTradeCount());
}
 

@EventSourcingHandler
public void on(BuyTransactionStartedEvent event) {
    transactionId = event.getTransactionId();
    amountOfItems = event.getTotalItems();
    type = TransactionType.BUY;
}
 

@EventSourcingHandler
public void on(SellTransactionStartedEvent event) {
    transactionId = event.getTransactionId();
    amountOfItems = event.getTotalItems();
    type = TransactionType.SELL;
}
 

@SuppressWarnings("unused")
@EventSourcingHandler
public void on(BuyTransactionExecutedEvent event) {
    amountOfExecutedItems = amountOfItems;
}
 

@SuppressWarnings("unused")
@EventSourcingHandler
public void on(SellTransactionExecutedEvent event) {
    amountOfExecutedItems = amountOfItems;
}