import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
@Override
protected Cluster doSelectCluster(EventListener eventListener, Class<?> listenerType) {
    final String packageName = listenerType.getPackage().getName();
    final Matcher matcher = pattern.matcher(packageName);
    final String group;

    if ( ! matcher.matches()) {
        group = "default";
        LOGGER.error("No cluster name matched from package '{}' using regex '{}'. Using '{}' as default cluster name",
                packageName, pattern, group);
    } else {
        group = matcher.group(1);
    }

    Cluster cluster = cache.get(group);

    if (null == cluster) {
        cluster = clusterFactory.create(group);
        cache.put(group, cluster);
    }

    return cluster;
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
@Override
public void after() {
    for (final EventListener eventListener : currentEventListeners) {
        currentEventBus.unsubscribe(eventListener);
    }
    currentEventListeners.clear();

    if (currentTerminal instanceof Closeable) {
        try {
            ((Closeable)currentTerminal).close();
        } catch (IOException e) {
            LOGGER.error("Unexpected error while shutdown the terminal");
        }
    }

    for (final EventMessage eventMessage : eventMessages) {
        final String topic = currentTopicStrategy.getTopic(eventMessage);
        topicStatement.remove(topic);
        LOGGER.debug("Deleted topic : {}", topic);
    }

    currentTopicStrategy = null;
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
@Test
public void onClusterCreated_withOneEventListener_createOneCluster() {
    // Given
    final String category = "fooBar";

    final ConsumerConnector consumerConnector = mock(ConsumerConnector.class);

    final ConsumerFactory consumerFactory = mock(ConsumerFactory.class);
    when(consumerFactory.createConnector(category)).thenReturn(consumerConnector);

    final Cluster cluster = mock(Cluster.class);
    when(cluster.getName()).thenReturn(category);
    when(cluster.getMembers()).thenReturn(Sets.<EventListener>newHashSet(mock(EventListener.class)));

    final KafkaTerminal terminal = new KafkaTerminal(consumerFactory, mock(ProducerFactory.class));

    // When
    terminal.onClusterCreated(cluster);

    // Then
    assertEquals(1, terminal.getClusterListeners().size());
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
@Test
public void onClusterCreated_withTwoEventListeners_createOneCluster() {
    // Given
    final String category = "fooBar";

    final ConsumerConnector consumerConnector = mock(ConsumerConnector.class);

    final ConsumerFactory consumerFactory = mock(ConsumerFactory.class);
    when(consumerFactory.createConnector(category)).thenReturn(consumerConnector);

    final Cluster cluster = mock(Cluster.class);
    when(cluster.getName()).thenReturn(category);
    when(cluster.getMembers()).thenReturn(Sets.<EventListener>newHashSet(mock(EventListener.class), mock(EventListener.class)));

    final KafkaTerminal terminal = new KafkaTerminal(consumerFactory, mock(ProducerFactory.class));

    // When
    terminal.onClusterCreated(cluster);

    // Then
    assertEquals(1, terminal.getClusterListeners().size());
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void addEventHandler(Object eventHandler) {
    if(!m_eventHandlers.containsKey(eventHandler)) {
        EventListener eventListener = new AnnotationEventListenerAdapter(eventHandler);
        m_eventBus.subscribe(eventListener);

        m_eventHandlers.put(eventHandler,eventListener);
    }
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void addEventHandler(Object eventHandler) {
    if(!m_eventHandlers.containsKey(eventHandler)) {
        EventListener eventListener = new AnnotationEventListenerAdapter(eventHandler);
        m_evtBus.subscribe(eventListener);

        m_eventHandlers.put(eventHandler,eventListener);
    }
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public static boolean isNotEventHandlerSubclass(final Class<?> beanClass) {
	return !EventListener.class.isAssignableFrom(beanClass);
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void subscribe(final EventListener eventListener) {
    checkState(currentEventBus != null, "Unable to subscribe event listener : the event bus is undefined");
    LOGGER.debug("Subscribing event listener : {}",  eventListener);
    currentEventBus.subscribe(eventListener);
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public EventListenerA(final EventListener delegate) {
    super(delegate);
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public EventListenerB(final EventListener delegate) {
    super(delegate);
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public EventListenerWrapper(final EventListener delegate) {
    this.delegate = Optional.fromNullable(delegate);
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void addEventListener(EventListener eventListener) {
    if(m_eventListeners.add(eventListener)) {
        m_eventBus.subscribe(eventListener);
    }
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void removeEventListener(EventListener eventListener) {
    if(eventListener != null) {
        m_eventBus.unsubscribe(eventListener);
    }
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void addEventListener(EventListener eventListener) {
    if(m_eventListeners.add(eventListener)) {
        m_evtBus.subscribe(eventListener);
    }
}
 

import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void removeEventListener(EventListener eventListener) {
    if(eventListener != null) {
        m_evtBus.unsubscribe(eventListener);
    }
}