@@ -104,7 +104,7 @@ public void executeChild() {
104104 }
105105 }
106106
107- public interface ReceiveSignalObject_ChildWorkflow {
107+ public interface ReceiveSignalObjectChildWorkflow {
108108
109109 @ WorkflowMethod
110110 String execute ();
@@ -116,7 +116,7 @@ public interface ReceiveSignalObject_ChildWorkflow {
116116 void close ();
117117 }
118118
119- public static class ReceiveSignalObject_ChildWorkflowImpl implements ReceiveSignalObject_ChildWorkflow {
119+ public static class ReceiveSignalObjectChildWorkflowImpl implements ReceiveSignalObjectChildWorkflow {
120120 private String receivedSignal = "Initial State" ;
121121 // Keep workflow open so that we can send signal
122122 CompletablePromise <Void > promise = Workflow .newPromise ();
@@ -137,17 +137,17 @@ public void close() {
137137 }
138138 }
139139
140- public interface SendSignalObject_Workflow {
140+ public interface SendSignalObjectWorkflow {
141141
142142 @ WorkflowMethod
143143 String execute ();
144144 }
145145
146- public static class SendSignalObject_WorkflowImpl implements SendSignalObject_Workflow {
146+ public static class SendSignalObjectWorkflowImpl implements SendSignalObjectWorkflow {
147147 @ Override
148148 public String execute () {
149- ReceiveSignalObject_ChildWorkflow child =
150- Workflow .newChildWorkflowStub (ReceiveSignalObject_ChildWorkflow .class );
149+ ReceiveSignalObjectChildWorkflow child =
150+ Workflow .newChildWorkflowStub (ReceiveSignalObjectChildWorkflow .class );
151151 Promise <String > greeting = Async .function (child ::execute );
152152 Signal sig = new Signal ();
153153 sig .value = "Hello World" ;
@@ -226,7 +226,7 @@ public void testCorruptedSignalMetrics() throws InterruptedException {
226226 builder .setInterceptorFactory (new CorruptedSignalWorkflowInterceptorFactory ()));
227227
228228 worker .registerWorkflowImplementationTypes (
229- SendSignalObject_WorkflowImpl .class , ReceiveSignalObject_ChildWorkflowImpl .class );
229+ SendSignalObjectWorkflowImpl .class , ReceiveSignalObjectChildWorkflowImpl .class );
230230 worker .start ();
231231
232232 WorkflowOptions options =
@@ -236,7 +236,7 @@ public void testCorruptedSignalMetrics() throws InterruptedException {
236236 .build ();
237237
238238 WorkflowClient workflowClient = testEnvironment .newWorkflowClient ();
239- SendSignalObject_Workflow workflow = workflowClient .newWorkflowStub (SendSignalObject_Workflow .class , options );
239+ SendSignalObjectWorkflow workflow = workflowClient .newWorkflowStub (SendSignalObjectWorkflow .class , options );
240240 workflow .execute ();
241241
242242 //Wait for reporter
0 commit comments