【delete】无用代码

pull/233/head
李同学 2 years ago
parent 258bda45d8
commit be761e12a0

@ -63,7 +63,6 @@ public class SpringCloudStreamRocketMQThreadPoolAdapter implements ThreadPoolAda
ThreadPoolAdapterState result = new ThreadPoolAdapterState(); ThreadPoolAdapterState result = new ThreadPoolAdapterState();
ThreadPoolExecutor rocketMQConsumeExecutor = ROCKET_MQ_SPRING_CLOUD_STREAM_CONSUME_EXECUTOR.get(identify); ThreadPoolExecutor rocketMQConsumeExecutor = ROCKET_MQ_SPRING_CLOUD_STREAM_CONSUME_EXECUTOR.get(identify);
if (rocketMQConsumeExecutor != null) { if (rocketMQConsumeExecutor != null) {
result.setThreadPoolKey(mark());
result.setThreadPoolKey(identify); result.setThreadPoolKey(identify);
result.setCoreSize(rocketMQConsumeExecutor.getCorePoolSize()); result.setCoreSize(rocketMQConsumeExecutor.getCorePoolSize());
result.setMaximumSize(rocketMQConsumeExecutor.getMaximumPoolSize()); result.setMaximumSize(rocketMQConsumeExecutor.getMaximumPoolSize());

Loading…
Cancel
Save