Rejectedproxy update

pull/131/head
sizegang1 3 years ago
parent 9397ecab8d
commit dc3fd76d2a

@ -28,8 +28,12 @@ public class RejectedProxyInvocationHandler implements InvocationHandler {
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
rejectCount.incrementAndGet();
ThreadPoolNotifyAlarmHandler alarmHandler = ApplicationContextHolder.getBean(ThreadPoolNotifyAlarmHandler.class);
alarmHandler.checkPoolRejectedAlarm(threadPoolId);
if (ApplicationContextHolder.getInstance() != null) {
ThreadPoolNotifyAlarmHandler alarmHandler = ApplicationContextHolder.getBean(ThreadPoolNotifyAlarmHandler.class);
if (alarmHandler != null) {
alarmHandler.checkPoolRejectedAlarm(threadPoolId);
}
}
try {
return method.invoke(target, args);

Loading…
Cancel
Save