diff --git a/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerClient.java b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerClient.java index 7b1296e..1d0a5f4 100644 --- a/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerClient.java +++ b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerClient.java @@ -17,7 +17,6 @@ package com.google.cloud.api.servicemanagement.v1; import com.google.api.Service; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -1953,12 +1952,7 @@ public static ApiFuture createAsync( ListServicesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListServicesPagedResponse apply(ListServicesPage input) { - return new ListServicesPagedResponse(input); - } - }, + input -> new ListServicesPagedResponse(input), MoreExecutors.directExecutor()); } @@ -2034,12 +2028,7 @@ public static ApiFuture createAsync( ListServiceConfigsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListServiceConfigsPagedResponse apply(ListServiceConfigsPage input) { - return new ListServiceConfigsPagedResponse(input); - } - }, + input -> new ListServiceConfigsPagedResponse(input), MoreExecutors.directExecutor()); } @@ -2116,12 +2105,7 @@ public static ApiFuture createAsync( ListServiceRolloutsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListServiceRolloutsPagedResponse apply(ListServiceRolloutsPage input) { - return new ListServiceRolloutsPagedResponse(input); - } - }, + input -> new ListServiceRolloutsPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerSettings.java b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerSettings.java index 493b8fb..cdc96f1 100644 --- a/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerSettings.java +++ b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/ServiceManagerSettings.java @@ -331,14 +331,13 @@ public ServiceManagerStubSettings.Builder getStubSettingsBuilder() { return ((ServiceManagerStubSettings.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-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/GrpcServiceManagerStub.java b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/GrpcServiceManagerStub.java index 28aca01..7763fb1 100644 --- a/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/GrpcServiceManagerStub.java +++ b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/GrpcServiceManagerStub.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.api.servicemanagement.v1.CreateServiceConfigRequest; import com.google.api.servicemanagement.v1.CreateServiceRequest; @@ -62,7 +61,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; @@ -325,13 +323,10 @@ protected GrpcServiceManagerStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(getServiceMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetServiceRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings createServiceTransportSettings = @@ -342,26 +337,20 @@ public Map extract(GetServiceRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteServiceMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteServiceRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings undeleteServiceTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(undeleteServiceMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UndeleteServiceRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings @@ -369,53 +358,41 @@ public Map extract(UndeleteServiceRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listServiceConfigsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListServiceConfigsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings getServiceConfigTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getServiceConfigMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetServiceConfigRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("config_id", String.valueOf(request.getConfigId())); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("config_id", String.valueOf(request.getConfigId())); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings createServiceConfigTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createServiceConfigMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateServiceConfigRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings submitConfigSourceTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(submitConfigSourceMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SubmitConfigSourceRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings @@ -423,40 +400,31 @@ public Map extract(SubmitConfigSourceRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listServiceRolloutsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListServiceRolloutsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings getServiceRolloutTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getServiceRolloutMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetServiceRolloutRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("rollout_id", String.valueOf(request.getRolloutId())); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("rollout_id", String.valueOf(request.getRolloutId())); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings createServiceRolloutTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createServiceRolloutMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateServiceRolloutRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings @@ -468,26 +436,20 @@ public Map extract(CreateServiceRolloutRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(enableServiceMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(EnableServiceRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); GrpcCallSettings disableServiceTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(disableServiceMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DisableServiceRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("service_name", String.valueOf(request.getServiceName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("service_name", String.valueOf(request.getServiceName())); + return params.build(); }) .build(); @@ -753,7 +715,13 @@ public UnaryCallable disableServiceCallable() @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-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/ServiceManagerStubSettings.java b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/ServiceManagerStubSettings.java index bd70d30..22a116f 100644 --- a/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/ServiceManagerStubSettings.java +++ b/google-cloud-service-management/src/main/java/com/google/cloud/api/servicemanagement/v1/stub/ServiceManagerStubSettings.java @@ -1021,14 +1021,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; }