add LOGGER for test

Author: chengyouling

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java

@@ -20,10 +20,10 @@
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.nio.charset.StandardCharsets;
+import java.util.Arrays;
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.servicecomb.common.rest.codec.RestObjectMapperFactory;
-import org.apache.servicecomb.common.rest.filter.inner.ServerRestArgsFilter;
 import org.apache.servicecomb.swagger.sse.SseEventResponseEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -33,7 +33,7 @@
 import jakarta.ws.rs.core.MediaType;
 
 public class ProduceEventStreamProcessor implements ProduceProcessor {
-  private static final Logger LOGGER = LoggerFactory.getLogger(ServerRestArgsFilter.class);
+  private static final Logger LOGGER = LoggerFactory.getLogger(ProduceEventStreamProcessor.class);
 
   private int writeIndex = 0;
 
@@ -59,15 +59,15 @@ public void doEncodeResponse(OutputStream output, Object result) throws Exceptio
       appendEventId(bufferBuilder, writeIndex++);
       appendData(bufferBuilder, result);
     }
-    LOGGER.info("==============provider encoder bufferBuilder==============>" + bufferBuilder);
     bufferBuilder.append("\n");
     output.write(bufferBuilder.toString().getBytes(StandardCharsets.UTF_8));
   }
 
   @Override
   public Object doDecodeResponse(InputStream input, JavaType type) throws Exception {
     String buffer = new String(input.readAllBytes(), StandardCharsets.UTF_8);
-    LOGGER.info("=========doDecodeResponse buffer===================>" + buffer);
+    LOGGER.info("=========doDecodeResponse buffer===================>" + buffer + "stack: {}", Arrays.toString(
+        new Exception().getStackTrace()));
     SseEventResponseEntity<?> responseEntity = new SseEventResponseEntity<>();
     boolean isResponseEntity = false;
     for (String line : buffer.split("\n")) {

demo/demo-spring-boot-transport/demo-spring-boot-springmvc-client/src/main/java/org/apache/servicecomb/springboot/springmvc/client/ReactiveStreamIT.java

@@ -29,12 +29,16 @@
 import org.reactivestreams.Publisher;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Component;
 
 @Component
 public class ReactiveStreamIT implements CategorizedTestCase {
+  private static final Logger LOGGER = LoggerFactory.getLogger(ReactiveStreamIT.class);
+
   @Autowired
   @Qualifier("reactiveStreamProvider")
   ReactiveStreamClient reactiveStreamProvider;
@@ -59,7 +63,6 @@ private void testSseStringWithParam(ReactiveStreamClient client) throws Exceptio
 
   private String buildBufferString(Publisher<String> result) throws Exception {
     CountDownLatch countDownLatch = new CountDownLatch(1);
-    countDownLatch.await(20, TimeUnit.SECONDS);
     StringBuilder buffer = new StringBuilder();
     result.subscribe(new Subscriber<>() {
       Subscription subscription;
@@ -72,18 +75,21 @@ public void onSubscribe(Subscription s) {
 
       @Override
       public void onNext(String s) {
+        LOGGER.info("=========buildBufferString result===================>" + s);
         buffer.append(s);
         subscription.request(1);
       }
 
       @Override
       public void onError(Throwable t) {
+        LOGGER.info("=========buildBufferString onError===================>");
         subscription.cancel();
         countDownLatch.countDown();
       }
 
       @Override
       public void onComplete() {
+        LOGGER.info("=========buildBufferString onComplete===================>");
         countDownLatch.countDown();
       }
     });
@@ -94,7 +100,6 @@ public void onComplete() {
   private void testSseModel(ReactiveStreamClient client) throws Exception {
     Publisher<Model> result = client.sseModel();
     CountDownLatch countDownLatch = new CountDownLatch(1);
-    countDownLatch.await(20, TimeUnit.SECONDS);
     StringBuilder buffer = new StringBuilder();
     result.subscribe(new Subscriber<>() {
       Subscription subscription;
@@ -108,17 +113,20 @@ public void onSubscribe(Subscription s) {
       @Override
       public void onNext(Model s) {
         buffer.append(s.getName()).append(s.getAge());
+        LOGGER.info("=========testSseModel result===================>" + buffer);
         subscription.request(1);
       }
 
       @Override
       public void onError(Throwable t) {
+        LOGGER.info("=========testSseModel error===================>");
         subscription.cancel();
         countDownLatch.countDown();
       }
 
       @Override
       public void onComplete() {
+        LOGGER.info("=========testSseModel onComplete===================>");
         countDownLatch.countDown();
       }
     });
@@ -129,7 +137,6 @@ public void onComplete() {
   private void testSseResponseEntity(ReactiveStreamClient client) throws Exception {
     Publisher<SseEventResponseEntity<Model>> result = client.sseResponseEntity();
     CountDownLatch countDownLatch = new CountDownLatch(1);
-    countDownLatch.await(20, TimeUnit.SECONDS);
     StringBuilder buffer = new StringBuilder();
     result.subscribe(new Subscriber<>() {
       Subscription subscription;
@@ -147,17 +154,20 @@ public void onNext(SseEventResponseEntity<Model> responseEntity) {
         }
         buffer.append(((Model) responseEntity.getData()).getName())
             .append(((Model) responseEntity.getData()).getAge());
+        LOGGER.info("=========testSseResponseEntity result===================>" + buffer);
         subscription.request(1);
       }
 
       @Override
       public void onError(Throwable t) {
+        LOGGER.info("=========testSseResponseEntity error===================>");
         subscription.cancel();
         countDownLatch.countDown();
       }
 
       @Override
       public void onComplete() {
+        LOGGER.info("=========testSseResponseEntity onComplete===================>");
         countDownLatch.countDown();
       }
     });