diff options
author | 2021-04-30 17:07:29 +0000 | |
---|---|---|
committer | 2021-04-30 17:07:29 +0000 | |
commit | e0b224292938634c10aecd17b641a0888065a8b1 (patch) | |
tree | 0e8cdea65c93feda4f8b118f4a6c58399877748d /plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-grpc/src | |
parent | 2f5f1dbd3c38dd3915760158a003b04ca69b478b (diff) | |
parent | 7bcbd221e350e45db5be0c4f1ceb2e4e1a418f63 (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/src')
-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.java | 6 |
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); |