stef_buwalda/pism
1
0
Fork 0
mirror of https://github.com/2OOP/pism.git synced 2026-02-04 10:54:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename

Browse Source
This commit is contained in:
lieght
2025-12-07 15:04:02 +01:00
parent b2e4e7d810
commit f62219605f
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
framework/src/main/java/org/toop/framework/eventbus/GlobalEventBus.java
View File

@@ -3,13 +3,13 @@ package org.toop.framework.eventbus;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.toop.framework.eventbus.bus.DisruptorEventBus; import org.toop.framework.eventbus.bus.DisruptorEventBus;
import org.toop.framework.eventbus.bus.EventBus; import org.toop.framework.eventbus.bus.EventBus;
import org.toop.framework.eventbus.holder.AsyncArraySubscriberStore; import org.toop.framework.eventbus.holder.DefaultSubscriberStore;
import org.toop.framework.eventbus.subscriber.Subscriber; import org.toop.framework.eventbus.subscriber.Subscriber;
public class GlobalEventBus implements EventBus { public class GlobalEventBus implements EventBus {
private static final EventBus INSTANCE = new DisruptorEventBus( private static final EventBus INSTANCE = new DisruptorEventBus(
LogManager.getLogger(DisruptorEventBus.class), LogManager.getLogger(DisruptorEventBus.class),
new AsyncArraySubscriberStore() new DefaultSubscriberStore()
); );
private GlobalEventBus() {} private GlobalEventBus() {}

2
framework/src/main/java/org/toop/framework/eventbus/holder/AsyncArraySubscriberStore.java → framework/src/main/java/org/toop/framework/eventbus/holder/DefaultSubscriberStore.java
View File

@@ -4,7 +4,7 @@ import org.toop.framework.eventbus.subscriber.Subscriber;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
public class AsyncArraySubscriberStore implements SubscriberStore { public class DefaultSubscriberStore implements SubscriberStore {
private static final Subscriber<?, ?>[] EMPTY = new Subscriber[0]; private static final Subscriber<?, ?>[] EMPTY = new Subscriber[0];