static ImmutableMap getRequestHeaderMap()

in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java [37:48]


  static ImmutableMap<String, String> getRequestHeaderMap(HttpExchange exchange) {
    if (exchange == null || exchange.getRequestHeaders() == null) {
      return ImmutableMap.of();
    }

    Map<String, String> headers = new HashMap<>();
    for (Map.Entry<String, List<String>> entry : exchange.getRequestHeaders().entrySet()) {
      headers.put(entry.getKey(), String.join(",", entry.getValue()));
    }

    return ImmutableMap.copyOf(headers);
  }