gpt4 book ai didi

com.netflix.zuul.message.ZuulMessage.getBodyAsText()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-18 19:45:31 26 4
gpt4 key购买 nike

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

ZuulMessage.getBodyAsText介绍

暂无

代码示例

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

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

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

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

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

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

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

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

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

@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

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

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

@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 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

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

@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: com.netflix.zuul/zuul-core

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

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

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

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

@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: 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);
  }
}

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

@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: com.netflix.zuul/zuul-core

@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"));
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com