Skip to content

Commit

Permalink
Show registered workflow
Browse files Browse the repository at this point in the history
  • Loading branch information
addjuarez committed Nov 9, 2023
1 parent 0d0d599 commit 759528a
Showing 1 changed file with 13 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,19 @@
import com.microsoft.durabletask.DurableTaskGrpcWorkerBuilder;
import io.dapr.utils.NetworkUtils;
import io.dapr.workflows.Workflow;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashSet;
import java.util.Set;

public class WorkflowRuntimeBuilder {
private static volatile WorkflowRuntime instance;
private DurableTaskGrpcWorkerBuilder builder;
private static final Logger LOGGER = LoggerFactory.getLogger(WorkflowRuntimeBuilder.class);
private static volatile Set<String> activity_Set = new HashSet<String>();
private static volatile Set<String> workflow_Set = new HashSet<String>();


public WorkflowRuntimeBuilder() {
this.builder = new DurableTaskGrpcWorkerBuilder().grpcChannel(NetworkUtils.buildGrpcManagedChannel());
Expand All @@ -38,6 +47,8 @@ public WorkflowRuntime build() {
}
}
}
LOGGER.info("List of registered workflows: " + workflow_Set);
LOGGER.info("List of registered activites: " + activity_Set);
return instance;
}

Expand All @@ -52,7 +63,7 @@ public <T extends Workflow> WorkflowRuntimeBuilder registerWorkflow(Class<T> cla
this.builder = this.builder.addOrchestration(
new OrchestratorWrapper<>(clazz)
);

WorkflowRuntimeBuilder.workflow_Set.add(clazz.getCanonicalName());
return this;
}

Expand All @@ -66,5 +77,6 @@ public <T extends WorkflowActivity> void registerActivity(Class<T> clazz) {
this.builder = this.builder.addActivity(
new ActivityWrapper<>(clazz)
);
WorkflowRuntimeBuilder.activity_Set.add(clazz.getCanonicalName());
}
}

0 comments on commit 759528a

Please sign in to comment.