diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/event/Event.java b/hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractEvent.java similarity index 90% rename from hippo4j-config/src/main/java/cn/hippo4j/config/event/Event.java rename to hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractEvent.java index c4e8f133..7684d5d4 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/event/Event.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractEvent.java @@ -9,7 +9,7 @@ import java.util.concurrent.atomic.AtomicLong; * @author chen.ma * @date 2021/6/23 18:59 */ -public abstract class Event implements Serializable { +public abstract class AbstractEvent implements Serializable { private static final AtomicLong SEQUENCE = new AtomicLong(0); diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/event/SlowEvent.java b/hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractSlowEvent.java similarity index 73% rename from hippo4j-config/src/main/java/cn/hippo4j/config/event/SlowEvent.java rename to hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractSlowEvent.java index deab7c80..9334adb5 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/event/SlowEvent.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractSlowEvent.java @@ -6,7 +6,7 @@ package cn.hippo4j.config.event; * @author chen.ma * @date 2021/6/23 19:05 */ -public abstract class SlowEvent extends Event { +public abstract class AbstractSlowEvent extends AbstractEvent { @Override public long sequence() { diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java b/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java index 2e3ba3aa..23ed93cf 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java @@ -8,7 +8,7 @@ import org.springframework.util.StringUtils; * @author chen.ma * @date 2021/6/24 23:35 */ -public class ConfigDataChangeEvent extends Event { +public class ConfigDataChangeEvent extends AbstractEvent { public final String tenantId; diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/event/LocalDataChangeEvent.java b/hippo4j-config/src/main/java/cn/hippo4j/config/event/LocalDataChangeEvent.java index 1cb5a639..03bcb6f3 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/event/LocalDataChangeEvent.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/event/LocalDataChangeEvent.java @@ -6,7 +6,7 @@ package cn.hippo4j.config.event; * @author chen.ma * @date 2021/6/23 19:13 */ -public class LocalDataChangeEvent extends Event { +public class LocalDataChangeEvent extends AbstractEvent { /** * 租户+项目+线程池 diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java index 1de56d31..39a052dd 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java @@ -1,8 +1,8 @@ package cn.hippo4j.config.notify; +import cn.hippo4j.config.event.AbstractEvent; import cn.hutool.core.collection.ConcurrentHashSet; -import cn.hippo4j.config.notify.listener.Subscriber; -import cn.hippo4j.config.event.Event; +import cn.hippo4j.config.notify.listener.AbstractSubscriber; import lombok.extern.slf4j.Slf4j; import org.springframework.util.CollectionUtils; @@ -20,9 +20,9 @@ import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; @Slf4j public class DefaultPublisher extends Thread implements EventPublisher { - protected final ConcurrentHashSet subscribers = new ConcurrentHashSet(); + protected final ConcurrentHashSet subscribers = new ConcurrentHashSet(); - private BlockingQueue queue; + private BlockingQueue queue; private volatile boolean initialized = false; @@ -36,7 +36,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { .newUpdater(DefaultPublisher.class, Long.class, "lastEventSequence"); @Override - public void init(Class type, int bufferSize) { + public void init(Class type, int bufferSize) { setDaemon(true); setName("dynamic.thread-pool.publisher-" + type.getName()); this.queueMaxSize = bufferSize; @@ -80,7 +80,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { if (shutdown) { break; } - final Event event = queue.take(); + final AbstractEvent event = queue.take(); receiveEvent(event); UPDATER.compareAndSet(this, lastEventSequence, Math.max(lastEventSequence, event.sequence())); } @@ -90,12 +90,12 @@ public class DefaultPublisher extends Thread implements EventPublisher { } @Override - public void addSubscriber(Subscriber subscriber) { + public void addSubscriber(AbstractSubscriber subscriber) { subscribers.add(subscriber); } @Override - public boolean publish(Event event) { + public boolean publish(AbstractEvent event) { boolean success = this.queue.offer(event); if (!success) { log.warn("Unable to plug in due to interruption, synchronize sending time, event :: {}", event); @@ -106,7 +106,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { } @Override - public void notifySubscriber(Subscriber subscriber, Event event) { + public void notifySubscriber(AbstractSubscriber subscriber, AbstractEvent event) { final Runnable job = () -> subscriber.onEvent(event); final Executor executor = subscriber.executor(); @@ -126,8 +126,8 @@ public class DefaultPublisher extends Thread implements EventPublisher { return !CollectionUtils.isEmpty(subscribers); } - void receiveEvent(Event event) { - for (Subscriber subscriber : subscribers) { + void receiveEvent(AbstractEvent event) { + for (AbstractSubscriber subscriber : subscribers) { notifySubscriber(subscriber, event); } } diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultSharePublisher.java b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultSharePublisher.java index 903e1b82..ad408343 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultSharePublisher.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultSharePublisher.java @@ -1,9 +1,9 @@ package cn.hippo4j.config.notify; +import cn.hippo4j.config.event.AbstractEvent; import cn.hutool.core.collection.ConcurrentHashSet; -import cn.hippo4j.config.notify.listener.Subscriber; -import cn.hippo4j.config.event.Event; -import cn.hippo4j.config.event.SlowEvent; +import cn.hippo4j.config.notify.listener.AbstractSubscriber; +import cn.hippo4j.config.event.AbstractSlowEvent; import java.util.Map; import java.util.Set; @@ -19,21 +19,21 @@ import java.util.concurrent.locks.ReentrantLock; */ public class DefaultSharePublisher extends DefaultPublisher { - private final Map, Set> subMappings = new ConcurrentHashMap(); + private final Map, Set> subMappings = new ConcurrentHashMap(); - protected final ConcurrentHashSet subscribers = new ConcurrentHashSet(); + protected final ConcurrentHashSet subscribers = new ConcurrentHashSet(); private final Lock lock = new ReentrantLock(); - public void addSubscriber(Subscriber subscriber, Class subscribeType) { - Class subSlowEventType = (Class) subscribeType; + public void addSubscriber(AbstractSubscriber subscriber, Class subscribeType) { + Class subSlowEventType = (Class) subscribeType; subscribers.add(subscriber); lock.lock(); try { - Set sets = subMappings.get(subSlowEventType); + Set sets = subMappings.get(subSlowEventType); if (sets == null) { - Set newSet = new ConcurrentHashSet(); + Set newSet = new ConcurrentHashSet(); newSet.add(subscriber); subMappings.put(subSlowEventType, newSet); return; diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java index 093c1ed5..927cc37f 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java @@ -1,7 +1,7 @@ package cn.hippo4j.config.notify; -import cn.hippo4j.config.notify.listener.Subscriber; -import cn.hippo4j.config.event.Event; +import cn.hippo4j.config.event.AbstractEvent; +import cn.hippo4j.config.notify.listener.AbstractSubscriber; /** * Event publisher. @@ -17,14 +17,14 @@ public interface EventPublisher { * @param type * @param bufferSize */ - void init(Class type, int bufferSize); + void init(Class type, int bufferSize); /** * Add subscriber. * * @param subscriber */ - void addSubscriber(Subscriber subscriber); + void addSubscriber(AbstractSubscriber subscriber); /** * Publish. @@ -32,7 +32,7 @@ public interface EventPublisher { * @param event * @return */ - boolean publish(Event event); + boolean publish(AbstractEvent event); /** * Notify subscriber. @@ -40,6 +40,6 @@ public interface EventPublisher { * @param subscriber * @param event */ - void notifySubscriber(Subscriber subscriber, Event event); + void notifySubscriber(AbstractSubscriber subscriber, AbstractEvent event); } diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java index 3e6e1e82..e4a98982 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java @@ -1,11 +1,11 @@ package cn.hippo4j.config.notify; -import cn.hippo4j.config.notify.listener.SmartSubscriber; -import cn.hippo4j.config.notify.listener.Subscriber; +import cn.hippo4j.config.event.AbstractEvent; +import cn.hippo4j.config.notify.listener.AbstractSmartSubscriber; +import cn.hippo4j.config.notify.listener.AbstractSubscriber; import cn.hippo4j.config.toolkit.ClassUtil; import cn.hippo4j.config.toolkit.MapUtil; -import cn.hippo4j.config.event.Event; -import cn.hippo4j.config.event.SlowEvent; +import cn.hippo4j.config.event.AbstractSlowEvent; import lombok.extern.slf4j.Slf4j; import java.util.Map; @@ -33,7 +33,7 @@ public class NotifyCenter { private static EventPublisher eventPublisher = new DefaultPublisher(); - private static BiFunction, Integer, EventPublisher> publisherFactory = null; + private static BiFunction, Integer, EventPublisher> publisherFactory = null; private final Map publisherMap = new ConcurrentHashMap(16); @@ -50,13 +50,13 @@ public class NotifyCenter { }; INSTANCE.sharePublisher = new DefaultSharePublisher(); - INSTANCE.sharePublisher.init(SlowEvent.class, shareBufferSize); + INSTANCE.sharePublisher.init(AbstractSlowEvent.class, shareBufferSize); } - public static void registerSubscriber(final Subscriber consumer) { - if (consumer instanceof SmartSubscriber) { - for (Class subscribeType : ((SmartSubscriber) consumer).subscribeTypes()) { - if (ClassUtil.isAssignableFrom(SlowEvent.class, subscribeType)) { + public static void registerSubscriber(final AbstractSubscriber consumer) { + if (consumer instanceof AbstractSmartSubscriber) { + for (Class subscribeType : ((AbstractSmartSubscriber) consumer).subscribeTypes()) { + if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, subscribeType)) { INSTANCE.sharePublisher.addSubscriber(consumer, subscribeType); } else { addSubscriber(consumer, subscribeType); @@ -65,8 +65,8 @@ public class NotifyCenter { return; } - final Class subscribeType = consumer.subscribeType(); - if (ClassUtil.isAssignableFrom(SlowEvent.class, subscribeType)) { + final Class subscribeType = consumer.subscribeType(); + if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, subscribeType)) { INSTANCE.sharePublisher.addSubscriber(consumer, subscribeType); return; } @@ -74,7 +74,7 @@ public class NotifyCenter { addSubscriber(consumer, subscribeType); } - private static void addSubscriber(final Subscriber consumer, Class subscribeType) { + private static void addSubscriber(final AbstractSubscriber consumer, Class subscribeType) { final String topic = ClassUtil.getCanonicalName(subscribeType); synchronized (NotifyCenter.class) { MapUtil.computeIfAbsent(INSTANCE.publisherMap, topic, publisherFactory, subscribeType, ringBufferSize); @@ -83,7 +83,7 @@ public class NotifyCenter { publisher.addSubscriber(consumer); } - public static boolean publishEvent(final Event event) { + public static boolean publishEvent(final AbstractEvent event) { try { return publishEvent(event.getClass(), event); } catch (Throwable ex) { @@ -92,8 +92,8 @@ public class NotifyCenter { } } - private static boolean publishEvent(final Class eventType, final Event event) { - if (ClassUtil.isAssignableFrom(SlowEvent.class, eventType)) { + private static boolean publishEvent(final Class eventType, final AbstractEvent event) { + if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, eventType)) { return INSTANCE.sharePublisher.publish(event); } @@ -107,8 +107,8 @@ public class NotifyCenter { return false; } - public static EventPublisher registerToPublisher(final Class eventType, final int queueMaxSize) { - if (ClassUtil.isAssignableFrom(SlowEvent.class, eventType)) { + public static EventPublisher registerToPublisher(final Class eventType, final int queueMaxSize) { + if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, eventType)) { return INSTANCE.sharePublisher; } diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/SmartSubscriber.java b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSmartSubscriber.java similarity index 55% rename from hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/SmartSubscriber.java rename to hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSmartSubscriber.java index 67214616..1bcb3990 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/SmartSubscriber.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSmartSubscriber.java @@ -1,6 +1,6 @@ package cn.hippo4j.config.notify.listener; -import cn.hippo4j.config.event.Event; +import cn.hippo4j.config.event.AbstractEvent; import java.util.List; @@ -10,13 +10,13 @@ import java.util.List; * @author chen.ma * @date 2021/6/23 19:02 */ -public abstract class SmartSubscriber extends Subscriber { +public abstract class AbstractSmartSubscriber extends AbstractSubscriber { /** * Subscribe types. * * @return */ - public abstract List> subscribeTypes(); + public abstract List> subscribeTypes(); } diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/Subscriber.java b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java similarity index 71% rename from hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/Subscriber.java rename to hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java index 424c4b8a..d746341e 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/Subscriber.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java @@ -1,6 +1,6 @@ package cn.hippo4j.config.notify.listener; -import cn.hippo4j.config.event.Event; +import cn.hippo4j.config.event.AbstractEvent; import java.util.concurrent.Executor; @@ -10,7 +10,7 @@ import java.util.concurrent.Executor; * @author chen.ma * @date 2021/6/23 19:02 */ -public abstract class Subscriber { +public abstract class AbstractSubscriber { /** * Event callback. @@ -24,7 +24,7 @@ public abstract class Subscriber { * * @return */ - public abstract Class subscribeType(); + public abstract Class subscribeType(); public Executor executor() { return null; diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java index 2cd28608..14fcb070 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java @@ -3,10 +3,10 @@ package cn.hippo4j.config.service; import cn.hippo4j.common.toolkit.JSONUtil; import cn.hippo4j.common.toolkit.Md5Util; import cn.hippo4j.common.web.base.Results; -import cn.hippo4j.config.event.Event; +import cn.hippo4j.config.event.AbstractEvent; import cn.hippo4j.config.event.LocalDataChangeEvent; import cn.hippo4j.config.notify.NotifyCenter; -import cn.hippo4j.config.notify.listener.Subscriber; +import cn.hippo4j.config.notify.listener.AbstractSubscriber; import cn.hippo4j.config.toolkit.ConfigExecutor; import cn.hippo4j.config.toolkit.MapUtil; import cn.hippo4j.config.toolkit.Md5ConfigUtil; @@ -58,10 +58,10 @@ public class LongPollingService { NotifyCenter.registerToPublisher(LocalDataChangeEvent.class, NotifyCenter.ringBufferSize); - NotifyCenter.registerSubscriber(new Subscriber() { + NotifyCenter.registerSubscriber(new AbstractSubscriber() { @Override - public void onEvent(Event event) { + public void onEvent(AbstractEvent event) { if (isFixedPolling()) { // Ignore. } else { @@ -73,7 +73,7 @@ public class LongPollingService { } @Override - public Class subscribeType() { + public Class subscribeType() { return LocalDataChangeEvent.class; } }); diff --git a/hippo4j-example/src/main/java/cn/hippo4j/example/config/ThreadPoolConfig.java b/hippo4j-example/src/main/java/cn/hippo4j/example/config/ThreadPoolConfig.java index 2fc21b7e..617e1a8e 100644 --- a/hippo4j-example/src/main/java/cn/hippo4j/example/config/ThreadPoolConfig.java +++ b/hippo4j-example/src/main/java/cn/hippo4j/example/config/ThreadPoolConfig.java @@ -2,9 +2,9 @@ package cn.hippo4j.example.config; import cn.hippo4j.example.inittest.TaskDecoratorTest; import cn.hippo4j.starter.core.DynamicThreadPool; -import cn.hippo4j.starter.core.DynamicThreadPoolExecutor; -import cn.hippo4j.starter.toolkit.thread.ThreadPoolBuilder; -import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper; +import cn.hippo4j.core.executor.DynamicThreadPoolExecutor; +import cn.hippo4j.core.executor.support.ThreadPoolBuilder; +import cn.hippo4j.core.executor.DynamicThreadPoolWrapper; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; diff --git a/hippo4j-example/src/main/java/cn/hippo4j/example/handler/ErrorLogRejectedExecutionHandler.java b/hippo4j-example/src/main/java/cn/hippo4j/example/handler/ErrorLogRejectedExecutionHandler.java index fa700658..93e37770 100644 --- a/hippo4j-example/src/main/java/cn/hippo4j/example/handler/ErrorLogRejectedExecutionHandler.java +++ b/hippo4j-example/src/main/java/cn/hippo4j/example/handler/ErrorLogRejectedExecutionHandler.java @@ -1,6 +1,6 @@ package cn.hippo4j.example.handler; -import cn.hippo4j.starter.spi.CustomRejectedExecutionHandler; +import cn.hippo4j.core.spi.CustomRejectedExecutionHandler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/AlarmSendMessageTest.java b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/AlarmSendMessageTest.java index 3466f4f4..d39ab983 100644 --- a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/AlarmSendMessageTest.java +++ b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/AlarmSendMessageTest.java @@ -2,8 +2,8 @@ package cn.hippo4j.example.inittest; import cn.hippo4j.example.constant.GlobalTestConstant; import cn.hutool.core.thread.ThreadUtil; -import cn.hippo4j.starter.core.GlobalThreadPoolManage; -import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper; +import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage; +import cn.hippo4j.core.executor.DynamicThreadPoolWrapper; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; diff --git a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java index c35053b2..e0cabef0 100644 --- a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java +++ b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java @@ -1,6 +1,6 @@ package cn.hippo4j.example.inittest; -import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper; +import cn.hippo4j.core.executor.DynamicThreadPoolWrapper; import cn.hutool.core.thread.ThreadUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; diff --git a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/TaskDecoratorTest.java b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/TaskDecoratorTest.java index c5d77793..c0f0bd15 100644 --- a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/TaskDecoratorTest.java +++ b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/TaskDecoratorTest.java @@ -1,8 +1,8 @@ package cn.hippo4j.example.inittest; import cn.hippo4j.example.constant.GlobalTestConstant; -import cn.hippo4j.starter.core.GlobalThreadPoolManage; -import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper; +import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage; +import cn.hippo4j.core.executor.DynamicThreadPoolWrapper; import cn.hutool.core.thread.ThreadUtil; import lombok.extern.slf4j.Slf4j; import org.slf4j.MDC; @@ -25,8 +25,8 @@ public class TaskDecoratorTest { /** * 测试动态线程池传递 {@link TaskDecorator} + * 如果需要运行此单测, 方法上添加 @PostConstruct */ - // @PostConstruct public void taskDecoratorTest() { new Thread(() -> { MDC.put(PLACEHOLDER, "查看官网: https://www.hippox.cn"); diff --git a/hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.core.spi.CustomRejectedExecutionHandler b/hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.core.spi.CustomRejectedExecutionHandler new file mode 100644 index 00000000..bdca3f76 --- /dev/null +++ b/hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.core.spi.CustomRejectedExecutionHandler @@ -0,0 +1 @@ +cn.hippo4j.example.handler.ErrorLogRejectedExecutionHandler \ No newline at end of file diff --git a/hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.starter.spi.CustomRejectedExecutionHandler b/hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.starter.spi.CustomRejectedExecutionHandler deleted file mode 100644 index adda6170..00000000 --- a/hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.starter.spi.CustomRejectedExecutionHandler +++ /dev/null @@ -1 +0,0 @@ -cn.hippo4j.example.handler.ErrorLogRejectedExecutionHandler