wip: wip

Signed-off-by: Javier Aliaga <[email protected]>

Author: javier-aliaga

dapr-spring/dapr-spring-workflows/src/main/java/io/dapr/spring/workflows/config/DaprWorkflowsConfiguration.java

@@ -58,13 +58,12 @@ private void registerWorkflowsAndActivities(ApplicationContext applicationContex
     for (WorkflowActivity activity :  workflowActivitiesBeans.values()) {
       // Get the @Component annotation
       Component componentAnnotation = activity.getClass().getAnnotation(Component.class);
-
+      activity.getName()
       if (componentAnnotation != null) {
         var componentValue = componentAnnotation.value();
         if (StringUtils.isNotEmpty(componentValue)) {
           LOGGER.info("Dapr Workflow Activity: '{}' with name '{}' registered", activity.getClass().getName(), componentValue);
           workflowRuntimeBuilder.registerActivity(componentValue, activity);
-          return;
         }
       }
 

examples/src/main/java/io/dapr/examples/workflows/continueasnew/CleanUpActivity.java

@@ -20,6 +20,7 @@
 
 import java.util.concurrent.TimeUnit;
 
+
 public class CleanUpActivity implements WorkflowActivity {
   @Override
   public Object run(WorkflowActivityContext ctx) {

sdk-workflows/src/main/java/io/dapr/workflows/WorkflowActivity.java

@@ -42,4 +42,8 @@ public interface WorkflowActivity {
    * @return any serializable value to be returned to the calling orchestrator.
    */
   Object run(WorkflowActivityContext ctx);
+
+  default String getName() {
+    return this.getClass().getCanonicalName();
+  }
 }

sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntimeBuilder.java

@@ -116,6 +116,23 @@ public <T extends Workflow> WorkflowRuntimeBuilder registerWorkflow(Class<T> cla
     this.builder.addOrchestration(new WorkflowClassWrapper<>(clazz));
     this.workflowSet.add(clazz.getCanonicalName());
     this.workflows.add(clazz.getSimpleName());
+    
+    this.logger.info("Registered Workflow: {}", clazz.getSimpleName());
+
+    return this;
+  }
+
+  /**
+   * Registers a Workflow object.
+   *
+   * @param <T>   any Workflow type
+   * @param clazz the class being registered
+   * @return the WorkflowRuntimeBuilder
+   */
+  public <T extends Workflow> WorkflowRuntimeBuilder registerWorkflow(String name, Class<T> clazz) {
+    this.builder.addOrchestration(new WorkflowClassWrapper<>(clazz));
+    this.workflowSet.add(name);
+    this.workflows.add(name);
 
     this.logger.info("Registered Workflow: {}", clazz.getSimpleName());