Skip to content

Commit

Permalink
Fix errors
Browse files Browse the repository at this point in the history
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
  • Loading branch information
addjuarez committed Nov 27, 2023
1 parent 76c2265 commit 878225d
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ public class WorkflowRuntimeBuilder {
private static volatile WorkflowRuntime instance;
private DurableTaskGrpcWorkerBuilder builder;
private static final Logger LOGGER = LoggerFactory.getLogger(WorkflowRuntimeBuilder.class);
private volatile Set<String> activity_Set = new HashSet<String>();
private volatile Set<String> workflow_Set = new HashSet<String>();
private volatile Set<String> activitySet = new HashSet<String>();
private volatile Set<String> workflowSet = new HashSet<String>();


public WorkflowRuntimeBuilder() {
Expand All @@ -47,8 +47,8 @@ public WorkflowRuntime build() {
}
}
}
LOGGER.info("List of registered workflows: " + workflow_Set);
LOGGER.info("List of registered activites: " + activity_Set);
LOGGER.info("List of registered workflows: " + this.workflowSet);
LOGGER.info("List of registered activites: " + this.activitySet);
return instance;
}

Expand All @@ -63,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());
this.workflowSet.add(clazz.getCanonicalName());
return this;
}

Expand All @@ -77,6 +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());
this.activitySet.add(clazz.getCanonicalName());
}
}

0 comments on commit 878225d

Please sign in to comment.