Skip to content

Commit 043f709

Browse files
demirkayaenderdemirkayaender
committed
Fix build issues related to GetTaskListsByDomain
1 parent 37473fb commit 043f709

File tree

5 files changed

+108
-1
lines changed

5 files changed

+108
-1
lines changed

‎src/main/java/com/uber/cadence/internal/metrics/ServiceMethod.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@
2020
public class ServiceMethod {
2121
public static final String DEPRECATE_DOMAIN =
2222
MetricsType.CADENCE_METRICS_PREFIX + "DeprecateDomain";
23+
public static final String GET_TASK_LISTS_BY_DOMAIN =
24+
MetricsType.CADENCE_METRICS_PREFIX + "GetTaskListsByDomain";
2325
public static final String DESCRIBE_DOMAIN =
2426
MetricsType.CADENCE_METRICS_PREFIX + "DescribeDomain";
2527
public static final String LIST_DOMAINS = MetricsType.CADENCE_METRICS_PREFIX + "ListDomains";

‎src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java

+18-1
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919

2020
import com.google.common.base.Defaults;
2121
import com.uber.cadence.*;
22+
import com.uber.cadence.GetTaskListsByDomainRequest;
23+
import com.uber.cadence.GetTaskListsByDomainResponse;
2224
import com.uber.cadence.activity.ActivityOptions;
2325
import com.uber.cadence.activity.LocalActivityOptions;
2426
import com.uber.cadence.internal.metrics.NoopScope;
@@ -585,6 +587,13 @@ public void DeprecateDomain(
585587
impl.DeprecateDomain(deprecateRequest, resultHandler);
586588
}
587589

590+
@Override
591+
public void GetTaskListsByDomain(
592+
GetTaskListsByDomainRequest request, AsyncMethodCallback resultHandler)
593+
throws org.apache.thrift.TException {
594+
impl.GetTaskListsByDomain(request, resultHandler);
595+
}
596+
588597
@Override
589598
public void StartWorkflowExecution(
590599
StartWorkflowExecutionRequest startRequest, AsyncMethodCallback resultHandler)
@@ -861,10 +870,18 @@ public UpdateDomainResponse UpdateDomain(UpdateDomainRequest updateRequest)
861870

862871
@Override
863872
public void DeprecateDomain(DeprecateDomainRequest deprecateRequest)
864-
throws BadRequestError, InternalServiceError, EntityNotExistsError, TException {
873+
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
874+
ClientVersionNotSupportedError, TException {
865875
impl.DeprecateDomain(deprecateRequest);
866876
}
867877

878+
@Override
879+
public GetTaskListsByDomainResponse GetTaskListsByDomain(GetTaskListsByDomainRequest request)
880+
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
881+
ClientVersionNotSupportedError, TException {
882+
return impl.GetTaskListsByDomain(request);
883+
}
884+
868885
@Override
869886
public StartWorkflowExecutionResponse StartWorkflowExecution(
870887
StartWorkflowExecutionRequest startRequest)

‎src/main/java/com/uber/cadence/internal/sync/TestWorkflowEnvironmentInternal.java

+18
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
package com.uber.cadence.internal.sync;
1919

2020
import com.uber.cadence.BadRequestError;
21+
import com.uber.cadence.ClientVersionNotSupportedError;
2122
import com.uber.cadence.ClusterInfo;
2223
import com.uber.cadence.CountWorkflowExecutionsRequest;
2324
import com.uber.cadence.CountWorkflowExecutionsResponse;
@@ -31,9 +32,12 @@
3132
import com.uber.cadence.DomainAlreadyExistsError;
3233
import com.uber.cadence.EntityNotExistsError;
3334
import com.uber.cadence.GetSearchAttributesResponse;
35+
import com.uber.cadence.GetTaskListsByDomainRequest;
36+
import com.uber.cadence.GetTaskListsByDomainResponse;
3437
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
3538
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
3639
import com.uber.cadence.InternalServiceError;
40+
import com.uber.cadence.LimitExceededError;
3741
import com.uber.cadence.ListArchivedWorkflowExecutionsRequest;
3842
import com.uber.cadence.ListArchivedWorkflowExecutionsResponse;
3943
import com.uber.cadence.ListClosedWorkflowExecutionsRequest;
@@ -452,6 +456,13 @@ public void DeprecateDomain(
452456
impl.DeprecateDomain(deprecateRequest, resultHandler);
453457
}
454458

459+
@Override
460+
public void GetTaskListsByDomain(
461+
GetTaskListsByDomainRequest request, AsyncMethodCallback resultHandler)
462+
throws org.apache.thrift.TException {
463+
impl.GetTaskListsByDomain(request, resultHandler);
464+
}
465+
455466
@Override
456467
public void StartWorkflowExecution(
457468
StartWorkflowExecutionRequest startRequest, AsyncMethodCallback resultHandler)
@@ -737,6 +748,13 @@ public void DeprecateDomain(DeprecateDomainRequest deprecateRequest)
737748
impl.DeprecateDomain(deprecateRequest);
738749
}
739750

751+
@Override
752+
public GetTaskListsByDomainResponse GetTaskListsByDomain(GetTaskListsByDomainRequest request)
753+
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
754+
ClientVersionNotSupportedError, TException {
755+
return impl.GetTaskListsByDomain(request);
756+
}
757+
740758
@Override
741759
public StartWorkflowExecutionResponse StartWorkflowExecution(
742760
StartWorkflowExecutionRequest startRequest)

‎src/main/java/com/uber/cadence/internal/testservice/TestWorkflowService.java

+16
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,8 @@
3333
import com.uber.cadence.DomainNotActiveError;
3434
import com.uber.cadence.EntityNotExistsError;
3535
import com.uber.cadence.GetSearchAttributesResponse;
36+
import com.uber.cadence.GetTaskListsByDomainRequest;
37+
import com.uber.cadence.GetTaskListsByDomainResponse;
3638
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
3739
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
3840
import com.uber.cadence.InternalServiceError;
@@ -210,6 +212,13 @@ public void DeprecateDomain(DeprecateDomainRequest deprecateRequest)
210212
throw new UnsupportedOperationException("not implemented");
211213
}
212214

215+
@Override
216+
public GetTaskListsByDomainResponse GetTaskListsByDomain(GetTaskListsByDomainRequest request)
217+
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
218+
ClientVersionNotSupportedError, TException {
219+
throw new UnsupportedOperationException("not implemented");
220+
}
221+
213222
@Override
214223
public StartWorkflowExecutionResponse StartWorkflowExecution(
215224
StartWorkflowExecutionRequest startRequest) throws TException {
@@ -795,6 +804,13 @@ public void DeprecateDomain(
795804
throw new UnsupportedOperationException("not implemented");
796805
}
797806

807+
@Override
808+
public void GetTaskListsByDomain(
809+
GetTaskListsByDomainRequest request, AsyncMethodCallback resultHandler)
810+
throws org.apache.thrift.TException {
811+
throw new UnsupportedOperationException("not implemented");
812+
}
813+
798814
@Override
799815
public void StartWorkflowExecution(
800816
StartWorkflowExecutionRequest startRequest, AsyncMethodCallback resultHandler)

‎src/main/java/com/uber/cadence/serviceclient/WorkflowServiceTChannel.java

+54
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,8 @@
3636
import com.uber.cadence.DomainNotActiveError;
3737
import com.uber.cadence.EntityNotExistsError;
3838
import com.uber.cadence.GetSearchAttributesResponse;
39+
import com.uber.cadence.GetTaskListsByDomainRequest;
40+
import com.uber.cadence.GetTaskListsByDomainResponse;
3941
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
4042
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
4143
import com.uber.cadence.History;
@@ -559,6 +561,51 @@ private void deprecateDomain(DeprecateDomainRequest deprecateRequest) throws TEx
559561
}
560562
}
561563

564+
@Override
565+
public GetTaskListsByDomainResponse GetTaskListsByDomain(
566+
GetTaskListsByDomainRequest getTaskListsByDomainRequest) throws TException {
567+
return measureRemoteCall(
568+
ServiceMethod.GET_TASK_LISTS_BY_DOMAIN,
569+
() -> getTaskListsByDomain(getTaskListsByDomainRequest));
570+
}
571+
572+
private GetTaskListsByDomainResponse getTaskListsByDomain(
573+
GetTaskListsByDomainRequest getTaskListsByDomainRequest) throws TException {
574+
ThriftResponse<WorkflowService.GetTaskListsByDomain_result> response = null;
575+
try {
576+
ThriftRequest<WorkflowService.GetTaskListsByDomain_args> request =
577+
buildThriftRequest(
578+
"GetTaskListsByDomain",
579+
new WorkflowService.GetTaskListsByDomain_args(getTaskListsByDomainRequest));
580+
response = doRemoteCall(request);
581+
WorkflowService.GetTaskListsByDomain_result result =
582+
response.getBody(WorkflowService.GetTaskListsByDomain_result.class);
583+
if (response.getResponseCode() == ResponseCode.OK) {
584+
return result.getSuccess();
585+
}
586+
if (result.isSetBadRequestError()) {
587+
throw result.getBadRequestError();
588+
}
589+
if (result.isSetEntityNotExistError()) {
590+
throw result.getEntityNotExistError();
591+
}
592+
if (result.isSetLimitExceededError()) {
593+
throw result.getLimitExceededError();
594+
}
595+
if (result.isSetServiceBusyError()) {
596+
throw result.getServiceBusyError();
597+
}
598+
if (result.isSetClientVersionNotSupportedError()) {
599+
throw result.getClientVersionNotSupportedError();
600+
}
601+
throw new TException("GetTaskListsByDomain failed with unknown error:" + result);
602+
} finally {
603+
if (response != null) {
604+
response.release();
605+
}
606+
}
607+
}
608+
562609
@Override
563610
public StartWorkflowExecutionResponse StartWorkflowExecution(
564611
StartWorkflowExecutionRequest request) throws TException {
@@ -2602,4 +2649,11 @@ public void DeprecateDomain(
26022649
throws TException {
26032650
throw new UnsupportedOperationException("not implemented");
26042651
}
2652+
2653+
@Override
2654+
public void GetTaskListsByDomain(
2655+
GetTaskListsByDomainRequest request, AsyncMethodCallback resultHandler)
2656+
throws org.apache.thrift.TException {
2657+
throw new UnsupportedOperationException("not implemented");
2658+
}
26052659
}

0 commit comments

Comments
 (0)