diff --git a/naming/src/main/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHook.java b/naming/src/main/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHook.java index b7a32835045..934a4e40da4 100644 --- a/naming/src/main/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHook.java +++ b/naming/src/main/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHook.java @@ -44,6 +44,7 @@ public void pushSuccess(PushResult result) { @Override public void pushFailed(PushResult result) { + MetricsMonitor.incrementPush(); MetricsMonitor.incrementFailPush(); if (isRpc(result.getSubscriber())) { NamingTpsMonitor.rpcPushFail(result.getSubscribeClientId(), result.getSubscriber().getIp()); diff --git a/naming/src/test/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHookTest.java b/naming/src/test/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHookTest.java index 90451aa5108..7310a976392 100644 --- a/naming/src/test/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHookTest.java +++ b/naming/src/test/java/com/alibaba/nacos/naming/push/v2/hook/NacosMonitorPushResultHookTest.java @@ -101,5 +101,6 @@ public void testPushSuccessForNoEmptyPush() { public void testPushFailed() { new NacosMonitorPushResultHook().pushFailed(pushResult); assertEquals(1, MetricsMonitor.getFailedPushMonitor().get()); + assertEquals(1, MetricsMonitor.getTotalPushMonitor().get()); } }