Skip to content

Commit 31c915f

Browse files
committed
[#noissue] Reduce excessive collector log
1 parent 9be1395 commit 31c915f

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

collector/src/main/java/com/navercorp/pinpoint/collector/handler/grpc/metric/AgentMetricBatchHandler.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import com.navercorp.pinpoint.collector.handler.SimpleHandler;
44
import com.navercorp.pinpoint.collector.handler.grpc.GrpcAgentEventService;
55
import com.navercorp.pinpoint.collector.mapper.grpc.stat.GrpcAgentStatBatchMapper;
6+
import com.navercorp.pinpoint.common.profiler.logging.ThrottledLogger;
67
import com.navercorp.pinpoint.common.server.bo.stat.AgentStatBo;
78
import com.navercorp.pinpoint.grpc.MessageFormatUtils;
89
import com.navercorp.pinpoint.grpc.trace.PAgentStatBatch;
@@ -17,6 +18,7 @@
1718
@Service
1819
public class AgentMetricBatchHandler implements SimpleHandler<PAgentStatBatch> {
1920
private final Logger logger = LogManager.getLogger(this.getClass());
21+
private final ThrottledLogger throttledLogger = ThrottledLogger.getLogger(logger, 1000);
2022

2123
private final GrpcAgentStatBatchMapper agentStatBatchMapper;
2224
private final AgentStatGroupService agentStatGroupService;
@@ -34,8 +36,8 @@ public AgentMetricBatchHandler(GrpcAgentStatBatchMapper agentStatBatchMapper,
3436

3537
@Override
3638
public void handleSimple(ServerRequest<PAgentStatBatch> request) {
37-
if (logger.isInfoEnabled()) {
38-
logger.info("Handle PAgentStatBatch {}", request.getHeader());
39+
if (throttledLogger.isInfoEnabled()) {
40+
throttledLogger.info("Handle PAgentStatBatch {}", request.getHeader());
3941
} else if (logger.isDebugEnabled()) {
4042
logger.debug("Handle PAgentStatBatch {} {}", request.getHeader(), MessageFormatUtils.debugLog(request.getData()));
4143
}

0 commit comments

Comments
 (0)