Skip to content

Commit aa4cc86

Browse files
committed
Updated
1 parent e99a7b4 commit aa4cc86

4 files changed

Lines changed: 8 additions & 11 deletions

File tree

core/src/main/java/io/temporal/samples/nexuswalkthrough/handler/ApprovalServiceImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public OperationHandler<RequestApprovalInput, RequestApprovalOutput> requestAppr
109109
(ctx, client, input) ->
110110
client.startWorkflow(
111111
ApprovalWorkflow.class,
112-
ApprovalWorkflow::requestApproval,
112+
ApprovalWorkflow::runApproval,
113113
input,
114114
WorkflowOptions.newBuilder()
115115
.setWorkflowId(ApprovalWorkflowId.forItem(input.getItemId()))
@@ -225,7 +225,7 @@ public OperationHandler<AttachApprovalContextInput, Void> attachApprovalContext(
225225
BatchRequest request = workflowClient.newSignalWithStartRequest();
226226
request.add(stub::attachContext, input.getNote());
227227
request.add(
228-
stub::requestApproval,
228+
stub::runApproval,
229229
new RequestApprovalInput(input.getItemId(), input.getRequester(), input.getAmount()));
230230
workflowClient.signalWithStart(request);
231231

core/src/main/java/io/temporal/samples/nexuswalkthrough/handler/ApprovalWorkflow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public interface ApprovalWorkflow {
4242
* result, it has to be the Operation's declared output type.
4343
*/
4444
@WorkflowMethod
45-
RequestApprovalOutput requestApproval(RequestApprovalInput input);
45+
RequestApprovalOutput runApproval(RequestApprovalInput input);
4646

4747
/**
4848
* STEP 7 - A Signal. Fire-and-forget: the caller gets no result back, which is why a Signal is

core/src/main/java/io/temporal/samples/nexuswalkthrough/handler/ApprovalWorkflowImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public class ApprovalWorkflowImpl implements ApprovalWorkflow {
3838
private final List<String> notes = new ArrayList<>();
3939

4040
@Override
41-
public RequestApprovalOutput requestApproval(RequestApprovalInput input) {
41+
public RequestApprovalOutput runApproval(RequestApprovalInput input) {
4242
// Placeholder. Real logic would apply policy, check limits, or call a risk service.
4343
activities.evaluateAutoDecision(input.getItemId(), input.getAmount());
4444

core/src/test/java/io/temporal/samples/nexuswalkthrough/ApprovalWorkflowTest.java

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ private ApprovalWorkflow newApproval(String itemId) {
5252
public void decisionSubmittedThroughUpdateBecomesTheResult() {
5353
ApprovalWorkflow approval = newApproval("standing-desk");
5454
WorkflowClient.start(
55-
approval::requestApproval,
55+
approval::runApproval,
5656
new RequestApprovalInput("standing-desk", "dana@example.com", 1250.00));
5757

5858
SubmitDecisionOutput ack =
@@ -70,8 +70,7 @@ public void decisionSubmittedThroughUpdateBecomesTheResult() {
7070
public void remindersAreCountedAndReportedWithTheDecision() {
7171
ApprovalWorkflow approval = newApproval("monitor-arm");
7272
WorkflowClient.start(
73-
approval::requestApproval,
74-
new RequestApprovalInput("monitor-arm", "dana@example.com", 900.00));
73+
approval::runApproval, new RequestApprovalInput("monitor-arm", "dana@example.com", 900.00));
7574

7675
approval.remindApprover();
7776
approval.remindApprover();
@@ -90,8 +89,7 @@ public void remindersAreCountedAndReportedWithTheDecision() {
9089
public void contextCanBeAttachedWhileTheApprovalIsPending() {
9190
ApprovalWorkflow approval = newApproval("laptop-dock");
9291
WorkflowClient.start(
93-
approval::requestApproval,
94-
new RequestApprovalInput("laptop-dock", "dana@example.com", 750.00));
92+
approval::runApproval, new RequestApprovalInput("laptop-dock", "dana@example.com", 750.00));
9593

9694
approval.attachContext("Approved in the Q3 ergonomics budget");
9795
SubmitDecisionOutput ack =
@@ -108,8 +106,7 @@ public void contextCanBeAttachedWhileTheApprovalIsPending() {
108106
public void aSecondDecisionIsRejected() {
109107
ApprovalWorkflow approval = newApproval("desk-lamp");
110108
WorkflowClient.start(
111-
approval::requestApproval,
112-
new RequestApprovalInput("desk-lamp", "dana@example.com", 600.00));
109+
approval::runApproval, new RequestApprovalInput("desk-lamp", "dana@example.com", 600.00));
113110

114111
approval.submitDecision(SubmitDecisionInput.Decision.DECISION_APPROVED);
115112

0 commit comments

Comments
 (0)