@@ -104,7 +104,7 @@ public void executeChild() {
104
104
}
105
105
}
106
106
107
- public interface ReceiveSignalObject_ChildWorkflow {
107
+ public interface ReceiveSignalObjectChildWorkflow {
108
108
109
109
@ WorkflowMethod
110
110
String execute ();
@@ -116,7 +116,7 @@ public interface ReceiveSignalObject_ChildWorkflow {
116
116
void close ();
117
117
}
118
118
119
- public static class ReceiveSignalObject_ChildWorkflowImpl implements ReceiveSignalObject_ChildWorkflow {
119
+ public static class ReceiveSignalObjectChildWorkflowImpl implements ReceiveSignalObjectChildWorkflow {
120
120
private String receivedSignal = "Initial State" ;
121
121
// Keep workflow open so that we can send signal
122
122
CompletablePromise <Void > promise = Workflow .newPromise ();
@@ -137,17 +137,17 @@ public void close() {
137
137
}
138
138
}
139
139
140
- public interface SendSignalObject_Workflow {
140
+ public interface SendSignalObjectWorkflow {
141
141
142
142
@ WorkflowMethod
143
143
String execute ();
144
144
}
145
145
146
- public static class SendSignalObject_WorkflowImpl implements SendSignalObject_Workflow {
146
+ public static class SendSignalObjectWorkflowImpl implements SendSignalObjectWorkflow {
147
147
@ Override
148
148
public String execute () {
149
- ReceiveSignalObject_ChildWorkflow child =
150
- Workflow .newChildWorkflowStub (ReceiveSignalObject_ChildWorkflow .class );
149
+ ReceiveSignalObjectChildWorkflow child =
150
+ Workflow .newChildWorkflowStub (ReceiveSignalObjectChildWorkflow .class );
151
151
Promise <String > greeting = Async .function (child ::execute );
152
152
Signal sig = new Signal ();
153
153
sig .value = "Hello World" ;
@@ -226,7 +226,7 @@ public void testCorruptedSignalMetrics() throws InterruptedException {
226
226
builder .setInterceptorFactory (new CorruptedSignalWorkflowInterceptorFactory ()));
227
227
228
228
worker .registerWorkflowImplementationTypes (
229
- SendSignalObject_WorkflowImpl .class , ReceiveSignalObject_ChildWorkflowImpl .class );
229
+ SendSignalObjectWorkflowImpl .class , ReceiveSignalObjectChildWorkflowImpl .class );
230
230
worker .start ();
231
231
232
232
WorkflowOptions options =
@@ -236,7 +236,7 @@ public void testCorruptedSignalMetrics() throws InterruptedException {
236
236
.build ();
237
237
238
238
WorkflowClient workflowClient = testEnvironment .newWorkflowClient ();
239
- SendSignalObject_Workflow workflow = workflowClient .newWorkflowStub (SendSignalObject_Workflow .class , options );
239
+ SendSignalObjectWorkflow workflow = workflowClient .newWorkflowStub (SendSignalObjectWorkflow .class , options );
240
240
workflow .execute ();
241
241
242
242
//Wait for reporter
0 commit comments