Able to set runner in services for statefull service which reuse same…

… runner (#264)
project-flogo · Oct 25, 2021 · c22e7e0 · c22e7e0
1 parent b041615
commit c22e7e0
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/action/action.go b/action/action.go
@@ -74,3 +74,7 @@ type ResultHandler interface {
 	// Done indicates that the action has completed
 	Done()
 }
+
+type RunnerSettable interface {
+	SetRunner(runner Runner)
+}
diff --git a/engine/engineimpl.go b/engine/engineimpl.go
@@ -120,6 +120,9 @@ func New(appConfig *app.Config, options ...Option) (Engine, error) {
 					if err != nil {
 						return nil, err
 					}
+					if s, ok := svc.(action.RunnerSettable); ok {
+						s.SetRunner(engine.actionRunner)
+					}
 					err = engine.serviceManager.RegisterService(svc)
 					if err != nil {
 						return nil, err