@@ -56,6 +56,7 @@ public class WorkflowImpl implements BindableComponent {
56
56
57
57
private static final StateKey <WorkflowExecutionState > WORKFLOW_EXECUTION_STATE_KEY =
58
58
StateKey .of ("_workflow_execution_state" , WORKFLOW_EXECUTION_STATE_SERDE );
59
+ private static final String START_HANDLER = "_start" ;
59
60
60
61
private final String name ;
61
62
private final Component .Handler <?, ?> workflowMethod ;
@@ -84,7 +85,8 @@ private WorkflowExecutionState submit(Context objectContext, InvokeRequest invok
84
85
.await ();
85
86
if (response .equals (WorkflowExecutionState .STARTED )) {
86
87
// Schedule start
87
- objectContext .send (workflowTarget (name ), INVOKE_REQUEST_SERDE , invokeRequest );
88
+ objectContext .send (
89
+ Target .service (name , WorkflowImpl .START_HANDLER ), INVOKE_REQUEST_SERDE , invokeRequest );
88
90
}
89
91
90
92
return response ;
@@ -316,10 +318,6 @@ private Target workflowManagerTarget(String key, String handler) {
316
318
return Target .virtualObject (workflowManagerObjectName (name ), key , handler );
317
319
}
318
320
319
- private Target workflowTarget (String handler ) {
320
- return Target .service (name , handler );
321
- }
322
-
323
321
// --- Components definition
324
322
325
323
@ Override
@@ -331,7 +329,7 @@ public List<ComponentDefinition> definitions() {
331
329
HandlerSignature .of ("submit" , INVOKE_REQUEST_SERDE , WORKFLOW_EXECUTION_STATE_SERDE ),
332
330
this ::submit )
333
331
.with (
334
- HandlerSignature .of ("_start" , INVOKE_REQUEST_SERDE , CoreSerdes .VOID ),
332
+ HandlerSignature .of (START_HANDLER , INVOKE_REQUEST_SERDE , CoreSerdes .VOID ),
335
333
(context , invokeRequest ) -> {
336
334
this .internalStart (context , invokeRequest );
337
335
return null ;
0 commit comments