|
48 | 48 | import com.uber.cadence.common.RetryOptions;
|
49 | 49 | import com.uber.cadence.converter.JsonDataConverter;
|
50 | 50 | import com.uber.cadence.internal.sync.DeterministicRunnerTest;
|
| 51 | +import com.uber.cadence.serviceclient.WorkflowServiceTChannel; |
51 | 52 | import com.uber.cadence.testing.TestEnvironmentOptions;
|
52 | 53 | import com.uber.cadence.testing.TestEnvironmentOptions.Builder;
|
53 | 54 | import com.uber.cadence.testing.TestWorkflowEnvironment;
|
@@ -142,6 +143,7 @@ protected void failed(Throwable e, Description description) {
|
142 | 143 | private TestWorkflowEnvironment testEnvironment;
|
143 | 144 | private ScheduledExecutorService scheduledExecutor;
|
144 | 145 | private List<ScheduledFuture<?>> delayedCallbacks = new ArrayList<>();
|
| 146 | + private static WorkflowServiceTChannel service = new WorkflowServiceTChannel(); |
145 | 147 |
|
146 | 148 | private static WorkflowOptions.Builder newWorkflowOptionsBuilder(String taskList) {
|
147 | 149 | return new WorkflowOptions.Builder()
|
@@ -175,7 +177,7 @@ public void setUp() {
|
175 | 177 | if (useExternalService) {
|
176 | 178 | WorkerOptions workerOptions =
|
177 | 179 | new WorkerOptions.Builder().setInterceptorFactory(tracer).build();
|
178 |
| - worker = new Worker(DOMAIN, taskList, workerOptions); |
| 180 | + worker = new Worker(service, DOMAIN, taskList, workerOptions); |
179 | 181 | workflowClient = WorkflowClient.newInstance(DOMAIN);
|
180 | 182 | WorkflowClientOptions clientOptions =
|
181 | 183 | new WorkflowClientOptions.Builder()
|
|
0 commit comments