import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(DeleteEvent event, @SequenceNumber Long version) {
    if (event.getLogic()){
        dao.logicDelete(event.getId());
    } else {
        dao.delete(event.getId());
    }
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(UserCreateEvent event, @SequenceNumber Long version) {
    UserEntry user = new UserEntry();
    user.setId(event.getId());
    user.setUsername(event.getUsername());
    user.setPassword(event.getPassword());
    user.setPhone(event.getPhone());
    user.setEmail(event.getEmail());
    user.setEnable(event.getEnable());
    dao.save(user);
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(OrgCreateEvent event, @SequenceNumber Long version) {
    OrgEntry org = new OrgEntry();
    org.setId(event.getId());
    if (StringUtils.isNotEmpty(event.getParentId())){
        OrgEntry parent = dao.findOne(event.getParentId());
        org.setParent(parent);
    }
    org.setCode(event.getCode());
    org.setName(event.getName());
    org.setOrderNum(event.getOrderNum());
    org.setEnable(event.getEnable());
    org.setOpen(event.getOpen());
    dao.save(org);
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(MoneyAddedEvent event) {
    BankAccountEntry bankAccountEntry = repository.findOneByAxonBankAccountId(event.getBankAccountId());
    bankAccountEntry.setBalance(bankAccountEntry.getBalance() + event.getAmount());

    repository.save(bankAccountEntry);

    broadcastUpdates();
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(BankTransferCreatedEvent event) {
    repository.save(new BankTransferEntry(event.getBankTransferId(),
                                          event.getSourceBankAccountId(),
                                          event.getDestinationBankAccountId(),
                                          event.getAmount()));
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(BankTransferCreatedEvent event) throws Exception {
    this.BankTransferId = event.getBankTransferId();
    this.sourceBankAccountId = event.getSourceBankAccountId();
    this.destinationBankAccountId = event.getDestinationBankAccountId();
    this.amount = event.getAmount();
    this.status = Status.STARTED;
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(TaskMarkedForCompletionEvent taskMarkedForCompletionEvent) {
  log.info("TaskMarkedForCompletionEvent received for task with taskId: {}", taskMarkedForCompletionEvent.getTaskId());
  final TaskQueryObject task = taskQueryObjectRepository.findOne(taskMarkedForCompletionEvent.getTaskId());
  if (taskIsCompletable(task)) {
    task.setEventType(task.getEventType().next());
    taskQueryObjectRepository.save(task);
    log.info(task.toString());
  }
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(ToDoItemCreatedEvent event, @Timestamp Instant time) {
	System.out.println(">> Receiving event: " + event);
	System.out.println(String.format("We've got something qualified to do: %s (%s, created at %s)",
			event.getDescription(),
			event.getTodoId(),
			time.toString()));
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(ToDoItemCreatedEvent event, @Timestamp Instant time) {
	System.out.println(">> Receiving event: " + event);
	System.out.println(String.format("We've got something to do: %s (%s, created at %s)",
			event.getDescription(),
			event.getTodoId(),
			time.toString()));
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(StepAddedEvent sae) {
    PreparationQueryObject prep = repo.findOne(sae.getId());
    prep.getSteps().add(sae.getStepType());
    PreparationQueryObject save = repo.save(prep);
    System.out.println("added one step:" + save);
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void doWith(final Method method) throws IllegalArgumentException, IllegalAccessException {
	if (method.isAnnotationPresent(EventHandler.class)) {
		result.set(true);
	}
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(BasketCreatedEvent event) {
    basketRepository.save(new ReadBasket(event.id()));
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void on(BasketCreatedEvent event) {
    this.id = event.id();
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(CreateAggregate event) {
    countDown.countDown();
}
 

import org.axonframework.eventhandling.EventHandler; //导入依赖的package包/类
@EventHandler
public void handle(CreateAggregate event) {
    log.info("Event {} handled by event listener", event);
}