diff options
author | Tait,Trevor(rt0435) <rtait@amdocs.com> | 2019-02-27 15:30:17 -0500 |
---|---|---|
committer | Tait,Trevor(rt0435) <rtait@amdocs.com> | 2019-03-04 16:22:59 -0500 |
commit | 3b255bbe0265f6310c928485476dcc65d8652651 (patch) | |
tree | a416e48a7c35ba523c20fdc5b43e2d80348aada7 /src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java | |
parent | ee99bf3fb4cdd26214d03045b18fa7f8b7f54027 (diff) |
POMBA: X-ONAP-RequestID and X-FromAppId support
Issue-ID: LOG-551
Change-Id: I672c32443c1f800607882571cf2927e3778d1e41
Signed-off-by: Tait,Trevor(rt0435) <rtait@amdocs.com>
Diffstat (limited to 'src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java')
-rw-r--r-- | src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java b/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java index 21f3a3e..dca9796 100644 --- a/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java +++ b/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java @@ -27,7 +27,6 @@ import com.att.nsa.mr.client.MRConsumer; import com.att.nsa.mr.client.MRPublisher; import com.att.nsa.mr.client.MRTopicManager; import com.att.nsa.mr.client.impl.MRSimplerBatchPublisher; - import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; @@ -35,12 +34,12 @@ import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.UUID; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; - import org.onap.pomba.common.datatypes.DataQuality; import org.onap.pomba.common.datatypes.DataQuality.Status; import org.onap.pomba.common.datatypes.ModelContext; @@ -65,6 +64,7 @@ public class ContextAggregatorProcessor implements Callable<Void> { private static final Gson gson = new GsonBuilder().disableHtmlEscaping().create(); private ExecutorService executor = Executors.newFixedThreadPool(10); private int retriesRemaining; + private static UUID instanceId = UUID.randomUUID(); @Autowired private MRConsumer consumer; @@ -108,7 +108,7 @@ public class ContextAggregatorProcessor implements Callable<Void> { for (ContextBuilder builder : contextBuilders) { try { log.info("Retrieving model data for: {}", builder.getContextName()); - String modelData = RestRequest.getModelData(builder, event); + String modelData = RestRequest.getModelData(builder, event, instanceId); retrievedModels.put(builder.getContextName(), modelData); } catch (ContextAggregatorException e) { DataQuality errorDataQuality = new DataQuality(); |