[pinpoint-apm#8557] add ning async http client support

yjqg6666 · Dec 30, 2021 · 89cae3b · 89cae3b
1 parent 8bf7d4c
commit 89cae3b
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/...va/com/navercorp/pinpoint/plugin/ning/asynchttpclient/interceptor/ExecuteInterceptor.java b/...va/com/navercorp/pinpoint/plugin/ning/asynchttpclient/interceptor/ExecuteInterceptor.java
@@ -23,9 +23,11 @@
 import com.navercorp.pinpoint.bootstrap.interceptor.AroundInterceptor;
 import com.navercorp.pinpoint.bootstrap.logging.PLogger;
 import com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory;
+import com.navercorp.pinpoint.bootstrap.plugin.request.ApplicationInfoSender;
 import com.navercorp.pinpoint.bootstrap.plugin.request.ClientHeaderAdaptor;
 import com.navercorp.pinpoint.bootstrap.plugin.request.ClientRequestAdaptor;
 import com.navercorp.pinpoint.bootstrap.plugin.request.ClientRequestRecorder;
+import com.navercorp.pinpoint.bootstrap.plugin.request.DefaultApplicationInfoSender;
 import com.navercorp.pinpoint.bootstrap.plugin.request.DefaultRequestTraceWriter;
 import com.navercorp.pinpoint.bootstrap.plugin.request.RequestTraceWriter;
 import com.navercorp.pinpoint.bootstrap.plugin.request.util.CookieExtractor;
@@ -56,6 +58,7 @@ public class ExecuteInterceptor implements AroundInterceptor {
 
  private final ClientRequestRecorder<Request> clientRequestRecorder;
  private final RequestTraceWriter<Request> requestTraceWriter;
+ private final ApplicationInfoSender<Request> applicationInfoSender;
  private final CookieRecorder<Request> cookieRecorder;
  private final EntityRecorder<Request> entityRecorder;
 
@@ -75,6 +78,7 @@ public ExecuteInterceptor(TraceContext traceContext, MethodDescriptor descriptor
 
  ClientHeaderAdaptor<Request> clientHeaderAdaptor = new RequestHeaderAdaptorV2();
  this.requestTraceWriter = new DefaultRequestTraceWriter<>(clientHeaderAdaptor, traceContext);
+ this.applicationInfoSender = new DefaultApplicationInfoSender<>(clientHeaderAdaptor, traceContext);
  }
 
  @Override
@@ -93,6 +97,8 @@ public void before(Object target, Object[] args) {
  }
 
  final Request httpRequest = (Request) args[0];
+ applicationInfoSender.sendCallerApplicationName(httpRequest);
+
  final boolean sampling = trace.canSampled();
  if (!sampling) {
  if (httpRequest != null) {

diff --git a/...navercorp/pinpoint/plugin/ning/asynchttpclient/interceptor/ExecuteRequestInterceptor.java b/...navercorp/pinpoint/plugin/ning/asynchttpclient/interceptor/ExecuteRequestInterceptor.java
@@ -23,9 +23,11 @@
 import com.navercorp.pinpoint.bootstrap.interceptor.AroundInterceptor;
 import com.navercorp.pinpoint.bootstrap.logging.PLogger;
 import com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory;
+import com.navercorp.pinpoint.bootstrap.plugin.request.ApplicationInfoSender;
 import com.navercorp.pinpoint.bootstrap.plugin.request.ClientHeaderAdaptor;
 import com.navercorp.pinpoint.bootstrap.plugin.request.ClientRequestAdaptor;
 import com.navercorp.pinpoint.bootstrap.plugin.request.ClientRequestRecorder;
+import com.navercorp.pinpoint.bootstrap.plugin.request.DefaultApplicationInfoSender;
 import com.navercorp.pinpoint.bootstrap.plugin.request.DefaultRequestTraceWriter;
 import com.navercorp.pinpoint.bootstrap.plugin.request.RequestTraceWriter;
 import com.navercorp.pinpoint.bootstrap.plugin.request.util.CookieExtractor;
@@ -63,6 +65,7 @@ public class ExecuteRequestInterceptor implements AroundInterceptor {
  private final EntityRecorder<Request> entityRecorder;
 
  private final RequestTraceWriter<Request> requestTraceWriter;
+ private final ApplicationInfoSender<Request> applicationInfoSender;
 
  // for 1.8.x and 1.9.x
  public ExecuteRequestInterceptor(TraceContext traceContext, MethodDescriptor descriptor) {
@@ -81,6 +84,7 @@ public ExecuteRequestInterceptor(TraceContext traceContext, MethodDescriptor des
 
  ClientHeaderAdaptor<Request> clientHeaderAdaptor = new RequestHeaderAdaptorV1();
  this.requestTraceWriter = new DefaultRequestTraceWriter<>(clientHeaderAdaptor, traceContext);
+ this.applicationInfoSender = new DefaultApplicationInfoSender<>(clientHeaderAdaptor, traceContext);
  }
 
  @Override
@@ -99,6 +103,8 @@ public void before(Object target, Object[] args) {
  }
 
  final Request httpRequest = (Request) args[0];
+ applicationInfoSender.sendCallerApplicationName(httpRequest);
+
  final boolean sampling = trace.canSampled();
  if (!sampling) {
  if (httpRequest != null) {