{"record":{"id":"007f0dde5b7dd18d","repo":"pinpoint-apm/pinpoint","slug":"failed-while-request-message-message","errorCode":null,"errorMessage":"Failed while request message. message:{}","messagePattern":"Failed while request message\\. message:(.+?)","errorType":"console","errorClass":null,"httpStatus":null,"severity":"error","filePath":"realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java","lineNumber":204,"sourceCode":"            logger.warn(\"Exception occurred while request message. message:{}\", e.getMessage(), e);\n            if (e.getStatus().getCode() == Status.CANCELLED.getCode()) {\n                clearConnection();\n                return CheckConnectionStatusResult.FAIL_AND_CLEAR_CONNECTION;\n            }\n            return CheckConnectionStatusResult.FAIL;\n        } catch (ClusterException e) {\n            logger.warn(\"Exception occurred while request message. message:{}\", e.getMessage(), e);\n            clearConnection();\n            return CheckConnectionStatusResult.FAIL_AND_CLEAR_CONNECTION;\n        }\n        try {\n            PCmdEchoResponse result = response.get(3000, TimeUnit.MILLISECONDS);\n            if (result.getMessage().equals(\"PING\")) {\n                return CheckConnectionStatusResult.SUCCESS;\n            }\n            logger.warn(\"Receive unexpected response: result = {}\", result);\n        } catch (Exception cause) {\n            logger.warn(\"Failed while request message. message:{}\", cause.getMessage(), cause);\n            return CheckConnectionStatusResult.FAIL;\n        }\n\n        return CheckConnectionStatusResult.FAIL;\n    }\n\n    private void clearConnection() {\n    }\n\n    // If the occur exception in connection, do not retry\n    // Multiple attempts only at timeout\n    private CompletableFuture<PCmdEchoResponse> request0(GrpcAgentConnection conn, int maxCount) {\n        Mono<PCmdEchoResponse> mono = Mono.create(sink -> {\n            long sinkId = this.echoSinkRepository.put(sink);\n            sink.onDispose(() -> {\n                this.echoSinkRepository.invalidate(sinkId);\n            });\n            conn.request(PCmdRequest.newBuilder()","sourceCodeStart":186,"sourceCodeEnd":222,"githubUrl":"https://github.com/pinpoint-apm/pinpoint/blob/744c3d3075e595656abb1ae331ad2c0e4c9eb996/realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java#L186-L222","documentation":"Warn log in ClusterPointController.request: a ClusterException occurred while sending the request to the pinned agent; the connection is cleared and the check returns FAIL_AND_CLEAR_CONNECTION, forcing re-registration.","triggerScenarios":"Thrown at realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java:204 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Check network/gRPC connectivity between collector and agent","Confirm the agent's cluster key is still registered and valid","Allow the connection to be re-established after clearing the stale one"],"exampleFix":null,"handlingStrategy":"fallback","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"744c3d3075e595656abb1ae331ad2c0e4c9eb996","analyzedAt":"2026-09-07T18:48:45.289Z","contentChangedAt":"2026-09-07T18:48:45.289Z","schemaVersion":2},"datasetVersion":"2026-09-17T15:17:12.973Z"}