Add additional refresh registration tasks

pull/289/head
lucky 8 2 years ago
parent 84083c593b
commit 0d47ad3a7e

@ -55,4 +55,11 @@ public interface ThreadPoolAdapter {
* @return
*/
boolean updateThreadPool(ThreadPoolAdapterParameter threadPoolAdapterParameter);
/**
* Additional refresh registration tasks
*
* @return
*/
void extraRefreshRegister();
}

@ -115,4 +115,9 @@ public class DubboThreadPoolAdapter implements ThreadPoolAdapter, ApplicationLis
log.error("Failed to get Dubbo {}.X protocol thread pool", is2xVersion ? "2" : "3", ex);
}
}
@Override
public void extraRefreshRegister() {
}
}

@ -163,4 +163,9 @@ public class HystrixThreadPoolAdapter implements ThreadPoolAdapter, ApplicationL
}
}
}
@Override
public void extraRefreshRegister() {
}
}

@ -49,4 +49,9 @@ public class KafkaThreadPoolAdapter implements ThreadPoolAdapter, ApplicationLis
public void onApplicationEvent(ApplicationStartedEvent event) {
}
@Override
public void extraRefreshRegister() {
}
}

@ -114,4 +114,9 @@ public class RabbitMQThreadPoolAdapter implements ThreadPoolAdapter, Application
}
}
}
@Override
public void extraRefreshRegister() {
}
}

@ -108,4 +108,9 @@ public class RocketMQThreadPoolAdapter implements ThreadPoolAdapter, Application
}
}
@Override
public void extraRefreshRegister() {
}
}

@ -56,4 +56,9 @@ public class SpringCloudStreamKafkaThreadPoolAdapter implements ThreadPoolAdapte
public void onApplicationEvent(ApplicationStartedEvent event) {
}
@Override
public void extraRefreshRegister() {
}
}

@ -122,4 +122,9 @@ public class SpringCloudStreamRocketMQThreadPoolAdapter implements ThreadPoolAda
log.error("Failed to get input-bindings thread pool.", ex);
}
}
@Override
public void extraRefreshRegister() {
}
}

Loading…
Cancel
Save