X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ves-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fvesagent%2Fmapper%2FMapperRequestSender.java;fp=ves-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fvesagent%2Fmapper%2FMapperRequestSender.java;h=37d8729b412d922a4231c3129ada938bdfebedce;hb=917e6436721c3cf0075ab1abacb5f7bc0e4732a9;hp=8cebd1d2c613965d68a6df56542514a71789e697;hpb=bf6ffaf6e08b066da8bc69ab7b478d8b5528ce21;p=oam%2Ftr069-adapter.git

diff --git a/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/mapper/MapperRequestSender.java b/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/mapper/MapperRequestSender.java
index 8cebd1d..37d8729 100644
--- a/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/mapper/MapperRequestSender.java
+++ b/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/mapper/MapperRequestSender.java
@@ -49,7 +49,7 @@ public class MapperRequestSender {
   // DeviceRPCResponse.class);
   // }
 
-  @Async
+  @Async("threadPoolTaskExecutor2")
   public Future<DeviceRPCResponse> sendRequest(DeviceRPCRequest deviceRPCRequest) {
     LOG.info("Sending device connectivity request to ACS for device {}",
         deviceRPCRequest.getDeviceDetails().getDeviceId());