Optimized adaptation

pull/289/head
lucky 8 3 years ago
parent 5a195cf650
commit 853714e5e2

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

@ -1,29 +0,0 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package cn.hippo4j.adapter.base;
import java.util.Map;
/**
* Thread Pool Adapter Extra Handle
**/
@FunctionalInterface
public interface ThreadPoolAdapterExtraHandle {
void execute(Map<String, ThreadPoolAdapter> map);
}

@ -115,9 +115,4 @@ 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,9 +163,4 @@ public class HystrixThreadPoolAdapter implements ThreadPoolAdapter, ApplicationL
}
}
}
@Override
public void extraRefreshRegister() {
}
}

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

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

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

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

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

Loading…
Cancel
Save