Update the test scenarios for the Jetty client

Author: xhrg

test/plugin/scenarios/jetty-scenario/jettyclient-scenario/src/main/java/org/apache/skywalking/apm/testcase/jettyclient/controller/CaseController.java

@@ -25,7 +25,11 @@
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClients;
 import org.eclipse.jetty.client.HttpClient;
+import org.eclipse.jetty.client.api.Request;
 import org.eclipse.jetty.client.api.Response;
+import org.eclipse.jetty.client.api.Result;
+import org.eclipse.jetty.client.util.BufferingResponseListener;
+import org.eclipse.jetty.http.HttpMethod;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.PropertySource;
 import org.springframework.stereotype.Controller;
@@ -61,6 +65,19 @@ public String jettyClientScenario() throws Exception {
             }
         };
         client.newRequest("http://" + jettyServerHost + ":18080/jettyserver-case/case/receiveContext-1").send(listener);
+
+        //When using BufferingResponseListener, check getContent
+        Request request = client.newRequest("http://" + jettyServerHost + ":18080/jettyserver-case/case/receiveContext-0").method(HttpMethod.GET);
+        request.send(new BufferingResponseListener() {
+            @Override
+            public void onComplete(Result result) {
+                byte[] bytes = getContent();
+                if (bytes == null || bytes.length == 0) {
+                    throw new RuntimeException("content cant empty");
+                }
+            }
+        });
+
         return "Success";
     }
 

test/plugin/scenarios/jetty-scenario/jettyserver-scenario/src/main/java/org/apache/skywalking/apm/testcase/jettyserver/servlet/CaseServlet.java

@@ -19,6 +19,7 @@
 package org.apache.skywalking.apm.testcase.jettyserver.servlet;
 
 import java.io.IOException;
+import java.io.PrintWriter;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServlet;
 import javax.servlet.http.HttpServletRequest;
@@ -31,6 +32,9 @@ public class CaseServlet extends HttpServlet {
     protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
         try {
             Thread.sleep(2000);
+            resp.setContentType("text/plain;charset=UTF-8");
+            PrintWriter out = resp.getWriter();
+            out.print("Success");
         } catch (InterruptedException e) {
         }
     }