Skip to content

Commit 54fcd36

Browse files
committed
using UpperCamelCase for the enum name and lowerCamelCase for values.
1 parent 989b9e1 commit 54fcd36

4 files changed

Lines changed: 20 additions & 20 deletions

File tree

core/src/main/java/io/temporal/samples/taskinteraction/Task.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -25,13 +25,13 @@ public class Task {
2525

2626
private String token;
2727
private Object data;
28-
private STATE state;
28+
private State state;
2929

3030
public Task() {}
3131

3232
public Task(String token) {
3333
this.token = token;
34-
this.state = STATE.PENDING;
34+
this.state = State.pending;
3535
}
3636

3737
public String getToken() {
@@ -46,27 +46,27 @@ public <T> T result(Class<T> tClass) {
4646
return (T) data;
4747
}
4848

49-
public void setState(STATE state) {
49+
public void setState(State state) {
5050
this.state = state;
5151
}
5252

53-
public STATE getState() {
53+
public State getState() {
5454
return state;
5555
}
5656

5757
@JsonIgnore
5858
public boolean isCompleted() {
59-
return STATE.COMPLETED == this.state;
59+
return State.completed == this.state;
6060
}
6161

6262
@Override
6363
public String toString() {
6464
return "Task{" + "token='" + token + '\'' + ", data=" + data + ", state=" + state + '}';
6565
}
6666

67-
public enum STATE {
68-
PENDING,
69-
STARTED,
70-
COMPLETED
67+
public enum State {
68+
pending,
69+
started,
70+
completed
7171
}
7272
}

core/src/main/java/io/temporal/samples/taskinteraction/TaskService.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public void updateTask(TaskRequest taskRequest) {
5555

5656
logger.info("Task updated: " + t);
5757

58-
if (taskRequest.state == Task.STATE.COMPLETED) {
58+
if (taskRequest.state == Task.State.completed) {
5959
final CompletablePromise<R> completablePromise = pendingPromises.get(token);
6060
completablePromise.complete((R) data);
6161
}
@@ -101,21 +101,21 @@ public interface Callback<T> {
101101

102102
public static class TaskRequest {
103103

104-
private Task.STATE state;
104+
private Task.State state;
105105
private String data;
106106
private String token;
107107

108108
public TaskRequest() {}
109109

110-
public TaskRequest(Task.STATE state, String data, String token) {
110+
public TaskRequest(Task.State state, String data, String token) {
111111
this.state = state;
112112
this.data = data;
113113
this.token = token;
114114
}
115115

116116
@JsonIgnore
117117
public boolean isCompleted() {
118-
return this.state == Task.STATE.COMPLETED;
118+
return this.state == Task.State.completed;
119119
}
120120

121121
public String getToken() {

core/src/main/java/io/temporal/samples/taskinteraction/client/UpdateTask.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,9 +41,9 @@ public static void main(String[] args) {
4141
final List<Task> openTasks = taskClient.getOpenTasks();
4242

4343
final Task randomOpenTask = openTasks.get(0);
44-
final List<Task.STATE> states = Arrays.asList(Task.STATE.values());
44+
final List<Task.State> states = Arrays.asList(Task.State.values());
4545

46-
final Task.STATE nextState = states.get(states.indexOf(randomOpenTask.getState()) + 1);
46+
final Task.State nextState = states.get(states.indexOf(randomOpenTask.getState()) + 1);
4747

4848
System.out.println("\nUpdating task " + randomOpenTask + " to " + nextState);
4949
taskClient.updateTask(

core/src/test/java/io/temporal/samples/taskinteraction/TaskWorkflowImplTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -80,28 +80,28 @@ public void testRunWorkflow() throws InterruptedException, ExecutionException {
8080
final List<Task> asyncTasksStarted = taskClient.getOpenTasks();
8181
assertEquals(2, asyncTasksStarted.size());
8282
// Change tasks state, not completing them yet
83-
changeTaskState(taskClient, asyncTasksStarted, Task.STATE.STARTED);
83+
changeTaskState(taskClient, asyncTasksStarted, Task.State.started);
8484

8585
// The two tasks are still open, lets complete them
8686
final List<Task> asyncTasksPending = taskClient.getOpenTasks();
8787
assertEquals(2, asyncTasksPending.size());
88-
changeTaskState(taskClient, asyncTasksPending, Task.STATE.COMPLETED);
88+
changeTaskState(taskClient, asyncTasksPending, Task.State.completed);
8989

9090
// Wait for the activity to get executed for the third time. One more task gets created
9191
completedActivities[0].get();
9292

9393
final List<Task> syncTask = taskClient.getOpenTasks();
9494
assertEquals(1, syncTask.size());
95-
changeTaskState(taskClient, syncTask, Task.STATE.STARTED);
96-
changeTaskState(taskClient, syncTask, Task.STATE.COMPLETED);
95+
changeTaskState(taskClient, syncTask, Task.State.started);
96+
changeTaskState(taskClient, syncTask, Task.State.completed);
9797

9898
// Workflow completes
9999
final WorkflowStub untyped =
100100
testWorkflowRule.getWorkflowClient().newUntypedWorkflowStub(execution.getWorkflowId());
101101
untyped.getResult(String.class);
102102
}
103103

104-
private static void changeTaskState(TaskClient client, List<Task> tasks, Task.STATE state) {
104+
private static void changeTaskState(TaskClient client, List<Task> tasks, Task.State state) {
105105
tasks.forEach(
106106
t -> {
107107
client.updateTask(

0 commit comments

Comments
 (0)