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

ZuulMessage介绍

[英]User: Mike Smith Date: 7/16/15 Time: 12:22 AM
[中]用户：迈克·史密斯日期：7/16/15时间：上午12:22

代码示例

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

@Override
public void bufferBodyContents(HttpContent chunk) {
  message.bufferBodyContents(chunk);
}

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

@Override
public void disposeBufferedBody() {
  message.disposeBufferedBody();
}

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

@Override
public boolean finishBufferedBodyIfIncomplete() {
  return message.finishBufferedBodyIfIncomplete();
}

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

public static Integer getBodySizeIfKnown(ZuulMessage msg) {
  final Integer bodySize = getContentLengthIfPresent(msg);
  if (bodySize != null) {
    return bodySize.intValue();
  }
  if (msg.hasCompleteBody()) {
    return msg.getBodyLength();
  }
  return null;
}

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

@Test
public void testMultiSetBodyAsTextGetBody() {
  final ZuulMessage msg = new ZuulMessageImpl(new SessionContext(), new Headers());
  msg.setBodyAsText("Hello World!");
  String body = new String(msg.getBody());
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Hello World!", body);
  msg.setBodyAsText("Goodbye World!");
  body = new String(msg.getBody());
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Goodbye World!", body);
}

代码示例来源：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 testBufferBody3GetBody() {
  final ZuulMessage msg = new ZuulMessageImpl(new SessionContext(), new Headers());
  msg.bufferBodyContents(new DefaultHttpContent(Unpooled.copiedBuffer("Hello ".getBytes())));
  msg.bufferBodyContents(new DefaultHttpContent(Unpooled.copiedBuffer("World!".getBytes())));
  msg.bufferBodyContents(new DefaultLastHttpContent());
  final String body = new String(msg.getBody());
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Hello World!", body);
}

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

@Test
public void testBufferBody3GetBodyAsText() {
  final ZuulMessage msg = new ZuulMessageImpl(new SessionContext(), new Headers());
  msg.bufferBodyContents(new DefaultHttpContent(Unpooled.copiedBuffer("Hello ".getBytes())));
  msg.bufferBodyContents(new DefaultHttpContent(Unpooled.copiedBuffer("World!".getBytes())));
  msg.bufferBodyContents(new DefaultLastHttpContent());
  final String body = msg.getBodyAsText();
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Hello World!", body);
}

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

@Test
public void testSetBodyAsTextGetBodyAsText() {
  final ZuulMessage msg = new ZuulMessageImpl(new SessionContext(), new Headers());
  msg.setBodyAsText("Hello World!");
  final String body = msg.getBodyAsText();
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Hello World!", body);
}

代码示例来源：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

protected final O filter(final ZuulFilter<I, O> filter, final I inMesg) {
  final long startTime = System.currentTimeMillis();
  final ZuulMessage snapshot = inMesg.getContext().debugRouting() ? inMesg.clone() : null;
  FilterChainResumer resumer = null;
    if (filter.filterType() == INBOUND && inMesg.getContext().shouldSendErrorResponse()) {
      LOG.debug("Filter {} waiting for body, UUID {}", filter.filterName(), inMesg.getContext().getUUID());
      return null;  //wait for whole body to be buffered
      Debug.addRoutingDebug(inMesg.getContext(), "Filter " + filter.filterType().toString() + " " + filter.filterOrder() + " " + filter.filterName());
    inMesg.runBufferedBodyContentThroughFilter(filter);
    outMesg.finishBufferedBodyIfIncomplete();
    recordFilterCompletion(FAILED, filter, startTime, inMesg, snapshot);
    return outMesg;

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

@Test
public void testMultiSetBodyGetBody() {
  final ZuulMessage msg = new ZuulMessageImpl(new SessionContext(), new Headers());
  msg.setBody("Hello World!".getBytes());
  String body = new String(msg.getBody());
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Hello World!", body);
  msg.setBody("Goodbye World!".getBytes());
  body = new String(msg.getBody());
  assertTrue(msg.hasBody());
  assertTrue(msg.hasCompleteBody());
  assertEquals("Goodbye World!", body);
}

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

inMesg.bufferBodyContents(chunk);
  CurrentPassport passport = CurrentPassport.fromSessionContext(inMesg.getContext());
  if (inMesg.hasCompleteBody()) {
    if (inMesg instanceof HttpRequestMessage) {
      passport.addIfNotAlready(PassportState.FILTERS_INBOUND_BUF_END);
if (isAwaitingBody && inMesg.hasCompleteBody()) {

代码示例来源：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

@Override
public SessionContext getContext()
{
  return message.getContext();
}

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

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

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

@Test
public void testSetBodyGetBody() {
  final ZuulMessage msg = new ZuulMessageImpl(new SessionContext(), new Headers());
  msg.setBody("Hello World!".getBytes());
  final String body = new String(msg.getBody());
  assertEquals("Hello World!", body);
}

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

@Override
public Iterable<HttpContent> getBodyContents() {
  return message.getBodyContents();
}

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

@Override
public int getBodyLength() {
  return message.getBodyLength();
}

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

@Override
public String getBodyAsText() {
  return message.getBodyAsText();
}