aboutsummaryrefslogtreecommitdiffstats
path: root/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc
diff options
context:
space:
mode:
authorRam Krishna Verma <ram_krishna.verma@bell.ca>2021-04-30 17:07:29 +0000
committerGerrit Code Review <gerrit@onap.org>2021-04-30 17:07:29 +0000
commite0b224292938634c10aecd17b641a0888065a8b1 (patch)
tree0e8cdea65c93feda4f8b118f4a6c58399877748d /plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc
parent2f5f1dbd3c38dd3915760158a003b04ca69b478b (diff)
parent7bcbd221e350e45db5be0c4f1ceb2e4e1a418f63 (diff)
Merge "Changes to retain executionProperties per event flow for better context handling"
Diffstat (limited to 'plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc')
-rw-r--r--plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc/src/main/java/org/onap/policy/apex/plugins/event/carrier/grpc/ApexGrpcProducer.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc/src/main/java/org/onap/policy/apex/plugins/event/carrier/grpc/ApexGrpcProducer.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc/src/main/java/org/onap/policy/apex/plugins/event/carrier/grpc/ApexGrpcProducer.java
index 410c83c40..ce00210e8 100644
--- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc/src/main/java/org/onap/policy/apex/plugins/event/carrier/grpc/ApexGrpcProducer.java
+++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc/src/main/java/org/onap/policy/apex/plugins/event/carrier/grpc/ApexGrpcProducer.java
@@ -128,10 +128,10 @@ public class ApexGrpcProducer extends ApexPluginsEventProducer implements CdsPro
LOGGER.error("Sending event \"{}\" by {} to CDS failed.", eventName, this.name);
}
- consumeEvent(executionId, cdsResponse.get());
+ consumeEvent(executionId, executionProperties, cdsResponse.get());
}
- private void consumeEvent(long executionId, ExecutionServiceOutput event) {
+ private void consumeEvent(long executionId, Properties executionProperties, ExecutionServiceOutput event) {
// Find the peered consumer for this producer
final PeeredReference peeredRequestorReference = peerReferenceMap.get(EventHandlerPeeredMode.REQUESTOR);
if (peeredRequestorReference == null) {
@@ -148,7 +148,7 @@ public class ApexGrpcProducer extends ApexPluginsEventProducer implements CdsPro
// Use the consumer to consume this response event in APEX
final ApexGrpcConsumer grpcConsumer = (ApexGrpcConsumer) consumer;
try {
- grpcConsumer.getEventReceiver().receiveEvent(executionId, new Properties(),
+ grpcConsumer.getEventReceiver().receiveEvent(executionId, executionProperties,
JsonFormat.printer().print(event));
} catch (ApexEventException | InvalidProtocolBufferException e) {
throw new ApexEventRuntimeException("Consuming gRPC response failed.", e);