/*
* 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();
}
}