[#5156] Apply AsyncSpanEvent to LinkFilter

pinpoint-apm · Feb 8, 2019 · c0f7dda · c0f7dda
1 parent 0a4ede9
commit c0f7dda
Show file tree

Hide file tree

Showing 5 changed files with 176 additions and 140 deletions.
diff --git a/commons-server/src/main/java/com/navercorp/pinpoint/common/server/bo/SpanBo.java b/commons-server/src/main/java/com/navercorp/pinpoint/common/server/bo/SpanBo.java
@@ -17,6 +17,7 @@
 package com.navercorp.pinpoint.common.server.bo;
 
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 
 import com.navercorp.pinpoint.common.util.TransactionId;
@@ -226,7 +227,7 @@ public List<SpanEventBo> getSpanEventBoList() {
 
     public List<SpanChunkBo> getAsyncSpanChunkBoList() {
         if (asyncSpanChunkBoList == null) {
-            this.asyncSpanChunkBoList = new ArrayList<>();
+            return Collections.emptyList();
         }
         return asyncSpanChunkBoList;
     }

diff --git a/web/src/main/java/com/navercorp/pinpoint/web/filter/Filter.java b/web/src/main/java/com/navercorp/pinpoint/web/filter/Filter.java
@@ -25,16 +25,16 @@
  * @author netspider
  * @author emeroad
  */
-public interface Filter {
+public interface Filter<T> {
     boolean ACCEPT = true;
     boolean REJECT = false;
 
     Filter NONE = new Filter() {
         @Override
-        public boolean include(List<SpanBo> transaction) {
+        public boolean include(List transaction) {
             return ACCEPT;
         }
     };
 
-    boolean include(List<SpanBo> transaction);
+    boolean include(List<T> transaction);
 }
diff --git a/web/src/main/java/com/navercorp/pinpoint/web/filter/FilterChain.java b/web/src/main/java/com/navercorp/pinpoint/web/filter/FilterChain.java
@@ -26,7 +26,7 @@
  * @author netspider
  *
  */
-public class FilterChain implements Filter {
+public class FilterChain implements Filter<SpanBo> {
 
     private final List<Filter> filterList = new ArrayList<>();