1616import com .microsoft .durabletask .DurableTaskGrpcWorkerBuilder ;
1717import io .dapr .utils .NetworkUtils ;
1818import io .dapr .workflows .Workflow ;
19+ import org .slf4j .Logger ;
20+ import org .slf4j .LoggerFactory ;
21+
22+ import java .util .HashSet ;
23+ import java .util .Set ;
1924
2025public class WorkflowRuntimeBuilder {
2126 private static volatile WorkflowRuntime instance ;
2227 private DurableTaskGrpcWorkerBuilder builder ;
28+ private static final Logger LOGGER = LoggerFactory .getLogger (WorkflowRuntimeBuilder .class );
29+ private static volatile Set <String > activity_Set = new HashSet <String >();
30+ private static volatile Set <String > workflow_Set = new HashSet <String >();
31+
2332
2433 public WorkflowRuntimeBuilder () {
2534 this .builder = new DurableTaskGrpcWorkerBuilder ().grpcChannel (NetworkUtils .buildGrpcManagedChannel ());
@@ -38,6 +47,8 @@ public WorkflowRuntime build() {
3847 }
3948 }
4049 }
50+ LOGGER .info ("List of registered workflows: " + workflow_Set );
51+ LOGGER .info ("List of registered activites: " + activity_Set );
4152 return instance ;
4253 }
4354
@@ -52,7 +63,7 @@ public <T extends Workflow> WorkflowRuntimeBuilder registerWorkflow(Class<T> cla
5263 this .builder = this .builder .addOrchestration (
5364 new OrchestratorWrapper <>(clazz )
5465 );
55-
66+ WorkflowRuntimeBuilder . workflow_Set . add ( clazz . getCanonicalName ());
5667 return this ;
5768 }
5869
@@ -66,5 +77,6 @@ public <T extends WorkflowActivity> void registerActivity(Class<T> clazz) {
6677 this .builder = this .builder .addActivity (
6778 new ActivityWrapper <>(clazz )
6879 );
80+ WorkflowRuntimeBuilder .activity_Set .add (clazz .getCanonicalName ());
6981 }
7082}
0 commit comments