30
30
import com .uber .cadence .serviceclient .ClientOptions ;
31
31
import com .uber .cadence .serviceclient .IWorkflowService ;
32
32
import com .uber .cadence .serviceclient .WorkflowServiceTChannel ;
33
+ import com .uber .cadence .testUtils .TestEnvironment ;
33
34
import com .uber .cadence .worker .Worker ;
34
35
import com .uber .cadence .worker .WorkerFactory ;
35
36
import com .uber .cadence .worker .WorkerFactoryOptions ;
@@ -138,8 +139,7 @@ public Integer Double(Integer n) {
138
139
}
139
140
}
140
141
141
- private static final boolean useDockerService =
142
- Boolean .parseBoolean (System .getenv ("USE_DOCKER_SERVICE" ));
142
+ private static final boolean useDockerService = true || TestEnvironment .isUseDockerService ();
143
143
private static final Logger logger = LoggerFactory .getLogger (StartWorkflowTest .class );
144
144
private static final String DOMAIN = "test-domain" ;
145
145
private static final String TASK_LIST = "test-tasklist" ;
@@ -160,7 +160,11 @@ public void testStartWorkflowGRPC() {
160
160
IWorkflowService service =
161
161
new Thrift2ProtoAdapter (
162
162
IGrpcServiceStubs .newInstance (
163
- ClientOptions .newBuilder ().setTracer (mockTracer ).setPort (7833 ).build ()));
163
+ ClientOptions .newBuilder ()
164
+ .setTracer (mockTracer )
165
+ .setHost ("localhost" )
166
+ .setPort (7833 )
167
+ .build ()));
164
168
testStartWorkflowHelper (service , mockTracer , true );
165
169
}
166
170
@@ -171,7 +175,11 @@ public void testStartMultipleWorkflowGRPC() {
171
175
IWorkflowService service =
172
176
new Thrift2ProtoAdapter (
173
177
IGrpcServiceStubs .newInstance (
174
- ClientOptions .newBuilder ().setTracer (mockTracer ).setPort (7833 ).build ()));
178
+ ClientOptions .newBuilder ()
179
+ .setTracer (mockTracer )
180
+ .setHost ("localhost" )
181
+ .setPort (7833 )
182
+ .build ()));
175
183
try {
176
184
service .RegisterDomain (new RegisterDomainRequest ().setName (DOMAIN ));
177
185
} catch (DomainAlreadyExistsError e ) {
@@ -259,7 +267,11 @@ public void testSignalWithStartWorkflowGRPC() {
259
267
IWorkflowService service =
260
268
new Thrift2ProtoAdapter (
261
269
IGrpcServiceStubs .newInstance (
262
- ClientOptions .newBuilder ().setTracer (mockTracer ).setPort (7833 ).build ()));
270
+ ClientOptions .newBuilder ()
271
+ .setTracer (mockTracer )
272
+ .setHost ("localhost" )
273
+ .setPort (7833 )
274
+ .build ()));
263
275
testSignalWithStartWorkflowHelper (service , mockTracer , true );
264
276
}
265
277
@@ -277,7 +289,8 @@ public void testStartWorkflowGRPCNoPropagation() {
277
289
MockTracer mockTracer = new MockTracer ();
278
290
IWorkflowService service =
279
291
new Thrift2ProtoAdapter (
280
- IGrpcServiceStubs .newInstance (ClientOptions .newBuilder ().setPort (7833 ).build ()));
292
+ IGrpcServiceStubs .newInstance (
293
+ ClientOptions .newBuilder ().setHost ("localhost" ).setPort (7833 ).build ()));
281
294
testStartWorkflowHelper (service , mockTracer , false );
282
295
}
283
296
@@ -295,7 +308,8 @@ public void testSignalStartWorkflowGRPCNoPropagation() {
295
308
MockTracer mockTracer = new MockTracer ();
296
309
IWorkflowService service =
297
310
new Thrift2ProtoAdapter (
298
- IGrpcServiceStubs .newInstance (ClientOptions .newBuilder ().setPort (7833 ).build ()));
311
+ IGrpcServiceStubs .newInstance (
312
+ ClientOptions .newBuilder ().setHost ("localhost" ).setPort (7833 ).build ()));
299
313
testSignalWithStartWorkflowHelper (service , mockTracer , false );
300
314
}
301
315
0 commit comments