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

*

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AWSGameSparksAsyncClient extends AWSGameSparksClient implements AWSGameSparksAsync { private static final int DEFAULT_THREAD_POOL_SIZE = 50; private final java.util.concurrent.ExecutorService executorService; public static AWSGameSparksAsyncClientBuilder asyncBuilder() { return AWSGameSparksAsyncClientBuilder.standard(); } /** * Constructs a new asynchronous client to invoke service methods on GameSparks using the specified parameters. * * @param asyncClientParams * Object providing client parameters. */ AWSGameSparksAsyncClient(AwsAsyncClientParams asyncClientParams) { this(asyncClientParams, false); } /** * Constructs a new asynchronous client to invoke service methods on GameSparks using the specified parameters. * * @param asyncClientParams * Object providing client parameters. * @param endpointDiscoveryEnabled * true will enable endpoint discovery if the service supports it. */ AWSGameSparksAsyncClient(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 createGameAsync(CreateGameRequest request) { return createGameAsync(request, null); } @Override public java.util.concurrent.Future createGameAsync(final CreateGameRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateGameRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateGameResult call() throws Exception { CreateGameResult result = null; try { result = executeCreateGame(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 createSnapshotAsync(CreateSnapshotRequest request) { return createSnapshotAsync(request, null); } @Override public java.util.concurrent.Future createSnapshotAsync(final CreateSnapshotRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateSnapshotRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateSnapshotResult call() throws Exception { CreateSnapshotResult result = null; try { result = executeCreateSnapshot(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 createStageAsync(CreateStageRequest request) { return createStageAsync(request, null); } @Override public java.util.concurrent.Future createStageAsync(final CreateStageRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateStageRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateStageResult call() throws Exception { CreateStageResult result = null; try { result = executeCreateStage(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 deleteGameAsync(DeleteGameRequest request) { return deleteGameAsync(request, null); } @Override public java.util.concurrent.Future deleteGameAsync(final DeleteGameRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteGameRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteGameResult call() throws Exception { DeleteGameResult result = null; try { result = executeDeleteGame(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 deleteStageAsync(DeleteStageRequest request) { return deleteStageAsync(request, null); } @Override public java.util.concurrent.Future deleteStageAsync(final DeleteStageRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteStageRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteStageResult call() throws Exception { DeleteStageResult result = null; try { result = executeDeleteStage(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 disconnectPlayerAsync(DisconnectPlayerRequest request) { return disconnectPlayerAsync(request, null); } @Override public java.util.concurrent.Future disconnectPlayerAsync(final DisconnectPlayerRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DisconnectPlayerRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DisconnectPlayerResult call() throws Exception { DisconnectPlayerResult result = null; try { result = executeDisconnectPlayer(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 exportSnapshotAsync(ExportSnapshotRequest request) { return exportSnapshotAsync(request, null); } @Override public java.util.concurrent.Future exportSnapshotAsync(final ExportSnapshotRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ExportSnapshotRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ExportSnapshotResult call() throws Exception { ExportSnapshotResult result = null; try { result = executeExportSnapshot(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 getExtensionAsync(GetExtensionRequest request) { return getExtensionAsync(request, null); } @Override public java.util.concurrent.Future getExtensionAsync(final GetExtensionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetExtensionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetExtensionResult call() throws Exception { GetExtensionResult result = null; try { result = executeGetExtension(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 getExtensionVersionAsync(GetExtensionVersionRequest request) { return getExtensionVersionAsync(request, null); } @Override public java.util.concurrent.Future getExtensionVersionAsync(final GetExtensionVersionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetExtensionVersionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetExtensionVersionResult call() throws Exception { GetExtensionVersionResult result = null; try { result = executeGetExtensionVersion(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 getGameAsync(GetGameRequest request) { return getGameAsync(request, null); } @Override public java.util.concurrent.Future getGameAsync(final GetGameRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetGameRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetGameResult call() throws Exception { GetGameResult result = null; try { result = executeGetGame(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 getGameConfigurationAsync(GetGameConfigurationRequest request) { return getGameConfigurationAsync(request, null); } @Override public java.util.concurrent.Future getGameConfigurationAsync(final GetGameConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetGameConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetGameConfigurationResult call() throws Exception { GetGameConfigurationResult result = null; try { result = executeGetGameConfiguration(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 getGeneratedCodeJobAsync(GetGeneratedCodeJobRequest request) { return getGeneratedCodeJobAsync(request, null); } @Override public java.util.concurrent.Future getGeneratedCodeJobAsync(final GetGeneratedCodeJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetGeneratedCodeJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetGeneratedCodeJobResult call() throws Exception { GetGeneratedCodeJobResult result = null; try { result = executeGetGeneratedCodeJob(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 getPlayerConnectionStatusAsync(GetPlayerConnectionStatusRequest request) { return getPlayerConnectionStatusAsync(request, null); } @Override public java.util.concurrent.Future getPlayerConnectionStatusAsync(final GetPlayerConnectionStatusRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetPlayerConnectionStatusRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetPlayerConnectionStatusResult call() throws Exception { GetPlayerConnectionStatusResult result = null; try { result = executeGetPlayerConnectionStatus(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 getSnapshotAsync(GetSnapshotRequest request) { return getSnapshotAsync(request, null); } @Override public java.util.concurrent.Future getSnapshotAsync(final GetSnapshotRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetSnapshotRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetSnapshotResult call() throws Exception { GetSnapshotResult result = null; try { result = executeGetSnapshot(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 getStageAsync(GetStageRequest request) { return getStageAsync(request, null); } @Override public java.util.concurrent.Future getStageAsync(final GetStageRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetStageRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetStageResult call() throws Exception { GetStageResult result = null; try { result = executeGetStage(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 getStageDeploymentAsync(GetStageDeploymentRequest request) { return getStageDeploymentAsync(request, null); } @Override public java.util.concurrent.Future getStageDeploymentAsync(final GetStageDeploymentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetStageDeploymentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetStageDeploymentResult call() throws Exception { GetStageDeploymentResult result = null; try { result = executeGetStageDeployment(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 importGameConfigurationAsync(ImportGameConfigurationRequest request) { return importGameConfigurationAsync(request, null); } @Override public java.util.concurrent.Future importGameConfigurationAsync(final ImportGameConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ImportGameConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ImportGameConfigurationResult call() throws Exception { ImportGameConfigurationResult result = null; try { result = executeImportGameConfiguration(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 listExtensionVersionsAsync(ListExtensionVersionsRequest request) { return listExtensionVersionsAsync(request, null); } @Override public java.util.concurrent.Future listExtensionVersionsAsync(final ListExtensionVersionsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListExtensionVersionsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListExtensionVersionsResult call() throws Exception { ListExtensionVersionsResult result = null; try { result = executeListExtensionVersions(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 listExtensionsAsync(ListExtensionsRequest request) { return listExtensionsAsync(request, null); } @Override public java.util.concurrent.Future listExtensionsAsync(final ListExtensionsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListExtensionsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListExtensionsResult call() throws Exception { ListExtensionsResult result = null; try { result = executeListExtensions(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 listGamesAsync(ListGamesRequest request) { return listGamesAsync(request, null); } @Override public java.util.concurrent.Future listGamesAsync(final ListGamesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListGamesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListGamesResult call() throws Exception { ListGamesResult result = null; try { result = executeListGames(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 listGeneratedCodeJobsAsync(ListGeneratedCodeJobsRequest request) { return listGeneratedCodeJobsAsync(request, null); } @Override public java.util.concurrent.Future listGeneratedCodeJobsAsync(final ListGeneratedCodeJobsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListGeneratedCodeJobsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListGeneratedCodeJobsResult call() throws Exception { ListGeneratedCodeJobsResult result = null; try { result = executeListGeneratedCodeJobs(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 listSnapshotsAsync(ListSnapshotsRequest request) { return listSnapshotsAsync(request, null); } @Override public java.util.concurrent.Future listSnapshotsAsync(final ListSnapshotsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListSnapshotsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListSnapshotsResult call() throws Exception { ListSnapshotsResult result = null; try { result = executeListSnapshots(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 listStageDeploymentsAsync(ListStageDeploymentsRequest request) { return listStageDeploymentsAsync(request, null); } @Override public java.util.concurrent.Future listStageDeploymentsAsync(final ListStageDeploymentsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListStageDeploymentsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListStageDeploymentsResult call() throws Exception { ListStageDeploymentsResult result = null; try { result = executeListStageDeployments(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 listStagesAsync(ListStagesRequest request) { return listStagesAsync(request, null); } @Override public java.util.concurrent.Future listStagesAsync(final ListStagesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListStagesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListStagesResult call() throws Exception { ListStagesResult result = null; try { result = executeListStages(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 startGeneratedCodeJobAsync(StartGeneratedCodeJobRequest request) { return startGeneratedCodeJobAsync(request, null); } @Override public java.util.concurrent.Future startGeneratedCodeJobAsync(final StartGeneratedCodeJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StartGeneratedCodeJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StartGeneratedCodeJobResult call() throws Exception { StartGeneratedCodeJobResult result = null; try { result = executeStartGeneratedCodeJob(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 startStageDeploymentAsync(StartStageDeploymentRequest request) { return startStageDeploymentAsync(request, null); } @Override public java.util.concurrent.Future startStageDeploymentAsync(final StartStageDeploymentRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StartStageDeploymentRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StartStageDeploymentResult call() throws Exception { StartStageDeploymentResult result = null; try { result = executeStartStageDeployment(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 updateGameAsync(UpdateGameRequest request) { return updateGameAsync(request, null); } @Override public java.util.concurrent.Future updateGameAsync(final UpdateGameRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateGameRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateGameResult call() throws Exception { UpdateGameResult result = null; try { result = executeUpdateGame(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 updateGameConfigurationAsync(UpdateGameConfigurationRequest request) { return updateGameConfigurationAsync(request, null); } @Override public java.util.concurrent.Future updateGameConfigurationAsync(final UpdateGameConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateGameConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateGameConfigurationResult call() throws Exception { UpdateGameConfigurationResult result = null; try { result = executeUpdateGameConfiguration(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 updateSnapshotAsync(UpdateSnapshotRequest request) { return updateSnapshotAsync(request, null); } @Override public java.util.concurrent.Future updateSnapshotAsync(final UpdateSnapshotRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateSnapshotRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateSnapshotResult call() throws Exception { UpdateSnapshotResult result = null; try { result = executeUpdateSnapshot(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 updateStageAsync(UpdateStageRequest request) { return updateStageAsync(request, null); } @Override public java.util.concurrent.Future updateStageAsync(final UpdateStageRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateStageRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateStageResult call() throws Exception { UpdateStageResult result = null; try { result = executeUpdateStage(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(); } }