/* * Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with * the License. A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions * and limitations under the License. */ package com.amazonaws.services.certificatemanager; import static java.util.concurrent.Executors.newFixedThreadPool; import javax.annotation.Generated; import com.amazonaws.services.certificatemanager.model.*; import com.amazonaws.client.AwsAsyncClientParams; import com.amazonaws.annotation.ThreadSafe; import com.amazonaws.ClientConfiguration; import com.amazonaws.auth.AWSCredentials; import com.amazonaws.auth.AWSCredentialsProvider; import java.util.concurrent.ExecutorService; import com.amazonaws.auth.DefaultAWSCredentialsProviderChain; /** * Client for accessing ACM asynchronously. Each asynchronous method will return a Java Future object representing the * asynchronous operation; overloads which accept an {@code AsyncHandler} can be used to receive notification when an * asynchronous operation completes. *

* Certificate Manager *

* You can use Certificate Manager (ACM) to manage SSL/TLS certificates for your Amazon Web Services-based websites and * applications. For more information about using ACM, see the Certificate Manager User Guide. *

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AWSCertificateManagerAsyncClient extends AWSCertificateManagerClient implements AWSCertificateManagerAsync { private static final int DEFAULT_THREAD_POOL_SIZE = 50; private final java.util.concurrent.ExecutorService executorService; /** * Constructs a new asynchronous client to invoke service methods on ACM. A credentials provider chain will be used * that searches for credentials in this order: * *

* Asynchronous methods are delegated to a fixed-size thread pool containing 50 threads (to match the default * maximum number of concurrent connections to the service). * * @see com.amazonaws.auth.DefaultAWSCredentialsProviderChain * @see java.util.concurrent.Executors#newFixedThreadPool(int) * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#defaultClient()} */ @Deprecated public AWSCertificateManagerAsyncClient() { this(DefaultAWSCredentialsProviderChain.getInstance()); } /** * Constructs a new asynchronous client to invoke service methods on ACM. A credentials provider chain will be used * that searches for credentials in this order: *

*

* Asynchronous methods are delegated to a fixed-size thread pool containing a number of threads equal to the * maximum number of concurrent connections configured via {@code ClientConfiguration.getMaxConnections()}. * * @param clientConfiguration * The client configuration options controlling how this client connects to ACM (ex: proxy settings, retry * counts, etc). * * @see com.amazonaws.auth.DefaultAWSCredentialsProviderChain * @see java.util.concurrent.Executors#newFixedThreadPool(int) * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withClientConfiguration(ClientConfiguration)} */ @Deprecated public AWSCertificateManagerAsyncClient(ClientConfiguration clientConfiguration) { this(DefaultAWSCredentialsProviderChain.getInstance(), clientConfiguration, newFixedThreadPool(clientConfiguration.getMaxConnections())); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified AWS account * credentials. *

* Asynchronous methods are delegated to a fixed-size thread pool containing 50 threads (to match the default * maximum number of concurrent connections to the service). * * @param awsCredentials * The AWS credentials (access key ID and secret key) to use when authenticating with AWS services. * @see java.util.concurrent.Executors#newFixedThreadPool(int) * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentials awsCredentials) { this(awsCredentials, newFixedThreadPool(DEFAULT_THREAD_POOL_SIZE)); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified AWS account credentials * and executor service. Default client settings will be used. * * @param awsCredentials * The AWS credentials (access key ID and secret key) to use when authenticating with AWS services. * @param executorService * The executor service by which all asynchronous requests will be executed. * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and * {@link AWSCertificateManagerAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentials awsCredentials, ExecutorService executorService) { this(awsCredentials, configFactory.getConfig(), executorService); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified AWS account * credentials, executor service, and client configuration options. * * @param awsCredentials * The AWS credentials (access key ID and secret key) to use when authenticating with AWS services. * @param clientConfiguration * Client configuration options (ex: max retry limit, proxy settings, etc). * @param executorService * The executor service by which all asynchronous requests will be executed. * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and * {@link AWSCertificateManagerAsyncClientBuilder#withClientConfiguration(ClientConfiguration)} and * {@link AWSCertificateManagerAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentials awsCredentials, ClientConfiguration clientConfiguration, ExecutorService executorService) { super(awsCredentials, clientConfiguration); this.executorService = executorService; } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified AWS account credentials * provider. Default client settings will be used. *

* Asynchronous methods are delegated to a fixed-size thread pool containing 50 threads (to match the default * maximum number of concurrent connections to the service). * * @param awsCredentialsProvider * The AWS credentials provider which will provide credentials to authenticate requests with AWS services. * @see java.util.concurrent.Executors#newFixedThreadPool(int) * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentialsProvider awsCredentialsProvider) { this(awsCredentialsProvider, newFixedThreadPool(DEFAULT_THREAD_POOL_SIZE)); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the provided AWS account credentials * provider and client configuration options. *

* Asynchronous methods are delegated to a fixed-size thread pool containing a number of threads equal to the * maximum number of concurrent connections configured via {@code ClientConfiguration.getMaxConnections()}. * * @param awsCredentialsProvider * The AWS credentials provider which will provide credentials to authenticate requests with AWS services. * @param clientConfiguration * Client configuration options (ex: max retry limit, proxy settings, etc). * * @see com.amazonaws.auth.DefaultAWSCredentialsProviderChain * @see java.util.concurrent.Executors#newFixedThreadPool(int) * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and * {@link AWSCertificateManagerAsyncClientBuilder#withClientConfiguration(ClientConfiguration)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentialsProvider awsCredentialsProvider, ClientConfiguration clientConfiguration) { this(awsCredentialsProvider, clientConfiguration, newFixedThreadPool(clientConfiguration.getMaxConnections())); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified AWS account credentials * provider and executor service. Default client settings will be used. * * @param awsCredentialsProvider * The AWS credentials provider which will provide credentials to authenticate requests with AWS services. * @param executorService * The executor service by which all asynchronous requests will be executed. * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and * {@link AWSCertificateManagerAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentialsProvider awsCredentialsProvider, ExecutorService executorService) { this(awsCredentialsProvider, configFactory.getConfig(), executorService); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified AWS account credentials * provider, executor service, and client configuration options. * * @param awsCredentialsProvider * The AWS credentials provider which will provide credentials to authenticate requests with AWS services. * @param clientConfiguration * Client configuration options (ex: max retry limit, proxy settings, etc). * @param executorService * The executor service by which all asynchronous requests will be executed. * @deprecated use {@link AWSCertificateManagerAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and * {@link AWSCertificateManagerAsyncClientBuilder#withClientConfiguration(ClientConfiguration)} and * {@link AWSCertificateManagerAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)} */ @Deprecated public AWSCertificateManagerAsyncClient(AWSCredentialsProvider awsCredentialsProvider, ClientConfiguration clientConfiguration, ExecutorService executorService) { super(awsCredentialsProvider, clientConfiguration); this.executorService = executorService; } public static AWSCertificateManagerAsyncClientBuilder asyncBuilder() { return AWSCertificateManagerAsyncClientBuilder.standard(); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified parameters. * * @param asyncClientParams * Object providing client parameters. */ AWSCertificateManagerAsyncClient(AwsAsyncClientParams asyncClientParams) { this(asyncClientParams, false); } /** * Constructs a new asynchronous client to invoke service methods on ACM using the specified parameters. * * @param asyncClientParams * Object providing client parameters. * @param endpointDiscoveryEnabled * true will enable endpoint discovery if the service supports it. */ AWSCertificateManagerAsyncClient(AwsAsyncClientParams asyncClientParams, boolean endpointDiscoveryEnabled) { super(asyncClientParams, endpointDiscoveryEnabled); this.executorService = asyncClientParams.getExecutor(); } /** * Returns the executor service used by this client to execute async requests. * * @return The executor service used by this client to execute async requests. */ public ExecutorService getExecutorService() { return executorService; } @Override public java.util.concurrent.Future addTagsToCertificateAsync(AddTagsToCertificateRequest request) { return addTagsToCertificateAsync(request, null); } @Override public java.util.concurrent.Future addTagsToCertificateAsync(final AddTagsToCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final AddTagsToCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public AddTagsToCertificateResult call() throws Exception { AddTagsToCertificateResult result = null; try { result = executeAddTagsToCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future deleteCertificateAsync(DeleteCertificateRequest request) { return deleteCertificateAsync(request, null); } @Override public java.util.concurrent.Future deleteCertificateAsync(final DeleteCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteCertificateResult call() throws Exception { DeleteCertificateResult result = null; try { result = executeDeleteCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeCertificateAsync(DescribeCertificateRequest request) { return describeCertificateAsync(request, null); } @Override public java.util.concurrent.Future describeCertificateAsync(final DescribeCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeCertificateResult call() throws Exception { DescribeCertificateResult result = null; try { result = executeDescribeCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future exportCertificateAsync(ExportCertificateRequest request) { return exportCertificateAsync(request, null); } @Override public java.util.concurrent.Future exportCertificateAsync(final ExportCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ExportCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ExportCertificateResult call() throws Exception { ExportCertificateResult result = null; try { result = executeExportCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future getAccountConfigurationAsync(GetAccountConfigurationRequest request) { return getAccountConfigurationAsync(request, null); } @Override public java.util.concurrent.Future getAccountConfigurationAsync(final GetAccountConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetAccountConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetAccountConfigurationResult call() throws Exception { GetAccountConfigurationResult result = null; try { result = executeGetAccountConfiguration(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future getCertificateAsync(GetCertificateRequest request) { return getCertificateAsync(request, null); } @Override public java.util.concurrent.Future getCertificateAsync(final GetCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetCertificateResult call() throws Exception { GetCertificateResult result = null; try { result = executeGetCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future importCertificateAsync(ImportCertificateRequest request) { return importCertificateAsync(request, null); } @Override public java.util.concurrent.Future importCertificateAsync(final ImportCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ImportCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ImportCertificateResult call() throws Exception { ImportCertificateResult result = null; try { result = executeImportCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listCertificatesAsync(ListCertificatesRequest request) { return listCertificatesAsync(request, null); } @Override public java.util.concurrent.Future listCertificatesAsync(final ListCertificatesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListCertificatesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListCertificatesResult call() throws Exception { ListCertificatesResult result = null; try { result = executeListCertificates(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listTagsForCertificateAsync(ListTagsForCertificateRequest request) { return listTagsForCertificateAsync(request, null); } @Override public java.util.concurrent.Future listTagsForCertificateAsync(final ListTagsForCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListTagsForCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListTagsForCertificateResult call() throws Exception { ListTagsForCertificateResult result = null; try { result = executeListTagsForCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future putAccountConfigurationAsync(PutAccountConfigurationRequest request) { return putAccountConfigurationAsync(request, null); } @Override public java.util.concurrent.Future putAccountConfigurationAsync(final PutAccountConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final PutAccountConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public PutAccountConfigurationResult call() throws Exception { PutAccountConfigurationResult result = null; try { result = executePutAccountConfiguration(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future removeTagsFromCertificateAsync(RemoveTagsFromCertificateRequest request) { return removeTagsFromCertificateAsync(request, null); } @Override public java.util.concurrent.Future removeTagsFromCertificateAsync(final RemoveTagsFromCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final RemoveTagsFromCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public RemoveTagsFromCertificateResult call() throws Exception { RemoveTagsFromCertificateResult result = null; try { result = executeRemoveTagsFromCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future renewCertificateAsync(RenewCertificateRequest request) { return renewCertificateAsync(request, null); } @Override public java.util.concurrent.Future renewCertificateAsync(final RenewCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final RenewCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public RenewCertificateResult call() throws Exception { RenewCertificateResult result = null; try { result = executeRenewCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future requestCertificateAsync(RequestCertificateRequest request) { return requestCertificateAsync(request, null); } @Override public java.util.concurrent.Future requestCertificateAsync(final RequestCertificateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final RequestCertificateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public RequestCertificateResult call() throws Exception { RequestCertificateResult result = null; try { result = executeRequestCertificate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future resendValidationEmailAsync(ResendValidationEmailRequest request) { return resendValidationEmailAsync(request, null); } @Override public java.util.concurrent.Future resendValidationEmailAsync(final ResendValidationEmailRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ResendValidationEmailRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ResendValidationEmailResult call() throws Exception { ResendValidationEmailResult result = null; try { result = executeResendValidationEmail(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateCertificateOptionsAsync(UpdateCertificateOptionsRequest request) { return updateCertificateOptionsAsync(request, null); } @Override public java.util.concurrent.Future updateCertificateOptionsAsync(final UpdateCertificateOptionsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateCertificateOptionsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateCertificateOptionsResult call() throws Exception { UpdateCertificateOptionsResult result = null; try { result = executeUpdateCertificateOptions(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } /** * Shuts down the client, releasing all managed resources. This includes forcibly terminating all pending * asynchronous service calls. Clients who wish to give pending asynchronous service calls time to complete should * call {@code getExecutorService().shutdown()} followed by {@code getExecutorService().awaitTermination()} prior to * calling this method. */ @Override public void shutdown() { super.shutdown(); executorService.shutdownNow(); } }