Change the path of starter basic package

pull/222/head
chen.ma 3 years ago
parent 7ef13e2a34
commit f585f4a448

@ -15,11 +15,11 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.config;
package cn.hippo4j.core.spring.boot.starter.config;
import cn.hippo4j.core.config.BootstrapPropertiesInterface;
import cn.hippo4j.core.starter.monitor.DynamicThreadPoolMonitor;
import cn.hippo4j.core.starter.parser.ConfigFileTypeEnum;
import cn.hippo4j.core.spring.boot.starter.monitor.DynamicThreadPoolMonitor;
import cn.hippo4j.core.spring.boot.starter.parser.ConfigFileTypeEnum;
import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.config;
package cn.hippo4j.core.spring.boot.starter.config;
import cn.hippo4j.common.api.NotifyConfigBuilder;
import cn.hippo4j.common.config.ApplicationContextHolder;
@ -31,15 +31,15 @@ import cn.hippo4j.core.config.WebThreadPoolConfiguration;
import cn.hippo4j.core.enable.MarkerConfiguration;
import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
import cn.hippo4j.core.executor.state.ThreadPoolRunStateHandler;
import cn.hippo4j.core.starter.monitor.DynamicThreadPoolMonitorExecutor;
import cn.hippo4j.core.starter.monitor.LogMonitorHandler;
import cn.hippo4j.core.starter.monitor.MetricMonitorHandler;
import cn.hippo4j.core.starter.notify.CoreNotifyConfigBuilder;
import cn.hippo4j.core.starter.refresher.ApolloRefresherHandler;
import cn.hippo4j.core.starter.refresher.NacosCloudRefresherHandler;
import cn.hippo4j.core.starter.refresher.NacosRefresherHandler;
import cn.hippo4j.core.starter.refresher.ZookeeperRefresherHandler;
import cn.hippo4j.core.starter.support.DynamicThreadPoolPostProcessor;
import cn.hippo4j.core.spring.boot.starter.monitor.DynamicThreadPoolMonitorExecutor;
import cn.hippo4j.core.spring.boot.starter.monitor.LogMonitorHandler;
import cn.hippo4j.core.spring.boot.starter.monitor.MetricMonitorHandler;
import cn.hippo4j.core.spring.boot.starter.refresher.ApolloRefresherHandler;
import cn.hippo4j.core.spring.boot.starter.refresher.NacosCloudRefresherHandler;
import cn.hippo4j.core.spring.boot.starter.refresher.NacosRefresherHandler;
import cn.hippo4j.core.spring.boot.starter.support.DynamicThreadPoolPostProcessor;
import cn.hippo4j.core.spring.boot.starter.notify.CoreNotifyConfigBuilder;
import cn.hippo4j.core.spring.boot.starter.refresher.ZookeeperRefresherHandler;
import lombok.AllArgsConstructor;
import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
import org.springframework.boot.autoconfigure.condition.*;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.config;
package cn.hippo4j.core.spring.boot.starter.config;
import cn.hippo4j.common.notify.ThreadPoolNotifyAlarm;
import com.google.common.collect.Maps;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.monitor;
package cn.hippo4j.core.spring.boot.starter.monitor;
import cn.hippo4j.common.model.PoolRunStateInfo;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;

@ -15,13 +15,13 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.monitor;
package cn.hippo4j.core.spring.boot.starter.monitor;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.common.toolkit.StringUtil;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import cn.hippo4j.core.spi.DynamicThreadPoolServiceLoader;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import com.google.common.collect.Lists;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.monitor;
package cn.hippo4j.core.spring.boot.starter.monitor;
import cn.hippo4j.common.model.PoolRunStateInfo;
import cn.hippo4j.common.toolkit.JSONUtil;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.monitor;
package cn.hippo4j.core.spring.boot.starter.monitor;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.common.model.PoolRunStateInfo;

@ -15,15 +15,15 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.notify;
package cn.hippo4j.core.spring.boot.starter.notify;
import cn.hippo4j.common.api.NotifyConfigBuilder;
import cn.hippo4j.common.notify.AlarmControlHandler;
import cn.hippo4j.common.notify.NotifyConfigDTO;
import cn.hippo4j.common.toolkit.StringUtil;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.starter.config.ExecutorProperties;
import cn.hippo4j.core.starter.config.NotifyPlatformProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.ExecutorProperties;
import cn.hippo4j.core.spring.boot.starter.config.NotifyPlatformProperties;
import cn.hutool.core.util.StrUtil;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.parser;
package cn.hippo4j.core.spring.boot.starter.parser;
import java.io.IOException;
import java.util.List;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.parser;
package cn.hippo4j.core.spring.boot.starter.parser;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.refresher;
package cn.hippo4j.core.spring.boot.starter.refresher;
import cn.hippo4j.common.api.ThreadPoolDynamicRefresh;
import cn.hippo4j.common.config.ApplicationContextHolder;
@ -34,12 +34,12 @@ import cn.hippo4j.core.executor.manage.GlobalNotifyAlarmManage;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.core.executor.support.*;
import cn.hippo4j.core.proxy.RejectedProxyUtil;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.starter.config.ExecutorProperties;
import cn.hippo4j.core.starter.config.WebThreadPoolProperties;
import cn.hippo4j.core.starter.notify.CoreNotifyConfigBuilder;
import cn.hippo4j.core.starter.parser.ConfigParserHandler;
import cn.hippo4j.core.starter.support.GlobalCoreThreadPoolManage;
import cn.hippo4j.core.spring.boot.starter.config.WebThreadPoolProperties;
import cn.hippo4j.core.spring.boot.starter.support.GlobalCoreThreadPoolManage;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.ExecutorProperties;
import cn.hippo4j.core.spring.boot.starter.notify.CoreNotifyConfigBuilder;
import cn.hippo4j.core.spring.boot.starter.parser.ConfigParserHandler;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;

@ -15,10 +15,10 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.refresher;
package cn.hippo4j.core.spring.boot.starter.refresher;
import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import com.ctrip.framework.apollo.Config;
import com.ctrip.framework.apollo.ConfigChangeListener;
import com.ctrip.framework.apollo.ConfigFile;

@ -15,15 +15,15 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.refresher;
package cn.hippo4j.core.spring.boot.starter.refresher;
import cn.hippo4j.common.notify.NotifyPlatformEnum;
import cn.hippo4j.common.notify.ThreadPoolNotifyAlarm;
import cn.hippo4j.common.toolkit.CollectionUtil;
import cn.hippo4j.common.toolkit.StringUtil;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.starter.config.ExecutorProperties;
import cn.hippo4j.core.starter.config.NotifyPlatformProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.ExecutorProperties;
import cn.hippo4j.core.spring.boot.starter.config.NotifyPlatformProperties;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.google.common.collect.Lists;
@ -36,7 +36,7 @@ import org.springframework.boot.context.properties.source.MapConfigurationProper
import java.util.List;
import java.util.Map;
import static cn.hippo4j.core.starter.config.BootstrapCoreProperties.PREFIX;
import static cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties.PREFIX;
/**
* Bootstrap core properties binder adapt.

@ -15,11 +15,11 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.refresher;
package cn.hippo4j.core.spring.boot.starter.refresher;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import com.alibaba.cloud.nacos.NacosConfigManager;
import com.alibaba.nacos.api.config.listener.Listener;
import lombok.extern.slf4j.Slf4j;

@ -15,11 +15,11 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.refresher;
package cn.hippo4j.core.spring.boot.starter.refresher;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import lombok.extern.slf4j.Slf4j;

@ -15,10 +15,10 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.refresher;
package cn.hippo4j.core.spring.boot.starter.refresher;
import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import com.google.common.base.Charsets;
import lombok.extern.slf4j.Slf4j;
import org.apache.curator.framework.CuratorFramework;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.support;
package cn.hippo4j.core.spring.boot.starter.support;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.common.notify.ThreadPoolNotifyAlarm;
@ -26,8 +26,8 @@ import cn.hippo4j.core.executor.DynamicThreadPoolWrapper;
import cn.hippo4j.core.executor.manage.GlobalNotifyAlarmManage;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.core.executor.support.*;
import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.starter.config.ExecutorProperties;
import cn.hippo4j.core.spring.boot.starter.config.BootstrapCoreProperties;
import cn.hippo4j.core.spring.boot.starter.config.ExecutorProperties;
import cn.hippo4j.core.toolkit.inet.DynamicThreadPoolAnnotationUtil;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;

@ -15,9 +15,9 @@
* limitations under the License.
*/
package cn.hippo4j.core.starter.support;
package cn.hippo4j.core.spring.boot.starter.support;
import cn.hippo4j.core.starter.config.ExecutorProperties;
import cn.hippo4j.core.spring.boot.starter.config.ExecutorProperties;
import com.google.common.collect.Maps;
import java.util.Map;

@ -1 +1 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.core.starter.config.DynamicThreadPoolCoreAutoConfiguration
org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.core.spring.boot.starter.config.DynamicThreadPoolCoreAutoConfiguration

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.config;
package cn.hippo4j.springboot.starter.config;
import cn.hippo4j.core.config.BootstrapPropertiesInterface;
import lombok.Getter;

@ -15,14 +15,15 @@
* limitations under the License.
*/
package cn.hippo4j.starter.config;
package cn.hippo4j.springboot.starter.config;
import cn.hippo4j.common.model.InstanceInfo;
import cn.hippo4j.common.toolkit.ContentUtil;
import cn.hippo4j.core.toolkit.IdentifyUtil;
import cn.hippo4j.core.toolkit.inet.InetUtils;
import cn.hippo4j.starter.core.DiscoveryClient;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.toolkit.CloudCommonIdUtil;
import cn.hippo4j.springboot.starter.core.DiscoveryClient;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hutool.core.text.StrBuilder;
import lombok.AllArgsConstructor;
import lombok.SneakyThrows;
@ -32,8 +33,6 @@ import org.springframework.core.env.ConfigurableEnvironment;
import java.net.InetAddress;
import static cn.hippo4j.core.toolkit.IdentifyUtil.CLIENT_IDENTIFICATION_VALUE;
import static cn.hippo4j.starter.toolkit.CloudCommonIdUtil.getDefaultInstanceId;
import static cn.hippo4j.starter.toolkit.CloudCommonIdUtil.getIpApplicationName;
/**
* Dynamic threadPool discovery config.
@ -60,12 +59,12 @@ public class DiscoveryConfiguration {
String active = environment.getProperty("spring.profiles.active", "UNKNOWN");
InstanceInfo instanceInfo = new InstanceInfo();
String instanceId = getDefaultInstanceId(environment, hippo4JInetUtils);
String instanceId = CloudCommonIdUtil.getDefaultInstanceId(environment, hippo4JInetUtils);
instanceId = StrBuilder.create().append(instanceId).append(":").append(CLIENT_IDENTIFICATION_VALUE).toString();
String contextPath = environment.getProperty("server.servlet.context-path", "");
instanceInfo.setInstanceId(instanceId)
.setIpApplicationName(getIpApplicationName(environment, hippo4JInetUtils))
.setIpApplicationName(CloudCommonIdUtil.getIpApplicationName(environment, hippo4JInetUtils))
.setHostName(InetAddress.getLocalHost().getHostAddress())
.setAppName(applicationName)
.setPort(port)

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.config;
package cn.hippo4j.springboot.starter.config;
import cn.hippo4j.common.api.ThreadDetailState;
import cn.hippo4j.common.config.ApplicationContextHolder;
@ -27,17 +27,18 @@ import cn.hippo4j.core.executor.web.WebThreadPoolHandlerChoose;
import cn.hippo4j.core.handler.DynamicThreadPoolBannerHandler;
import cn.hippo4j.core.toolkit.IdentifyUtil;
import cn.hippo4j.core.toolkit.inet.InetUtils;
import cn.hippo4j.starter.controller.PoolRunStateController;
import cn.hippo4j.starter.controller.WebThreadPoolController;
import cn.hippo4j.springboot.starter.core.*;
import cn.hippo4j.springboot.starter.event.ApplicationContentPostProcessor;
import cn.hippo4j.springboot.starter.monitor.collect.RunTimeInfoCollector;
import cn.hippo4j.springboot.starter.controller.PoolRunStateController;
import cn.hippo4j.springboot.starter.controller.WebThreadPoolController;
import cn.hippo4j.starter.core.*;
import cn.hippo4j.starter.event.ApplicationContentPostProcessor;
import cn.hippo4j.starter.monitor.ReportingEventExecutor;
import cn.hippo4j.starter.monitor.collect.RunTimeInfoCollector;
import cn.hippo4j.starter.monitor.send.HttpConnectSender;
import cn.hippo4j.starter.monitor.send.MessageSender;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.starter.remote.HttpScheduledHealthCheck;
import cn.hippo4j.starter.remote.ServerHealthCheck;
import cn.hippo4j.springboot.starter.monitor.ReportingEventExecutor;
import cn.hippo4j.springboot.starter.monitor.send.HttpConnectSender;
import cn.hippo4j.springboot.starter.monitor.send.MessageSender;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.remote.HttpScheduledHealthCheck;
import cn.hippo4j.springboot.starter.remote.ServerHealthCheck;
import lombok.AllArgsConstructor;
import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;

@ -15,11 +15,11 @@
* limitations under the License.
*/
package cn.hippo4j.starter.config;
package cn.hippo4j.springboot.starter.config;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.starter.remote.ServerHttpAgent;
import cn.hippo4j.starter.toolkit.HttpClientUtil;
import cn.hippo4j.springboot.starter.toolkit.HttpClientUtil;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.remote.ServerHttpAgent;
import lombok.SneakyThrows;
import okhttp3.OkHttpClient;
import org.springframework.context.annotation.Bean;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.config;
package cn.hippo4j.springboot.starter.config;
import cn.hippo4j.common.api.NotifyConfigBuilder;
import cn.hippo4j.common.notify.*;
@ -23,9 +23,9 @@ import cn.hippo4j.common.notify.platform.DingSendMessageHandler;
import cn.hippo4j.common.notify.platform.LarkSendMessageHandler;
import cn.hippo4j.common.notify.platform.WeChatSendMessageHandler;
import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
import cn.hippo4j.starter.core.ServerThreadPoolDynamicRefresh;
import cn.hippo4j.starter.notify.ServerNotifyConfigBuilder;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.core.ServerThreadPoolDynamicRefresh;
import cn.hippo4j.springboot.starter.notify.ServerNotifyConfigBuilder;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import lombok.AllArgsConstructor;
import org.springframework.context.annotation.Bean;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.controller;
package cn.hippo4j.springboot.starter.controller;
import cn.hippo4j.common.api.ThreadDetailState;
import cn.hippo4j.common.model.PoolRunStateInfo;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.controller;
package cn.hippo4j.springboot.starter.controller;
import cn.hippo4j.common.model.PoolBaseInfo;
import cn.hippo4j.common.model.PoolParameterInfo;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.common.api.ThreadDetailState;
import cn.hippo4j.common.model.ThreadDetailStateInfo;

@ -15,10 +15,10 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.starter.wrapper.ManagerListenerWrapper;
import cn.hippo4j.springboot.starter.wrapper.ManagerListenerWrapper;
import cn.hippo4j.common.toolkit.ContentUtil;
import cn.hippo4j.common.toolkit.Md5Util;
import cn.hippo4j.common.constant.Constants;

@ -15,15 +15,15 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.common.model.PoolParameterInfo;
import cn.hippo4j.common.toolkit.ContentUtil;
import cn.hippo4j.common.toolkit.GroupKey;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.common.web.base.Result;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.starter.remote.ServerHealthCheck;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.remote.ServerHealthCheck;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import cn.hutool.core.util.IdUtil;
import lombok.SneakyThrows;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.core.config.ConfigEmptyException;
import org.springframework.boot.diagnostics.AbstractFailureAnalyzer;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.common.api.ClientCloseHookExecute;
import cn.hippo4j.common.constant.Constants;
@ -23,7 +23,7 @@ import cn.hippo4j.common.model.InstanceInfo;
import cn.hippo4j.common.web.base.Result;
import cn.hippo4j.common.web.base.Results;
import cn.hippo4j.common.web.exception.ErrorCodeEnum;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import cn.hutool.core.text.StrBuilder;
import cn.hutool.core.util.StrUtil;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.common.constant.Constants;
@ -31,8 +31,8 @@ import cn.hippo4j.core.executor.manage.GlobalNotifyAlarmManage;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.core.executor.support.*;
import cn.hippo4j.core.toolkit.inet.DynamicThreadPoolAnnotationUtil;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hutool.core.util.BooleanUtil;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import java.util.concurrent.Executor;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.common.enums.EnableEnum;
import cn.hippo4j.common.model.PoolParameter;

@ -15,11 +15,11 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.starter.event.ApplicationCompleteEvent;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.starter.remote.ServerHealthCheck;
import cn.hippo4j.springboot.starter.event.ApplicationCompleteEvent;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.remote.ServerHealthCheck;
import org.springframework.context.ApplicationListener;
import java.util.Arrays;

@ -15,9 +15,9 @@
* limitations under the License.
*/
package cn.hippo4j.starter.core;
package cn.hippo4j.springboot.starter.core;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import java.util.concurrent.Executor;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.event;
package cn.hippo4j.springboot.starter.event;
import org.springframework.context.ApplicationEvent;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.event;
package cn.hippo4j.springboot.starter.event;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationContext;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.event;
package cn.hippo4j.springboot.starter.event;
import cn.hippo4j.common.function.NoArgsConsumer;
import cn.hippo4j.core.executor.support.QueueTypeEnum;

@ -15,14 +15,14 @@
* limitations under the License.
*/
package cn.hippo4j.starter.monitor;
package cn.hippo4j.springboot.starter.monitor;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.common.monitor.Message;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.starter.monitor.collect.Collector;
import cn.hippo4j.starter.monitor.send.MessageSender;
import cn.hippo4j.starter.remote.ServerHealthCheck;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.monitor.collect.Collector;
import cn.hippo4j.springboot.starter.remote.ServerHealthCheck;
import cn.hippo4j.springboot.starter.monitor.send.MessageSender;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import cn.hippo4j.common.toolkit.ThreadUtil;
import cn.hutool.core.collection.CollUtil;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.monitor.collect;
package cn.hippo4j.springboot.starter.monitor.collect;
import cn.hippo4j.common.monitor.Message;

@ -15,14 +15,14 @@
* limitations under the License.
*/
package cn.hippo4j.starter.monitor.collect;
package cn.hippo4j.springboot.starter.monitor.collect;
import cn.hippo4j.common.model.PoolRunStateInfo;
import cn.hippo4j.common.monitor.AbstractMessage;
import cn.hippo4j.common.monitor.Message;
import cn.hippo4j.common.monitor.MessageTypeEnum;
import cn.hippo4j.common.monitor.RuntimeMessage;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.core.executor.state.AbstractThreadPoolRuntime;
import cn.hutool.core.bean.BeanUtil;

@ -15,12 +15,12 @@
* limitations under the License.
*/
package cn.hippo4j.starter.monitor.send;
package cn.hippo4j.springboot.starter.monitor.send;
import cn.hippo4j.common.monitor.Message;
import cn.hippo4j.common.monitor.MessageWrapper;
import cn.hippo4j.common.toolkit.MessageConvert;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.monitor.send;
package cn.hippo4j.springboot.starter.monitor.send;
import cn.hippo4j.common.monitor.Message;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.notify;
package cn.hippo4j.springboot.starter.notify;
import cn.hippo4j.common.notify.AlarmControlHandler;
import cn.hippo4j.common.api.NotifyConfigBuilder;
@ -26,8 +26,8 @@ import cn.hippo4j.common.toolkit.GroupKey;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.common.web.base.Result;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.starter.remote.HttpAgent;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.remote.HttpAgent;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.google.common.collect.Lists;

@ -15,10 +15,10 @@
* limitations under the License.
*/
package cn.hippo4j.starter.remote;
package cn.hippo4j.springboot.starter.remote;
import cn.hippo4j.starter.core.ShutdownExecuteException;
import cn.hippo4j.starter.event.ApplicationCompleteEvent;
import cn.hippo4j.springboot.starter.event.ApplicationCompleteEvent;
import cn.hippo4j.springboot.starter.core.ShutdownExecuteException;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.remote;
package cn.hippo4j.springboot.starter.remote;
import cn.hippo4j.common.web.base.Result;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.remote;
package cn.hippo4j.springboot.starter.remote;
import cn.hippo4j.common.web.base.Result;
import lombok.AllArgsConstructor;

@ -15,14 +15,14 @@
* limitations under the License.
*/
package cn.hippo4j.starter.remote;
package cn.hippo4j.springboot.starter.remote;
import cn.hippo4j.common.config.ApplicationContextHolder;
import cn.hippo4j.common.constant.Constants;
import cn.hippo4j.common.web.base.Result;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.starter.security.SecurityProxy;
import cn.hippo4j.starter.toolkit.HttpClientUtil;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.security.SecurityProxy;
import cn.hippo4j.springboot.starter.toolkit.HttpClientUtil;
import cn.hippo4j.core.executor.support.ThreadFactoryBuilder;
import cn.hutool.core.util.StrUtil;
import com.google.common.collect.Maps;

@ -15,9 +15,9 @@
* limitations under the License.
*/
package cn.hippo4j.starter.remote;
package cn.hippo4j.springboot.starter.remote;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hutool.core.util.StrUtil;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;

@ -15,15 +15,15 @@
* limitations under the License.
*/
package cn.hippo4j.starter.security;
package cn.hippo4j.springboot.starter.security;
import cn.hippo4j.common.constant.Constants;
import cn.hippo4j.common.model.TokenInfo;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.common.toolkit.StringUtil;
import cn.hippo4j.common.web.base.Result;
import cn.hippo4j.starter.config.BootstrapProperties;
import cn.hippo4j.starter.toolkit.HttpClientUtil;
import cn.hippo4j.springboot.starter.config.BootstrapProperties;
import cn.hippo4j.springboot.starter.toolkit.HttpClientUtil;
import lombok.extern.slf4j.Slf4j;
import java.util.HashMap;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.toolkit;
package cn.hippo4j.springboot.starter.toolkit;
import cn.hippo4j.core.toolkit.inet.InetUtils;
import lombok.SneakyThrows;

@ -15,7 +15,7 @@
* limitations under the License.
*/
package cn.hippo4j.starter.toolkit;
package cn.hippo4j.springboot.starter.toolkit;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.common.web.exception.ServiceException;

@ -15,9 +15,9 @@
* limitations under the License.
*/
package cn.hippo4j.starter.wrapper;
package cn.hippo4j.springboot.starter.wrapper;
import cn.hippo4j.starter.core.Listener;
import cn.hippo4j.springboot.starter.core.Listener;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;

@ -1,2 +1,2 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.starter.config.DynamicThreadPoolAutoConfiguration
org.springframework.boot.diagnostics.FailureAnalyzer=cn.hippo4j.starter.core.ConfigEmptyAnalyzer
org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.springboot.starter.config.DynamicThreadPoolAutoConfiguration
org.springframework.boot.diagnostics.FailureAnalyzer=cn.hippo4j.springboot.starter.core.ConfigEmptyAnalyzer

Loading…
Cancel
Save