private void onRequestBody()

in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java [47:66]

• 15 lines of code
• 2 McCabe index (conditional complexity)

    private void onRequestBody(HttpServerExchange exchange, byte[] payload) {
      exchange.dispatch();

      try {
        final Address address = parseAddress(exchange.getRelativePath());
        final String typeUrl = parseTypeUrl(exchange.getRequestHeaders());

        final RoutingConfig routingConfig = createRoutingConfig(address, typeUrl);

        final AutoRoutable autoRoutable = createAutoRoutable(payload, address, routingConfig);

        messageQueue.put(autoRoutable);
        exchange.getResponseHeaders().put(Headers.STATUS, StatusCodes.OK);
      } catch (ParseException | InterruptedException e) {
        e.printStackTrace(System.out);
        exchange.getResponseHeaders().put(Headers.STATUS, StatusCodes.INTERNAL_SERVER_ERROR);
      }

      exchange.endExchange();
    }