|
|
|
@ -46,6 +46,7 @@ public class SeataHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy
|
|
|
|
|
|
|
|
|
|
private final Logger logger = LoggerFactory
|
|
|
|
|
.getLogger(SeataHystrixConcurrencyStrategy.class);
|
|
|
|
|
|
|
|
|
|
private HystrixConcurrencyStrategy delegate;
|
|
|
|
|
|
|
|
|
|
public SeataHystrixConcurrencyStrategy() {
|
|
|
|
@ -78,8 +79,8 @@ public class SeataHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void logCurrentStateOfHystrixPlugins(HystrixEventNotifier eventNotifier,
|
|
|
|
|
HystrixMetricsPublisher metricsPublisher,
|
|
|
|
|
HystrixPropertiesStrategy propertiesStrategy) {
|
|
|
|
|
HystrixMetricsPublisher metricsPublisher,
|
|
|
|
|
HystrixPropertiesStrategy propertiesStrategy) {
|
|
|
|
|
if (logger.isDebugEnabled()) {
|
|
|
|
|
logger.debug("Current Hystrix plugins configuration is ["
|
|
|
|
|
+ "concurrencyStrategy [" + this.delegate + "]," + "eventNotifier ["
|
|
|
|
@ -91,17 +92,17 @@ public class SeataHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey,
|
|
|
|
|
HystrixProperty<Integer> corePoolSize,
|
|
|
|
|
HystrixProperty<Integer> maximumPoolSize,
|
|
|
|
|
HystrixProperty<Integer> keepAliveTime, TimeUnit unit,
|
|
|
|
|
BlockingQueue<Runnable> workQueue) {
|
|
|
|
|
HystrixProperty<Integer> corePoolSize,
|
|
|
|
|
HystrixProperty<Integer> maximumPoolSize,
|
|
|
|
|
HystrixProperty<Integer> keepAliveTime, TimeUnit unit,
|
|
|
|
|
BlockingQueue<Runnable> workQueue) {
|
|
|
|
|
return this.delegate.getThreadPool(threadPoolKey, corePoolSize, maximumPoolSize,
|
|
|
|
|
keepAliveTime, unit, workQueue);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey,
|
|
|
|
|
HystrixThreadPoolProperties threadPoolProperties) {
|
|
|
|
|
HystrixThreadPoolProperties threadPoolProperties) {
|
|
|
|
|
return this.delegate.getThreadPool(threadPoolKey, threadPoolProperties);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|