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

Renaming

Browse Source
This commit is contained in:
lieght
2025-12-07 02:47:15 +01:00
parent 854744cefa
commit 5ee2f2187e
6 changed files with 11 additions and 12 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.AsyncEventsHolder; import org.toop.framework.eventbus.holder.AsyncSubscriberStore;
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 AsyncEventsHolder() new AsyncSubscriberStore()
); );
private GlobalEventBus() {} private GlobalEventBus() {}

7
framework/src/main/java/org/toop/framework/eventbus/bus/DefaultEventBus.java
View File

@@ -1,9 +1,8 @@
package org.toop.framework.eventbus.bus; package org.toop.framework.eventbus.bus;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.toop.framework.eventbus.events.EventType; import org.toop.framework.eventbus.events.EventType;
import org.toop.framework.eventbus.holder.EventsHolder; import org.toop.framework.eventbus.holder.SubscriberStore;
import org.toop.framework.eventbus.subscriber.Subscriber; import org.toop.framework.eventbus.subscriber.Subscriber;
import java.util.ArrayList; import java.util.ArrayList;
@@ -12,9 +11,9 @@ import java.util.function.Consumer;
public class DefaultEventBus implements EventBus { public class DefaultEventBus implements EventBus {
private final Logger logger; private final Logger logger;
private final EventsHolder eventsHolder; private final SubscriberStore eventsHolder;
public DefaultEventBus(Logger logger, EventsHolder eventsHolder) { public DefaultEventBus(Logger logger, SubscriberStore eventsHolder) {
this.logger = logger; this.logger = logger;
this.eventsHolder = eventsHolder; this.eventsHolder = eventsHolder;
} }

6
framework/src/main/java/org/toop/framework/eventbus/bus/DisruptorEventBus.java
View File

@@ -7,7 +7,7 @@ import com.lmax.disruptor.dsl.ProducerType;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.toop.framework.eventbus.subscriber.Subscriber; import org.toop.framework.eventbus.subscriber.Subscriber;
import org.toop.framework.eventbus.events.EventType; import org.toop.framework.eventbus.events.EventType;
import org.toop.framework.eventbus.holder.EventsHolder; import org.toop.framework.eventbus.holder.SubscriberStore;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadFactory;
@@ -20,12 +20,12 @@ public class DisruptorEventBus implements EventBus {
} }
private final Logger logger; private final Logger logger;
private final EventsHolder eventsHolder; private final SubscriberStore eventsHolder;
private final Disruptor<EventHolder<?>> disruptor; private final Disruptor<EventHolder<?>> disruptor;
private final RingBuffer<EventHolder<?>> ringBuffer; private final RingBuffer<EventHolder<?>> ringBuffer;
public DisruptorEventBus(Logger logger, EventsHolder eventsHolder) { public DisruptorEventBus(Logger logger, SubscriberStore eventsHolder) {
this.logger = logger; this.logger = logger;
this.eventsHolder = eventsHolder; this.eventsHolder = eventsHolder;

2
framework/src/main/java/org/toop/framework/eventbus/holder/AsyncEventsHolder.java → framework/src/main/java/org/toop/framework/eventbus/holder/AsyncSubscriberStore.java
View File

@@ -7,7 +7,7 @@ import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
public class AsyncEventsHolder implements EventsHolder { public class AsyncSubscriberStore implements SubscriberStore {
private final Map<Class<?>, CopyOnWriteArrayList<Subscriber<?, ?>>> LISTENERS = new ConcurrentHashMap<>(); private final Map<Class<?>, CopyOnWriteArrayList<Subscriber<?, ?>>> LISTENERS = new ConcurrentHashMap<>();
@Override @Override

2
framework/src/main/java/org/toop/framework/eventbus/holder/EventsHolder.java → framework/src/main/java/org/toop/framework/eventbus/holder/SubscriberStore.java
View File

@@ -4,7 +4,7 @@ import org.toop.framework.eventbus.subscriber.Subscriber;
import java.util.List; import java.util.List;
public interface EventsHolder { public interface SubscriberStore {
void add(Subscriber<?, ?> subscriber); void add(Subscriber<?, ?> subscriber);
void remove(Subscriber<?, ?> subscriber); void remove(Subscriber<?, ?> subscriber);
List<Subscriber<?, ?>> get(Class<?> event); List<Subscriber<?, ?>> get(Class<?> event);

2
framework/src/main/java/org/toop/framework/eventbus/holder/SyncEventsHolder.java → framework/src/main/java/org/toop/framework/eventbus/holder/SyncSubscriberStore.java
View File

@@ -7,7 +7,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
public class SyncEventsHolder implements EventsHolder { public class SyncSubscriberStore implements SubscriberStore {
private final Map<Class<?>, List<Subscriber<?, ?>>> LISTENERS = new ConcurrentHashMap<>(); private final Map<Class<?>, List<Subscriber<?, ?>>> LISTENERS = new ConcurrentHashMap<>();
@Override @Override