diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceClient.java index 2826e9ed..23d4726d 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -701,12 +700,7 @@ public static ApiFuture createAsync( ListCompaniesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListCompaniesPagedResponse apply(ListCompaniesPage input) { - return new ListCompaniesPagedResponse(input); - } - }, + input -> new ListCompaniesPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceSettings.java index a89c12ef..1b01ca9e 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompanyServiceSettings.java @@ -181,14 +181,13 @@ public CompanyServiceStubSettings.Builder getStubSettingsBuilder() { return ((CompanyServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompletionSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompletionSettings.java index 3c02aaf2..74bfa499 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompletionSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/CompletionSettings.java @@ -154,14 +154,13 @@ public CompletionStubSettings.Builder getStubSettingsBuilder() { return ((CompletionStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/EventServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/EventServiceSettings.java index 608ef5da..6bd2952a 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/EventServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/EventServiceSettings.java @@ -155,14 +155,13 @@ public EventServiceStubSettings.Builder getStubSettingsBuilder() { return ((EventServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceClient.java index 752be867..abe1c0f2 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -1337,14 +1336,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListJobsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListJobsPagedResponse apply(ListJobsPage input) { - return new ListJobsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListJobsPagedResponse(input), MoreExecutors.directExecutor()); } private ListJobsPagedResponse(ListJobsPage page) { diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceSettings.java index bff69826..fb191227 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/JobServiceSettings.java @@ -227,14 +227,13 @@ public JobServiceStubSettings.Builder getStubSettingsBuilder() { return ((JobServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceClient.java index 24e65750..ff1455ba 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -692,14 +691,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListTenantsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListTenantsPagedResponse apply(ListTenantsPage input) { - return new ListTenantsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListTenantsPagedResponse(input), MoreExecutors.directExecutor()); } private ListTenantsPagedResponse(ListTenantsPage page) { diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceSettings.java index 1a941bd9..92ef4656 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/TenantServiceSettings.java @@ -180,14 +180,13 @@ public TenantServiceStubSettings.Builder getStubSettingsBuilder() { return ((TenantServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompanyServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompanyServiceStubSettings.java index cde6b6e4..58db25ac 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompanyServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompanyServiceStubSettings.java @@ -402,14 +402,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompletionStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompletionStubSettings.java index c76477d6..faaaf5e2 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompletionStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/CompletionStubSettings.java @@ -250,14 +250,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/EventServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/EventServiceStubSettings.java index 67d8832e..5c497dac 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/EventServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/EventServiceStubSettings.java @@ -244,14 +244,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompanyServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompanyServiceStub.java index bbe56c6a..35711e04 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompanyServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompanyServiceStub.java @@ -23,7 +23,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4.Company; import com.google.cloud.talent.v4.CreateCompanyRequest; @@ -38,7 +37,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -153,65 +151,50 @@ protected GrpcCompanyServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getCompanyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateCompanyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("company.name", String.valueOf(request.getCompany().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("company.name", String.valueOf(request.getCompany().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteCompanyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings listCompaniesTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listCompaniesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListCompaniesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -275,7 +258,13 @@ public UnaryCallable listCompaniesC @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompletionStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompletionStub.java index 34a3ac89..336e6b33 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompletionStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcCompletionStub.java @@ -21,7 +21,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4.CompleteQueryRequest; import com.google.cloud.talent.v4.CompleteQueryResponse; @@ -30,7 +29,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -101,13 +99,10 @@ protected GrpcCompletionStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(completeQueryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CompleteQueryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("tenant", String.valueOf(request.getTenant())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("tenant", String.valueOf(request.getTenant())); + return params.build(); }) .build(); @@ -130,7 +125,13 @@ public UnaryCallable completeQueryC @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcEventServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcEventServiceStub.java index 2f873751..9adf46b3 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcEventServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcEventServiceStub.java @@ -21,7 +21,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4.ClientEvent; import com.google.cloud.talent.v4.CreateClientEventRequest; @@ -30,7 +29,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -100,13 +98,10 @@ protected GrpcEventServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createClientEventMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateClientEventRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -131,7 +126,13 @@ public UnaryCallable createClientEventCal @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcJobServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcJobServiceStub.java index 7b6af386..a4d7908d 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcJobServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcJobServiceStub.java @@ -24,7 +24,6 @@ import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.OperationCallable; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4.BatchCreateJobsRequest; import com.google.cloud.talent.v4.BatchCreateJobsResponse; @@ -49,7 +48,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -217,130 +215,100 @@ protected GrpcJobServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings batchCreateJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(batchCreateJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(BatchCreateJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getJobTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateJobTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("job.name", String.valueOf(request.getJob().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("job.name", String.valueOf(request.getJob().getName())); + return params.build(); }) .build(); GrpcCallSettings batchUpdateJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(batchUpdateJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(BatchUpdateJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deleteJobTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings batchDeleteJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(batchDeleteJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(BatchDeleteJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings listJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings searchJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(searchJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SearchJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings searchJobsForAlertTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(searchJobsForAlertMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SearchJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -481,7 +449,13 @@ public UnaryCallable searchJobsForAlertCa @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcTenantServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcTenantServiceStub.java index fd8e8420..2152e622 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcTenantServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/GrpcTenantServiceStub.java @@ -23,7 +23,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4.CreateTenantRequest; import com.google.cloud.talent.v4.DeleteTenantRequest; @@ -38,7 +37,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -146,65 +144,50 @@ protected GrpcTenantServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getTenantTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateTenantTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("tenant.name", String.valueOf(request.getTenant().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("tenant.name", String.valueOf(request.getTenant().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTenantTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings listTenantsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listTenantsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTenantsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -267,7 +250,13 @@ public UnaryCallable listTenantsPa @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/JobServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/JobServiceStubSettings.java index 37b18339..d4c3767f 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/JobServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/JobServiceStubSettings.java @@ -623,14 +623,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/TenantServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/TenantServiceStubSettings.java index 2d87d58b..77f352f1 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/TenantServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4/stub/TenantServiceStubSettings.java @@ -401,14 +401,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceClient.java index 5fcaddb3..e58d0ef4 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -721,12 +720,7 @@ public static ApiFuture createAsync( ListApplicationsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListApplicationsPagedResponse apply(ListApplicationsPage input) { - return new ListApplicationsPagedResponse(input); - } - }, + input -> new ListApplicationsPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceSettings.java index d6c0fcf9..767e4522 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ApplicationServiceSettings.java @@ -184,14 +184,13 @@ public ApplicationServiceStubSettings.Builder getStubSettingsBuilder() { return ((ApplicationServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceClient.java index d5f4f250..3cba04c9 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -791,12 +790,7 @@ public static ApiFuture createAsync( ListCompaniesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListCompaniesPagedResponse apply(ListCompaniesPage input) { - return new ListCompaniesPagedResponse(input); - } - }, + input -> new ListCompaniesPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceSettings.java index 468f8edd..eb90ec34 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceSettings.java @@ -182,14 +182,13 @@ public CompanyServiceStubSettings.Builder getStubSettingsBuilder() { return ((CompanyServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompletionSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompletionSettings.java index 30858e5c..f459f18e 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompletionSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/CompletionSettings.java @@ -155,14 +155,13 @@ public CompletionStubSettings.Builder getStubSettingsBuilder() { return ((CompletionStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/EventServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/EventServiceSettings.java index 80d37d81..f62e2116 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/EventServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/EventServiceSettings.java @@ -156,14 +156,13 @@ public EventServiceStubSettings.Builder getStubSettingsBuilder() { return ((EventServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceClient.java index a78af51f..4c9feaa5 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -1633,14 +1632,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListJobsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListJobsPagedResponse apply(ListJobsPage input) { - return new ListJobsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListJobsPagedResponse(input), MoreExecutors.directExecutor()); } private ListJobsPagedResponse(ListJobsPage page) { @@ -1707,14 +1699,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = SearchJobsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public SearchJobsPagedResponse apply(SearchJobsPage input) { - return new SearchJobsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new SearchJobsPagedResponse(input), MoreExecutors.directExecutor()); } private SearchJobsPagedResponse(SearchJobsPage page) { @@ -1789,12 +1774,7 @@ public static ApiFuture createAsync( SearchJobsForAlertPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public SearchJobsForAlertPagedResponse apply(SearchJobsForAlertPage input) { - return new SearchJobsForAlertPagedResponse(input); - } - }, + input -> new SearchJobsForAlertPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceSettings.java index 7d452dae..aaeb1f92 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/JobServiceSettings.java @@ -223,14 +223,13 @@ public JobServiceStubSettings.Builder getStubSettingsBuilder() { return ((JobServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceClient.java index 6ab63656..ea7290b8 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -837,12 +836,7 @@ public static ApiFuture createAsync( ListProfilesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListProfilesPagedResponse apply(ListProfilesPage input) { - return new ListProfilesPagedResponse(input); - } - }, + input -> new ListProfilesPagedResponse(input), MoreExecutors.directExecutor()); } @@ -917,12 +911,7 @@ public static ApiFuture createAsync( SearchProfilesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public SearchProfilesPagedResponse apply(SearchProfilesPage input) { - return new SearchProfilesPagedResponse(input); - } - }, + input -> new SearchProfilesPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceSettings.java index 75275cb9..663dfcf7 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/ProfileServiceSettings.java @@ -190,14 +190,13 @@ public ProfileServiceStubSettings.Builder getStubSettingsBuilder() { return ((ProfileServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceClient.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceClient.java index 0f4f9eab..098f2a17 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceClient.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceClient.java @@ -16,7 +16,6 @@ package com.google.cloud.talent.v4beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -684,14 +683,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListTenantsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListTenantsPagedResponse apply(ListTenantsPage input) { - return new ListTenantsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListTenantsPagedResponse(input), MoreExecutors.directExecutor()); } private ListTenantsPagedResponse(ListTenantsPage page) { diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceSettings.java index c36e0151..84d4b752 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/TenantServiceSettings.java @@ -181,14 +181,13 @@ public TenantServiceStubSettings.Builder getStubSettingsBuilder() { return ((TenantServiceStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ApplicationServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ApplicationServiceStubSettings.java index ca1de53e..f78211c1 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ApplicationServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ApplicationServiceStubSettings.java @@ -416,14 +416,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompanyServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompanyServiceStubSettings.java index f126646b..eaadec78 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompanyServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompanyServiceStubSettings.java @@ -403,14 +403,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompletionStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompletionStubSettings.java index 7e69b5dd..b828a828 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompletionStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/CompletionStubSettings.java @@ -251,14 +251,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/EventServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/EventServiceStubSettings.java index 0c0e59aa..5916a6a5 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/EventServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/EventServiceStubSettings.java @@ -245,14 +245,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcApplicationServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcApplicationServiceStub.java index d3a916b6..d16632f8 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcApplicationServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcApplicationServiceStub.java @@ -24,7 +24,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.Application; import com.google.cloud.talent.v4beta1.CreateApplicationRequest; @@ -39,7 +38,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -160,53 +158,41 @@ protected GrpcApplicationServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createApplicationMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateApplicationRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getApplicationTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getApplicationMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetApplicationRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateApplicationTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateApplicationMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateApplicationRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put( - "application.name", String.valueOf(request.getApplication().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put( + "application.name", String.valueOf(request.getApplication().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteApplicationTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteApplicationMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteApplicationRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -214,13 +200,10 @@ public Map extract(DeleteApplicationRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listApplicationsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListApplicationsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -291,7 +274,13 @@ public UnaryCallable deleteApplicationCallable( @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompanyServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompanyServiceStub.java index a2e9e74c..8c4317a6 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompanyServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompanyServiceStub.java @@ -24,7 +24,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.Company; import com.google.cloud.talent.v4beta1.CreateCompanyRequest; @@ -39,7 +38,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -155,65 +153,50 @@ protected GrpcCompanyServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getCompanyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateCompanyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("company.name", String.valueOf(request.getCompany().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("company.name", String.valueOf(request.getCompany().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteCompanyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteCompanyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteCompanyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings listCompaniesTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listCompaniesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListCompaniesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -277,7 +260,13 @@ public UnaryCallable listCompaniesC @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompletionStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompletionStub.java index d7ecdf1c..7c717a22 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompletionStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcCompletionStub.java @@ -22,7 +22,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.CompleteQueryRequest; import com.google.cloud.talent.v4beta1.CompleteQueryResponse; @@ -31,7 +30,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -103,13 +101,10 @@ protected GrpcCompletionStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(completeQueryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CompleteQueryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -132,7 +127,13 @@ public UnaryCallable completeQueryC @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcEventServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcEventServiceStub.java index ed90f3b3..d702436d 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcEventServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcEventServiceStub.java @@ -22,7 +22,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.ClientEvent; import com.google.cloud.talent.v4beta1.CreateClientEventRequest; @@ -31,7 +30,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -102,13 +100,10 @@ protected GrpcEventServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createClientEventMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateClientEventRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -133,7 +128,13 @@ public UnaryCallable createClientEventCal @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcJobServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcJobServiceStub.java index 8537cee7..282d2640 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcJobServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcJobServiceStub.java @@ -27,7 +27,6 @@ import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.OperationCallable; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.BatchCreateJobsRequest; import com.google.cloud.talent.v4beta1.BatchDeleteJobsRequest; @@ -50,7 +49,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -219,130 +217,100 @@ protected GrpcJobServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings batchCreateJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(batchCreateJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(BatchCreateJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getJobTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateJobTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("job.name", String.valueOf(request.getJob().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("job.name", String.valueOf(request.getJob().getName())); + return params.build(); }) .build(); GrpcCallSettings batchUpdateJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(batchUpdateJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(BatchUpdateJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deleteJobTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteJobMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteJobRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings batchDeleteJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(batchDeleteJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(BatchDeleteJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings listJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings searchJobsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(searchJobsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SearchJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings searchJobsForAlertTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(searchJobsForAlertMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SearchJobsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -490,7 +458,13 @@ public UnaryCallable searchJobsForAlertCa @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcProfileServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcProfileServiceStub.java index 99dfd8e8..98c49de6 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcProfileServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcProfileServiceStub.java @@ -25,7 +25,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.CreateProfileRequest; import com.google.cloud.talent.v4beta1.DeleteProfileRequest; @@ -42,7 +41,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -171,65 +169,50 @@ protected GrpcProfileServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(listProfilesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListProfilesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings createProfileTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createProfileMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateProfileRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getProfileTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getProfileMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetProfileRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateProfileTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateProfileMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateProfileRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("profile.name", String.valueOf(request.getProfile().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("profile.name", String.valueOf(request.getProfile().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteProfileTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteProfileMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteProfileRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -237,13 +220,10 @@ public Map extract(DeleteProfileRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(searchProfilesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SearchProfilesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -323,7 +303,13 @@ public UnaryCallable searchProfil @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcTenantServiceStub.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcTenantServiceStub.java index d195a3e3..7c4aacb3 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcTenantServiceStub.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/GrpcTenantServiceStub.java @@ -24,7 +24,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.talent.v4beta1.CreateTenantRequest; import com.google.cloud.talent.v4beta1.DeleteTenantRequest; @@ -39,7 +38,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -148,65 +146,50 @@ protected GrpcTenantServiceStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getTenantTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateTenantTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("tenant.name", String.valueOf(request.getTenant().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("tenant.name", String.valueOf(request.getTenant().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTenantTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTenantMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTenantRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings listTenantsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listTenantsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTenantsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -269,7 +252,13 @@ public UnaryCallable listTenantsPa @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/JobServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/JobServiceStubSettings.java index 79292d50..e80ad705 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/JobServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/JobServiceStubSettings.java @@ -704,14 +704,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ProfileServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ProfileServiceStubSettings.java index a2be19c1..f6c61315 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ProfileServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/ProfileServiceStubSettings.java @@ -487,14 +487,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/TenantServiceStubSettings.java b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/TenantServiceStubSettings.java index b32871fc..20a0b08e 100644 --- a/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/TenantServiceStubSettings.java +++ b/google-cloud-talent/src/main/java/com/google/cloud/talent/v4beta1/stub/TenantServiceStubSettings.java @@ -402,14 +402,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/synth.metadata b/synth.metadata index a0f18722..d711a09d 100644 --- a/synth.metadata +++ b/synth.metadata @@ -4,23 +4,23 @@ "git": { "name": ".", "remote": "https://github.com/googleapis/java-talent.git", - "sha": "331d13a4af070fc0a3f3f9219c214b0485ed6a51" + "sha": "7931edb4617690db6a226501c0e89b0047cb5909" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "551681f25e36b11829e87e580281350461f4f3f5", - "internalRef": "379784268" + "sha": "d9eaf41de44d953458b18712a3f240bb4c564e48", + "internalRef": "388535346" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "551681f25e36b11829e87e580281350461f4f3f5", - "internalRef": "379784268" + "sha": "d9eaf41de44d953458b18712a3f240bb4c564e48", + "internalRef": "388535346" } }, {