public void onMessage()

in client/src/main/java/co/elastic/opamp/client/request/service/WebSocketRequestService.java [121:133]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  public void onMessage(WebSocket webSocket, byte[] data) {
    try {
      Opamp.ServerToAgent serverToAgent = readServerToAgent(data);

      if (serverToAgent.hasErrorResponse()) {
        handleServerError(serverToAgent.getErrorResponse());
      }

      callback.onRequestSuccess(Response.create(serverToAgent));
    } catch (IOException e) {
      callback.onRequestFailed(e);
    }
  }