ONOS-7963 workflow invocation trigger on ONOS event
Change-Id: Ie9014bfa77f5514c3580042f9ff2add8e42f25f6
diff --git a/apps/workflow/api/src/main/java/org/onosproject/workflow/api/DefaultWorkflowContext.java b/apps/workflow/api/src/main/java/org/onosproject/workflow/api/DefaultWorkflowContext.java
index 8f5d3c7..977a978 100644
--- a/apps/workflow/api/src/main/java/org/onosproject/workflow/api/DefaultWorkflowContext.java
+++ b/apps/workflow/api/src/main/java/org/onosproject/workflow/api/DefaultWorkflowContext.java
@@ -92,6 +92,12 @@
private transient WorkplaceStore workplaceStore;
/**
+ * Service reference for eventMap store.
+ */
+ private transient ContextEventMapStore eventMapStore;
+
+
+ /**
* Constructor of DefaultWorkflowContext.
* @param builder default workflow context builder
*/
@@ -214,6 +220,11 @@
}
@Override
+ public void registerTriggerEvent(Class<? extends Event> event, Set<String> eventHintSet) throws WorkflowException {
+ eventMapStore.registerTriggerFlag(event.getName(), eventHintSet, this.name());
+ }
+
+ @Override
public void setWorkflowExecutionService(WorkflowExecutionService workflowExecutionService) {
this.workflowExecutionService = workflowExecutionService;
}
@@ -243,6 +254,17 @@
return workplaceStore;
}
+
+ @Override
+ public void setEventMapStore(ContextEventMapStore contextEventMapStore) {
+ this.eventMapStore = contextEventMapStore;
+ }
+
+ @Override
+ public ContextEventMapStore eventMapStore() {
+ return eventMapStore;
+ }
+
public <T> T getService(Class<T> serviceClass) throws WorkflowException {
T service;
try {