import org.apache.isis.applib.services.eventbus.ActionDomainEvent; //导入依赖的package包/类
@Test
public void subscriberReceivesEvent() throws Exception {

    // given
    assertThat(toDoItemSubscriptions.getSubscriberBehaviour()).isEqualTo(DemoBehaviour.ANY_EXECUTE_ACCEPT);
    toDoItem.setComplete(true);

    // when
    wrap(toDoItem).notYetCompleted();

    // then
    assertThat(toDoItem.isComplete()).isFalse();

    // and then
    final ActionDomainEvent<ToDoItem> ev = toDoItemSubscriptions.mostRecentlyReceivedEvent(ActionDomainEvent.class);
    assertThat(ev).isNotNull();

    final ToDoItem source = ev.getSource();
    assertThat(source).isEqualTo(toDoItem);
    assertThat(ev.getIdentifier().getMemberName()).isEqualTo("notYetCompleted");
}
 

import org.apache.isis.applib.services.eventbus.ActionDomainEvent; //导入依赖的package包/类
private void vetoIf(
        final org.apache.isis.applib.services.eventbus.ActionDomainEvent<?> ev,
        final DemoBehaviour... behaviours) {
    if (ev.getEventPhase() != org.apache.isis.applib.services.eventbus.AbstractDomainEvent.Phase.HIDE) {
        return;
    }
    for (final DemoBehaviour behaviour : behaviours) {
        if(getSubscriberBehaviour() == behaviour) {
            ev.hide();
        }
    }
}
 

import org.apache.isis.applib.services.eventbus.ActionDomainEvent; //导入依赖的package包/类
@Programmatic
@com.google.common.eventbus.Subscribe
@org.axonframework.eventhandling.annotation.EventHandler
public void on(final org.apache.isis.applib.services.eventbus.ActionDomainEvent<?> ev) {
    recordEvent(ev);
    switch(ev.getEventPhase()) {
        case HIDE:
            if(getSubscriberBehaviour() == DemoBehaviour.UPDATE_COST_ACTION_HIDE && 
                    ev.getIdentifier().getMemberName().equals("updateCost")) {
                ev.hide();
            }
            break;
        case DISABLE:
            if(getSubscriberBehaviour() == DemoBehaviour.UPDATE_COST_ACTION_DISABLE && 
                    ev.getIdentifier().getMemberName().equals("updateCost")) {
                ev.disable("ToDoItemSubscriptions says: updateCost action disabled!");
            }
            break;
        case VALIDATE:
            if(getSubscriberBehaviour() == DemoBehaviour.UPDATE_COST_ACTION_INVALIDATE &&
                    ev.getIdentifier().getMemberName().equals("updateCost")) {
                ev.invalidate("ToDoItemSubscriptions says: can't invoke updateCost action with these args!");
            }
            break;
        case EXECUTING:
            break;
        case EXECUTED:
            //container.is
            //LOG.info("Received ActionDomainEvent, " + source.toString() + ", invoked " + ev.getIdentifier().getMemberName());
            onExecutedThrowExceptionIfSet(ev);
            break;
    }
}
 

import org.apache.isis.applib.services.eventbus.ActionDomainEvent; //导入依赖的package包/类
void logEvent(final ToDoAppDomainModule.ActionDomainEvent<?> ev) {
    switch(ev.getEventPhase()) {
    case HIDE:
        break;
    case DISABLE:
        break;
    case VALIDATE:
        break;
    case EXECUTING:
        break;
    case EXECUTED:
        LOG.info("Received {} for {}", ev.getClass().getName(), ev.getSource().toString());
        break;
    }
}
 

import org.apache.isis.applib.services.eventbus.ActionDomainEvent; //导入依赖的package包/类
private void onExecutedThrowExceptionIfSet(final ActionDomainEvent<?> ev) {
    if(ev != null && ev.getSemantics().isSafeInNature()) {
        return;
    }
    onExecutedThrowExceptionIfSet();
}