Skip to content

Commit 7e9deee

Browse files
committed
fix: Use newWorkflowClient from QuerySampleSupport
Signed-off-by: “Kevin” <kevlar_ksb@yahoo.com>
1 parent 7e9c8c9 commit 7e9deee

1 file changed

Lines changed: 1 addition & 7 deletions

File tree

src/main/java/com/uber/cadence/samples/query/QueryWorker.java

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,6 @@
2020
import static com.uber.cadence.samples.query.QueryConstants.TASK_LIST;
2121

2222
import com.uber.cadence.client.WorkflowClient;
23-
import com.uber.cadence.client.WorkflowClientOptions;
24-
import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
25-
import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
2623
import com.uber.cadence.worker.Worker;
2724
import com.uber.cadence.worker.WorkerFactory;
2825
import com.uber.cadence.samples.common.SampleConstants;
@@ -37,10 +34,7 @@ public final class QueryWorker {
3734
private QueryWorker() {}
3835

3936
public static void main(String[] args) {
40-
WorkflowClient workflowClient =
41-
WorkflowClient.newInstance(
42-
new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance()),
43-
WorkflowClientOptions.newBuilder().setDomain(SampleConstants.DOMAIN).build());
37+
WorkflowClient workflowClient = QuerySampleSupport.newWorkflowClient();
4438

4539
WorkerFactory factory = WorkerFactory.newInstance(workflowClient);
4640
Worker worker = factory.newWorker(TASK_LIST);

0 commit comments

Comments
 (0)