本文整理了Java中com.netflix.zuul.message.ZuulMessage.getHeaders()方法的一些代码示例，展示了ZuulMessage.getHeaders()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZuulMessage.getHeaders()方法的具体详情如下：
包路径：com.netflix.zuul.message.ZuulMessage
类名称：ZuulMessage
方法名：getHeaders

ZuulMessage.getHeaders介绍

暂无

代码示例

代码示例来源：origin: Netflix/zuul

@Override
public Headers getHeaders()
{
  return message.getHeaders();
}

代码示例来源：origin: Netflix/zuul

@Override
public Headers getHeaders()
{
  return message.getHeaders();
}

代码示例来源：origin: Netflix/zuul

public static boolean hasChunkedTransferEncodingHeader(ZuulMessage msg)
{
  boolean isChunked = false;
  String teValue = msg.getHeaders().getFirst(com.netflix.zuul.message.http.HttpHeaderNames.TRANSFER_ENCODING);
  if (StringUtils.isNotEmpty(teValue)) {
    isChunked = "chunked".equals(teValue.toLowerCase());
  }
  return isChunked;
}

代码示例来源：origin: Netflix/zuul

@Override
public Headers getHeaders()
{
  return message.getHeaders();
}

代码示例来源：origin: Netflix/zuul

@Override
public Headers getHeaders()
{
  return message.getHeaders();
}

代码示例来源：origin: Netflix/zuul

public static Integer getContentLengthIfPresent(ZuulMessage msg)
{
  final String contentLengthValue = msg.getHeaders().getFirst(com.netflix.zuul.message.http.HttpHeaderNames.CONTENT_LENGTH);
  if (StringUtils.isNotEmpty(contentLengthValue) && StringUtils.isNumeric(contentLengthValue)) {
    try {
      return Integer.valueOf(contentLengthValue);
    }
    catch (NumberFormatException e) {
      LOG.info("Invalid Content-Length header value on request. " +
          "value = " + String.valueOf(contentLengthValue));
    }
  }
  return null;
}

代码示例来源：origin: Netflix/zuul

public static boolean hasChunkedTransferEncodingHeader(ZuulMessage msg)
{
  boolean isChunked = false;
  String teValue = msg.getHeaders().getFirst(com.netflix.zuul.message.http.HttpHeaderNames.TRANSFER_ENCODING);
  if (StringUtils.isNotEmpty(teValue)) {
    isChunked = "chunked".equals(teValue.toLowerCase());
  }
  return isChunked;
}

代码示例来源：origin: Netflix/zuul

public static Integer getContentLengthIfPresent(ZuulMessage msg)
{
  final String contentLengthValue = msg.getHeaders().getFirst(com.netflix.zuul.message.http.HttpHeaderNames.CONTENT_LENGTH);
  if (StringUtils.isNotEmpty(contentLengthValue) && StringUtils.isNumeric(contentLengthValue)) {
    try {
      return Integer.valueOf(contentLengthValue);
    }
    catch (NumberFormatException e) {
      LOG.info("Invalid Content-Length header value on request. " +
          "value = " + String.valueOf(contentLengthValue));
    }
  }
  return null;
}

代码示例来源：origin: Netflix/zuul

public static Observable<Boolean> writeDebugMessage(SessionContext context, ZuulMessage msg,
                            String prefix, String arrow)
{
  Observable<Boolean> obs = null;
  for (Header header : msg.getHeaders().entries()) {
    Debug.addRequestDebug(context, String.format("%s:: %s HDR: %s:%s", prefix, arrow, header.getKey(), header.getValue()));
  }
  // Capture the response body into a Byte array for later usage.
  if (msg.hasBody()) {
    if (! Debug.debugRequestHeadersOnly(context)) {
      // Convert body to a String and add to debug log.
      String body = msg.getBodyAsText();
      Debug.addRequestDebug(context, String.format("%s:: %s BODY: %s", prefix, arrow, body));
    }
  }
  if (obs == null)
    obs = Observable.just(Boolean.FALSE);
  return obs;
}

代码示例来源：origin: Netflix/zuul

protected HttpRequestInfo copyRequestInfo()
{
  // Unlike clone(), we create immutable copies of the Headers and HttpQueryParams here.
  HttpRequestMessageImpl req = new HttpRequestMessageImpl(message.getContext(),
      protocol, method, path,
      queryParams.immutableCopy(), message.getHeaders().immutableCopy(), clientIp, scheme,
      port, serverName, true);
  req.setHasBody(hasBody());
  return req;
}

代码示例来源：origin: Netflix/zuul

public static void addRequestDebugForMessage(SessionContext ctx, ZuulMessage message, String prefix)
{
  for (Header header : message.getHeaders().entries()) {
    Debug.addRequestDebug(ctx, prefix + " " + header.getKey() + " " + header.getValue());
  }
  if (message.hasBody()) {
    String bodyStr = message.getBodyAsText();
    Debug.addRequestDebug(ctx, prefix + " " + bodyStr);
  }
}

代码示例来源：origin: Netflix/zuul

@Test
public void testClone()
{
  SessionContext ctx1 = new SessionContext();
  ctx1.set("k1", "v1");
  Headers headers1 = new Headers();
  headers1.set("k1", "v1");
  ZuulMessage msg1 = new ZuulMessageImpl(ctx1, headers1);
  ZuulMessage msg2 = msg1.clone();
  assertEquals(msg1.getBodyAsText(), msg2.getBodyAsText());
  assertEquals(msg1.getHeaders(), msg2.getHeaders());
  assertEquals(msg1.getContext(), msg2.getContext());
  // Verify that values of the 2 messages are decoupled.
  msg1.getHeaders().set("k1", "v_new");
  msg1.getContext().set("k1", "v_new");
  assertEquals("v1", msg2.getHeaders().getFirst("k1"));
  assertEquals("v1", msg2.getContext().get("k1"));
}

代码示例来源：origin: Netflix/zuul

@Override
public ZuulMessage clone()
{
  HttpRequestMessageImpl clone = new HttpRequestMessageImpl(message.getContext().clone(),
      protocol, method, path,
      queryParams.clone(), message.getHeaders().clone(), clientIp, scheme,
      port, serverName);
  if (getInboundRequest() != null) {
    clone.inboundRequest = (HttpRequestInfo) getInboundRequest().clone();
  }
  return clone;
}

代码示例来源：origin: Netflix/zuul

public static Observable<Boolean> writeDebugMessage(SessionContext context, ZuulMessage msg,
                            String prefix, String arrow)
{
  Observable<Boolean> obs = null;
  for (Header header : msg.getHeaders().entries()) {
    Debug.addRequestDebug(context, String.format("%s:: %s HDR: %s:%s", prefix, arrow, header.getKey(), header.getValue()));
  }
  // Capture the response body into a Byte array for later usage.
  if (msg.hasBody()) {
    if (! Debug.debugRequestHeadersOnly(context)) {
      // Convert body to a String and add to debug log.
      String body = msg.getBodyAsText();
      Debug.addRequestDebug(context, String.format("%s:: %s BODY: %s", prefix, arrow, body));
    }
  }
  if (obs == null)
    obs = Observable.just(Boolean.FALSE);
  return obs;
}

代码示例来源：origin: Netflix/zuul

protected HttpRequestInfo copyRequestInfo()
{
  // Unlike clone(), we create immutable copies of the Headers and HttpQueryParams here.
  HttpRequestMessageImpl req = new HttpRequestMessageImpl(message.getContext(),
      protocol, method, path,
      queryParams.immutableCopy(), message.getHeaders().immutableCopy(), clientIp, scheme,
      port, serverName, true);
  req.setHasBody(hasBody());
  return req;
}

代码示例来源：origin: Netflix/zuul

@Test
public void testClone()
{
  SessionContext ctx1 = new SessionContext();
  ctx1.set("k1", "v1");
  Headers headers1 = new Headers();
  headers1.set("k1", "v1");
  ZuulMessage msg1 = new ZuulMessageImpl(ctx1, headers1);
  ZuulMessage msg2 = msg1.clone();
  assertEquals(msg1.getBodyAsText(), msg2.getBodyAsText());
  assertEquals(msg1.getHeaders(), msg2.getHeaders());
  assertEquals(msg1.getContext(), msg2.getContext());
  // Verify that values of the 2 messages are decoupled.
  msg1.getHeaders().set("k1", "v_new");
  msg1.getContext().set("k1", "v_new");
  assertEquals("v1", msg2.getHeaders().getFirst("k1"));
  assertEquals("v1", msg2.getContext().get("k1"));
}

代码示例来源：origin: Netflix/zuul

public static void addRequestDebugForMessage(SessionContext ctx, ZuulMessage message, String prefix)
{
  for (Header header : message.getHeaders().entries()) {
    Debug.addRequestDebug(ctx, prefix + " " + header.getKey() + " " + header.getValue());
  }
  if (message.hasBody()) {
    String bodyStr = message.getBodyAsText();
    Debug.addRequestDebug(ctx, prefix + " " + bodyStr);
  }
}

代码示例来源：origin: Netflix/zuul

@Override
public ZuulMessage clone()
{
  HttpRequestMessageImpl clone = new HttpRequestMessageImpl(message.getContext().clone(),
      protocol, method, path,
      queryParams.clone(), message.getHeaders().clone(), clientIp, scheme,
      port, serverName);
  if (getInboundRequest() != null) {
    clone.inboundRequest = (HttpRequestInfo) getInboundRequest().clone();
  }
  return clone;
}

代码示例来源：origin: com.netflix.zuul/zuul-core

public static boolean hasChunkedTransferEncodingHeader(ZuulMessage msg)
{
  boolean isChunked = false;
  String teValue = msg.getHeaders().getFirst(com.netflix.zuul.message.http.HttpHeaderNames.TRANSFER_ENCODING);
  if (StringUtils.isNotEmpty(teValue)) {
    isChunked = "chunked".equals(teValue.toLowerCase());
  }
  return isChunked;
}

代码示例来源：origin: com.netflix.zuul/zuul-core

public static void addRequestDebugForMessage(SessionContext ctx, ZuulMessage message, String prefix)
{
  for (Header header : message.getHeaders().entries()) {
    Debug.addRequestDebug(ctx, prefix + " " + header.getKey() + " " + header.getValue());
  }
  if (message.hasBody()) {
    String bodyStr = message.getBodyAsText();
    Debug.addRequestDebug(ctx, prefix + " " + bodyStr);
  }
}