@@ -50,47 +50,42 @@ public WorkflowRuntimeBuilder workflowRuntimeBuilder(
5050 @ Value ("${dapr.http.endpoint}" ) String daprHttpEndpoint ,
5151 @ Value ("${dapr.grpc.endpoint}" ) String daprGrpcEndpoint
5252 ){
53- Map <String , String > overrides = Map .of (
54- "dapr.http.endpoint" , daprHttpEndpoint ,
55- "dapr.grpc.endpoint" , daprGrpcEndpoint
56- );
57-
58- WorkflowRuntimeBuilder builder = new WorkflowRuntimeBuilder (new Properties (overrides ));
59-
60- builder .registerWorkflow (TestWorkflow .class );
61- builder .registerWorkflow (TestExecutionKeysWorkflow .class );
62- builder .registerWorkflow (TestNamedActivitiesWorkflow .class );
63-
64- builder .registerActivity (FirstActivity .class );
65- builder .registerActivity (SecondActivity .class );
66- builder .registerActivity (TaskExecutionIdActivity .class );
67-
68-
69- builder .registerActivity ("a" ,FirstActivity .class );
70- builder .registerActivity ("b" ,FirstActivity .class );
71- builder .registerActivity ("c" , new SecondActivity ());
72- builder .registerActivity ("d" , new WorkflowActivity () {
73- @ Override
74- public Object run (WorkflowActivityContext ctx ) {
75- TestWorkflowPayload workflowPayload = ctx .getInput (TestWorkflowPayload .class );
76- workflowPayload .getPayloads ().add ("Anonymous Activity" );
77- return workflowPayload ;
78- }
79- });
80- builder .registerActivity ("e" , new WorkflowActivity () {
81- @ Override
82- public Object run (WorkflowActivityContext ctx ) {
83- TestWorkflowPayload workflowPayload = ctx .getInput (TestWorkflowPayload .class );
84- workflowPayload .getPayloads ().add ("Anonymous Activity 2" );
85- return workflowPayload ;
86- }
87- });
53+ Map <String , String > overrides = Map .of (
54+ "dapr.http.endpoint" , daprHttpEndpoint ,
55+ "dapr.grpc.endpoint" , daprGrpcEndpoint
56+ );
8857
58+ WorkflowRuntimeBuilder builder = new WorkflowRuntimeBuilder (new Properties (overrides ));
8959
60+ builder .registerWorkflow (TestWorkflow .class );
61+ builder .registerWorkflow (TestExecutionKeysWorkflow .class );
62+ builder .registerWorkflow (TestNamedActivitiesWorkflow .class );
9063
91- builder .registerActivity (TaskExecutionKeyActivity .class );
64+ builder .registerActivity (FirstActivity .class );
65+ builder .registerActivity (SecondActivity .class );
66+ builder .registerActivity (TaskExecutionIdActivity .class );
9267
68+ builder .registerActivity ("a" , FirstActivity .class );
69+ builder .registerActivity ("b" , FirstActivity .class );
70+ builder .registerActivity ("c" , new SecondActivity ());
71+ builder .registerActivity ("d" , new WorkflowActivity () {
72+ @ Override
73+ public Object run (WorkflowActivityContext ctx ) {
74+ TestWorkflowPayload workflowPayload = ctx .getInput (TestWorkflowPayload .class );
75+ workflowPayload .getPayloads ().add ("Anonymous Activity" );
76+ return workflowPayload ;
77+ }
78+ });
79+ builder .registerActivity ("e" , new WorkflowActivity () {
80+ @ Override
81+ public Object run (WorkflowActivityContext ctx ) {
82+ TestWorkflowPayload workflowPayload = ctx .getInput (TestWorkflowPayload .class );
83+ workflowPayload .getPayloads ().add ("Anonymous Activity 2" );
84+ return workflowPayload ;
85+ }
86+ });
9387
94- return builder ;
88+ builder .registerActivity (TaskExecutionIdActivity .class );
89+ return builder ;
9590 }
9691}
0 commit comments