Skip to content

Commit a25a54a

Browse files
committed
Rename internal debouncer workflow to debouncerWorkflow, drop redundant dbos prefix
1 parent 40215c3 commit a25a54a

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

transact/src/main/java/dev/dbos/transact/Constants.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ public class Constants {
1616

1717
public static final String DBOS_INTERNAL_QUEUE = "_dbos_internal_queue";
1818

19-
public static final String DEBOUNCER_WORKFLOW_NAME = "_dbos_debouncer_workflow";
20-
public static final String DEBOUNCER_SERVICE_CLASS_NAME = "DBOS.InternalWorkflows";
19+
public static final String DEBOUNCER_WORKFLOW_NAME = "debouncerWorkflow";
20+
public static final String DEBOUNCER_CLASS_NAME = "DBOS.InternalWorkflows";
2121
public static final String DEBOUNCER_TOPIC = "_dbos_debouncer_topic";
2222
// Event key published by the debouncer-workflow so callers can retrieve the pre-assigned
2323
// user workflow id without relying on Jackson deserialization of workflow inputs.

transact/src/main/java/dev/dbos/transact/DBOS.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ public DBOS(@NonNull DBOSConfig config) {
9797
this.debouncerWorkflow =
9898
integration.registerInternalWorkflow(
9999
Constants.DEBOUNCER_WORKFLOW_NAME,
100-
Constants.DEBOUNCER_SERVICE_CLASS_NAME,
100+
Constants.DEBOUNCER_CLASS_NAME,
101101
internalWorkflows,
102102
InternalWorkflows.debouncerWorkflowMethod());
103103
}

transact/src/main/java/dev/dbos/transact/DebouncerClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ private DebouncerClient(
261261
var enqueueOpts =
262262
new DBOSClient.EnqueueOptions(
263263
Constants.DEBOUNCER_WORKFLOW_NAME,
264-
Constants.DEBOUNCER_SERVICE_CLASS_NAME,
264+
Constants.DEBOUNCER_CLASS_NAME,
265265
Constants.DBOS_INTERNAL_QUEUE)
266266
.withDeduplicationId(deduplicationId);
267267

0 commit comments

Comments
 (0)