/* * 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.amplify; import javax.annotation.Generated; import com.amazonaws.services.amplify.model.*; import com.amazonaws.client.AwsAsyncClientParams; import com.amazonaws.annotation.ThreadSafe; import java.util.concurrent.ExecutorService; /** * Client for accessing Amplify 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. *

*

* Amplify enables developers to develop and deploy cloud-powered mobile and web apps. The Amplify Console provides a * continuous delivery and hosting service for web applications. For more information, see the Amplify Console User Guide. The Amplify * Framework is a comprehensive set of SDKs, libraries, tools, and documentation for client app development. For more * information, see the Amplify Framework. *

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AWSAmplifyAsyncClient extends AWSAmplifyClient implements AWSAmplifyAsync { private static final int DEFAULT_THREAD_POOL_SIZE = 50; private final java.util.concurrent.ExecutorService executorService; public static AWSAmplifyAsyncClientBuilder asyncBuilder() { return AWSAmplifyAsyncClientBuilder.standard(); } /** * Constructs a new asynchronous client to invoke service methods on Amplify using the specified parameters. * * @param asyncClientParams * Object providing client parameters. */ AWSAmplifyAsyncClient(AwsAsyncClientParams asyncClientParams) { this(asyncClientParams, false); } /** * Constructs a new asynchronous client to invoke service methods on Amplify using the specified parameters. * * @param asyncClientParams * Object providing client parameters. * @param endpointDiscoveryEnabled * true will enable endpoint discovery if the service supports it. */ AWSAmplifyAsyncClient(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 createAppAsync(CreateAppRequest request) { return createAppAsync(request, null); } @Override public java.util.concurrent.Future createAppAsync(final CreateAppRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateAppRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateAppResult call() throws Exception { CreateAppResult result = null; try { result = executeCreateApp(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 createBackendEnvironmentAsync(CreateBackendEnvironmentRequest request) { return createBackendEnvironmentAsync(request, null); } @Override public java.util.concurrent.Future createBackendEnvironmentAsync(final CreateBackendEnvironmentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateBackendEnvironmentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateBackendEnvironmentResult call() throws Exception { CreateBackendEnvironmentResult result = null; try { result = executeCreateBackendEnvironment(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 createBranchAsync(CreateBranchRequest request) { return createBranchAsync(request, null); } @Override public java.util.concurrent.Future createBranchAsync(final CreateBranchRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateBranchRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateBranchResult call() throws Exception { CreateBranchResult result = null; try { result = executeCreateBranch(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 createDeploymentAsync(CreateDeploymentRequest request) { return createDeploymentAsync(request, null); } @Override public java.util.concurrent.Future createDeploymentAsync(final CreateDeploymentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateDeploymentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateDeploymentResult call() throws Exception { CreateDeploymentResult result = null; try { result = executeCreateDeployment(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 createDomainAssociationAsync(CreateDomainAssociationRequest request) { return createDomainAssociationAsync(request, null); } @Override public java.util.concurrent.Future createDomainAssociationAsync(final CreateDomainAssociationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateDomainAssociationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateDomainAssociationResult call() throws Exception { CreateDomainAssociationResult result = null; try { result = executeCreateDomainAssociation(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 createWebhookAsync(CreateWebhookRequest request) { return createWebhookAsync(request, null); } @Override public java.util.concurrent.Future createWebhookAsync(final CreateWebhookRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateWebhookRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateWebhookResult call() throws Exception { CreateWebhookResult result = null; try { result = executeCreateWebhook(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 deleteAppAsync(DeleteAppRequest request) { return deleteAppAsync(request, null); } @Override public java.util.concurrent.Future deleteAppAsync(final DeleteAppRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteAppRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteAppResult call() throws Exception { DeleteAppResult result = null; try { result = executeDeleteApp(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 deleteBackendEnvironmentAsync(DeleteBackendEnvironmentRequest request) { return deleteBackendEnvironmentAsync(request, null); } @Override public java.util.concurrent.Future deleteBackendEnvironmentAsync(final DeleteBackendEnvironmentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteBackendEnvironmentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteBackendEnvironmentResult call() throws Exception { DeleteBackendEnvironmentResult result = null; try { result = executeDeleteBackendEnvironment(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 deleteBranchAsync(DeleteBranchRequest request) { return deleteBranchAsync(request, null); } @Override public java.util.concurrent.Future deleteBranchAsync(final DeleteBranchRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteBranchRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteBranchResult call() throws Exception { DeleteBranchResult result = null; try { result = executeDeleteBranch(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 deleteDomainAssociationAsync(DeleteDomainAssociationRequest request) { return deleteDomainAssociationAsync(request, null); } @Override public java.util.concurrent.Future deleteDomainAssociationAsync(final DeleteDomainAssociationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteDomainAssociationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteDomainAssociationResult call() throws Exception { DeleteDomainAssociationResult result = null; try { result = executeDeleteDomainAssociation(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 deleteJobAsync(DeleteJobRequest request) { return deleteJobAsync(request, null); } @Override public java.util.concurrent.Future deleteJobAsync(final DeleteJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteJobResult call() throws Exception { DeleteJobResult result = null; try { result = executeDeleteJob(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 deleteWebhookAsync(DeleteWebhookRequest request) { return deleteWebhookAsync(request, null); } @Override public java.util.concurrent.Future deleteWebhookAsync(final DeleteWebhookRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteWebhookRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteWebhookResult call() throws Exception { DeleteWebhookResult result = null; try { result = executeDeleteWebhook(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 generateAccessLogsAsync(GenerateAccessLogsRequest request) { return generateAccessLogsAsync(request, null); } @Override public java.util.concurrent.Future generateAccessLogsAsync(final GenerateAccessLogsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GenerateAccessLogsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GenerateAccessLogsResult call() throws Exception { GenerateAccessLogsResult result = null; try { result = executeGenerateAccessLogs(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 getAppAsync(GetAppRequest request) { return getAppAsync(request, null); } @Override public java.util.concurrent.Future getAppAsync(final GetAppRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetAppRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetAppResult call() throws Exception { GetAppResult result = null; try { result = executeGetApp(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 getArtifactUrlAsync(GetArtifactUrlRequest request) { return getArtifactUrlAsync(request, null); } @Override public java.util.concurrent.Future getArtifactUrlAsync(final GetArtifactUrlRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetArtifactUrlRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetArtifactUrlResult call() throws Exception { GetArtifactUrlResult result = null; try { result = executeGetArtifactUrl(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 getBackendEnvironmentAsync(GetBackendEnvironmentRequest request) { return getBackendEnvironmentAsync(request, null); } @Override public java.util.concurrent.Future getBackendEnvironmentAsync(final GetBackendEnvironmentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetBackendEnvironmentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetBackendEnvironmentResult call() throws Exception { GetBackendEnvironmentResult result = null; try { result = executeGetBackendEnvironment(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 getBranchAsync(GetBranchRequest request) { return getBranchAsync(request, null); } @Override public java.util.concurrent.Future getBranchAsync(final GetBranchRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetBranchRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetBranchResult call() throws Exception { GetBranchResult result = null; try { result = executeGetBranch(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 getDomainAssociationAsync(GetDomainAssociationRequest request) { return getDomainAssociationAsync(request, null); } @Override public java.util.concurrent.Future getDomainAssociationAsync(final GetDomainAssociationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetDomainAssociationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetDomainAssociationResult call() throws Exception { GetDomainAssociationResult result = null; try { result = executeGetDomainAssociation(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 getJobAsync(GetJobRequest request) { return getJobAsync(request, null); } @Override public java.util.concurrent.Future getJobAsync(final GetJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetJobResult call() throws Exception { GetJobResult result = null; try { result = executeGetJob(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 getWebhookAsync(GetWebhookRequest request) { return getWebhookAsync(request, null); } @Override public java.util.concurrent.Future getWebhookAsync(final GetWebhookRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetWebhookRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetWebhookResult call() throws Exception { GetWebhookResult result = null; try { result = executeGetWebhook(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 listAppsAsync(ListAppsRequest request) { return listAppsAsync(request, null); } @Override public java.util.concurrent.Future listAppsAsync(final ListAppsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAppsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAppsResult call() throws Exception { ListAppsResult result = null; try { result = executeListApps(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 listArtifactsAsync(ListArtifactsRequest request) { return listArtifactsAsync(request, null); } @Override public java.util.concurrent.Future listArtifactsAsync(final ListArtifactsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListArtifactsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListArtifactsResult call() throws Exception { ListArtifactsResult result = null; try { result = executeListArtifacts(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 listBackendEnvironmentsAsync(ListBackendEnvironmentsRequest request) { return listBackendEnvironmentsAsync(request, null); } @Override public java.util.concurrent.Future listBackendEnvironmentsAsync(final ListBackendEnvironmentsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListBackendEnvironmentsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListBackendEnvironmentsResult call() throws Exception { ListBackendEnvironmentsResult result = null; try { result = executeListBackendEnvironments(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 listBranchesAsync(ListBranchesRequest request) { return listBranchesAsync(request, null); } @Override public java.util.concurrent.Future listBranchesAsync(final ListBranchesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListBranchesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListBranchesResult call() throws Exception { ListBranchesResult result = null; try { result = executeListBranches(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 listDomainAssociationsAsync(ListDomainAssociationsRequest request) { return listDomainAssociationsAsync(request, null); } @Override public java.util.concurrent.Future listDomainAssociationsAsync(final ListDomainAssociationsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListDomainAssociationsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListDomainAssociationsResult call() throws Exception { ListDomainAssociationsResult result = null; try { result = executeListDomainAssociations(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 listJobsAsync(ListJobsRequest request) { return listJobsAsync(request, null); } @Override public java.util.concurrent.Future listJobsAsync(final ListJobsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListJobsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListJobsResult call() throws Exception { ListJobsResult result = null; try { result = executeListJobs(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 listTagsForResourceAsync(ListTagsForResourceRequest request) { return listTagsForResourceAsync(request, null); } @Override public java.util.concurrent.Future listTagsForResourceAsync(final ListTagsForResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListTagsForResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListTagsForResourceResult call() throws Exception { ListTagsForResourceResult result = null; try { result = executeListTagsForResource(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 listWebhooksAsync(ListWebhooksRequest request) { return listWebhooksAsync(request, null); } @Override public java.util.concurrent.Future listWebhooksAsync(final ListWebhooksRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListWebhooksRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListWebhooksResult call() throws Exception { ListWebhooksResult result = null; try { result = executeListWebhooks(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 startDeploymentAsync(StartDeploymentRequest request) { return startDeploymentAsync(request, null); } @Override public java.util.concurrent.Future startDeploymentAsync(final StartDeploymentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StartDeploymentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StartDeploymentResult call() throws Exception { StartDeploymentResult result = null; try { result = executeStartDeployment(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 startJobAsync(StartJobRequest request) { return startJobAsync(request, null); } @Override public java.util.concurrent.Future startJobAsync(final StartJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StartJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StartJobResult call() throws Exception { StartJobResult result = null; try { result = executeStartJob(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 stopJobAsync(StopJobRequest request) { return stopJobAsync(request, null); } @Override public java.util.concurrent.Future stopJobAsync(final StopJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StopJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StopJobResult call() throws Exception { StopJobResult result = null; try { result = executeStopJob(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 tagResourceAsync(TagResourceRequest request) { return tagResourceAsync(request, null); } @Override public java.util.concurrent.Future tagResourceAsync(final TagResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final TagResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public TagResourceResult call() throws Exception { TagResourceResult result = null; try { result = executeTagResource(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 untagResourceAsync(UntagResourceRequest request) { return untagResourceAsync(request, null); } @Override public java.util.concurrent.Future untagResourceAsync(final UntagResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UntagResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UntagResourceResult call() throws Exception { UntagResourceResult result = null; try { result = executeUntagResource(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 updateAppAsync(UpdateAppRequest request) { return updateAppAsync(request, null); } @Override public java.util.concurrent.Future updateAppAsync(final UpdateAppRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAppRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAppResult call() throws Exception { UpdateAppResult result = null; try { result = executeUpdateApp(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 updateBranchAsync(UpdateBranchRequest request) { return updateBranchAsync(request, null); } @Override public java.util.concurrent.Future updateBranchAsync(final UpdateBranchRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateBranchRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateBranchResult call() throws Exception { UpdateBranchResult result = null; try { result = executeUpdateBranch(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 updateDomainAssociationAsync(UpdateDomainAssociationRequest request) { return updateDomainAssociationAsync(request, null); } @Override public java.util.concurrent.Future updateDomainAssociationAsync(final UpdateDomainAssociationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateDomainAssociationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateDomainAssociationResult call() throws Exception { UpdateDomainAssociationResult result = null; try { result = executeUpdateDomainAssociation(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 updateWebhookAsync(UpdateWebhookRequest request) { return updateWebhookAsync(request, null); } @Override public java.util.concurrent.Future updateWebhookAsync(final UpdateWebhookRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateWebhookRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateWebhookResult call() throws Exception { UpdateWebhookResult result = null; try { result = executeUpdateWebhook(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(); } }