本文整理汇总了Java中org.axonframework.eventhandling.EventListener类的典型用法代码示例。如果您正苦于以下问题:Java EventListener类的具体用法?Java EventListener怎么用?Java EventListener使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
EventListener类属于org.axonframework.eventhandling包,在下文中一共展示了EventListener类的15个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: doSelectCluster
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;
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:24,代码来源:ClassnameDynamicClusterSelector.java
示例2: after
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;
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:24,代码来源:TestEventBus.java
示例3: onClusterCreated_withOneEventListener_createOneCluster
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());
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:23,代码来源:KafkaTerminalUTest.java
示例4: onClusterCreated_withTwoEventListeners_createOneCluster
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());
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:23,代码来源:KafkaTerminalUTest.java
示例5: addEventHandler
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);
}
}
开发者ID:lburgazzoli,项目名称:lb-axon,代码行数:9,代码来源:AxonService.java
示例6: addEventHandler
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);
}
}
开发者ID:lburgazzoli,项目名称:lb-axon,代码行数:9,代码来源:AxonService.java
示例7: isNotEventHandlerSubclass
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public static boolean isNotEventHandlerSubclass(final Class<?> beanClass) {
return !EventListener.class.isAssignableFrom(beanClass);
}
开发者ID:kamaladafrica,项目名称:axon-cdi,代码行数:4,代码来源:AxonUtils.java
示例8: subscribe
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);
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:6,代码来源:TestEventBus.java
示例9: EventListenerA
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public EventListenerA(final EventListener delegate) {
super(delegate);
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:4,代码来源:GroupB.java
示例10: EventListenerB
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public EventListenerB(final EventListener delegate) {
super(delegate);
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:4,代码来源:GroupB.java
示例11: EventListenerWrapper
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public EventListenerWrapper(final EventListener delegate) {
this.delegate = Optional.fromNullable(delegate);
}
开发者ID:viadeo,项目名称:axon-kafka-terminal,代码行数:4,代码来源:EventListenerWrapper.java
示例12: addEventListener
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void addEventListener(EventListener eventListener) {
if(m_eventListeners.add(eventListener)) {
m_eventBus.subscribe(eventListener);
}
}
开发者ID:lburgazzoli,项目名称:lb-axon,代码行数:6,代码来源:AxonService.java
示例13: removeEventListener
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void removeEventListener(EventListener eventListener) {
if(eventListener != null) {
m_eventBus.unsubscribe(eventListener);
}
}
开发者ID:lburgazzoli,项目名称:lb-axon,代码行数:6,代码来源:AxonService.java
示例14: addEventListener
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void addEventListener(EventListener eventListener) {
if(m_eventListeners.add(eventListener)) {
m_evtBus.subscribe(eventListener);
}
}
开发者ID:lburgazzoli,项目名称:lb-axon,代码行数:6,代码来源:AxonService.java
示例15: removeEventListener
import org.axonframework.eventhandling.EventListener; //导入依赖的package包/类
public void removeEventListener(EventListener eventListener) {
if(eventListener != null) {
m_evtBus.unsubscribe(eventListener);
}
}
开发者ID:lburgazzoli,项目名称:lb-axon,代码行数:6,代码来源:AxonService.java
注:本文中的org.axonframework.eventhandling.EventListener类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论