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

*

* Welcome to the IoT SiteWise API Reference. IoT SiteWise is an Amazon Web Services service that connects Industrial Internet of Things * (IIoT) devices to the power of the Amazon Web Services Cloud. For more information, see the IoT SiteWise User Guide. For information about * IoT SiteWise quotas, see Quotas * in the IoT SiteWise User Guide. *

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AWSIoTSiteWiseAsyncClient extends AWSIoTSiteWiseClient implements AWSIoTSiteWiseAsync { private static final int DEFAULT_THREAD_POOL_SIZE = 50; private final java.util.concurrent.ExecutorService executorService; public static AWSIoTSiteWiseAsyncClientBuilder asyncBuilder() { return AWSIoTSiteWiseAsyncClientBuilder.standard(); } /** * Constructs a new asynchronous client to invoke service methods on AWS IoT SiteWise using the specified * parameters. * * @param asyncClientParams * Object providing client parameters. */ AWSIoTSiteWiseAsyncClient(AwsAsyncClientParams asyncClientParams) { this(asyncClientParams, false); } /** * Constructs a new asynchronous client to invoke service methods on AWS IoT SiteWise using the specified * parameters. * * @param asyncClientParams * Object providing client parameters. * @param endpointDiscoveryEnabled * true will enable endpoint discovery if the service supports it. */ AWSIoTSiteWiseAsyncClient(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 associateAssetsAsync(AssociateAssetsRequest request) { return associateAssetsAsync(request, null); } @Override public java.util.concurrent.Future associateAssetsAsync(final AssociateAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final AssociateAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public AssociateAssetsResult call() throws Exception { AssociateAssetsResult result = null; try { result = executeAssociateAssets(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 associateTimeSeriesToAssetPropertyAsync( AssociateTimeSeriesToAssetPropertyRequest request) { return associateTimeSeriesToAssetPropertyAsync(request, null); } @Override public java.util.concurrent.Future associateTimeSeriesToAssetPropertyAsync( final AssociateTimeSeriesToAssetPropertyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final AssociateTimeSeriesToAssetPropertyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public AssociateTimeSeriesToAssetPropertyResult call() throws Exception { AssociateTimeSeriesToAssetPropertyResult result = null; try { result = executeAssociateTimeSeriesToAssetProperty(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 batchAssociateProjectAssetsAsync(BatchAssociateProjectAssetsRequest request) { return batchAssociateProjectAssetsAsync(request, null); } @Override public java.util.concurrent.Future batchAssociateProjectAssetsAsync(final BatchAssociateProjectAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final BatchAssociateProjectAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public BatchAssociateProjectAssetsResult call() throws Exception { BatchAssociateProjectAssetsResult result = null; try { result = executeBatchAssociateProjectAssets(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 batchDisassociateProjectAssetsAsync(BatchDisassociateProjectAssetsRequest request) { return batchDisassociateProjectAssetsAsync(request, null); } @Override public java.util.concurrent.Future batchDisassociateProjectAssetsAsync( final BatchDisassociateProjectAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final BatchDisassociateProjectAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public BatchDisassociateProjectAssetsResult call() throws Exception { BatchDisassociateProjectAssetsResult result = null; try { result = executeBatchDisassociateProjectAssets(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 batchGetAssetPropertyAggregatesAsync( BatchGetAssetPropertyAggregatesRequest request) { return batchGetAssetPropertyAggregatesAsync(request, null); } @Override public java.util.concurrent.Future batchGetAssetPropertyAggregatesAsync( final BatchGetAssetPropertyAggregatesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final BatchGetAssetPropertyAggregatesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public BatchGetAssetPropertyAggregatesResult call() throws Exception { BatchGetAssetPropertyAggregatesResult result = null; try { result = executeBatchGetAssetPropertyAggregates(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 batchGetAssetPropertyValueAsync(BatchGetAssetPropertyValueRequest request) { return batchGetAssetPropertyValueAsync(request, null); } @Override public java.util.concurrent.Future batchGetAssetPropertyValueAsync(final BatchGetAssetPropertyValueRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final BatchGetAssetPropertyValueRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public BatchGetAssetPropertyValueResult call() throws Exception { BatchGetAssetPropertyValueResult result = null; try { result = executeBatchGetAssetPropertyValue(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 batchGetAssetPropertyValueHistoryAsync( BatchGetAssetPropertyValueHistoryRequest request) { return batchGetAssetPropertyValueHistoryAsync(request, null); } @Override public java.util.concurrent.Future batchGetAssetPropertyValueHistoryAsync( final BatchGetAssetPropertyValueHistoryRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final BatchGetAssetPropertyValueHistoryRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public BatchGetAssetPropertyValueHistoryResult call() throws Exception { BatchGetAssetPropertyValueHistoryResult result = null; try { result = executeBatchGetAssetPropertyValueHistory(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 batchPutAssetPropertyValueAsync(BatchPutAssetPropertyValueRequest request) { return batchPutAssetPropertyValueAsync(request, null); } @Override public java.util.concurrent.Future batchPutAssetPropertyValueAsync(final BatchPutAssetPropertyValueRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final BatchPutAssetPropertyValueRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public BatchPutAssetPropertyValueResult call() throws Exception { BatchPutAssetPropertyValueResult result = null; try { result = executeBatchPutAssetPropertyValue(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 createAccessPolicyAsync(CreateAccessPolicyRequest request) { return createAccessPolicyAsync(request, null); } @Override public java.util.concurrent.Future createAccessPolicyAsync(final CreateAccessPolicyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateAccessPolicyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateAccessPolicyResult call() throws Exception { CreateAccessPolicyResult result = null; try { result = executeCreateAccessPolicy(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 createAssetAsync(CreateAssetRequest request) { return createAssetAsync(request, null); } @Override public java.util.concurrent.Future createAssetAsync(final CreateAssetRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateAssetRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateAssetResult call() throws Exception { CreateAssetResult result = null; try { result = executeCreateAsset(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 createAssetModelAsync(CreateAssetModelRequest request) { return createAssetModelAsync(request, null); } @Override public java.util.concurrent.Future createAssetModelAsync(final CreateAssetModelRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateAssetModelRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateAssetModelResult call() throws Exception { CreateAssetModelResult result = null; try { result = executeCreateAssetModel(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 createBulkImportJobAsync(CreateBulkImportJobRequest request) { return createBulkImportJobAsync(request, null); } @Override public java.util.concurrent.Future createBulkImportJobAsync(final CreateBulkImportJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateBulkImportJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateBulkImportJobResult call() throws Exception { CreateBulkImportJobResult result = null; try { result = executeCreateBulkImportJob(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 createDashboardAsync(CreateDashboardRequest request) { return createDashboardAsync(request, null); } @Override public java.util.concurrent.Future createDashboardAsync(final CreateDashboardRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateDashboardRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateDashboardResult call() throws Exception { CreateDashboardResult result = null; try { result = executeCreateDashboard(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 createGatewayAsync(CreateGatewayRequest request) { return createGatewayAsync(request, null); } @Override public java.util.concurrent.Future createGatewayAsync(final CreateGatewayRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateGatewayRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateGatewayResult call() throws Exception { CreateGatewayResult result = null; try { result = executeCreateGateway(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 createPortalAsync(CreatePortalRequest request) { return createPortalAsync(request, null); } @Override public java.util.concurrent.Future createPortalAsync(final CreatePortalRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreatePortalRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreatePortalResult call() throws Exception { CreatePortalResult result = null; try { result = executeCreatePortal(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 createProjectAsync(CreateProjectRequest request) { return createProjectAsync(request, null); } @Override public java.util.concurrent.Future createProjectAsync(final CreateProjectRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateProjectRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateProjectResult call() throws Exception { CreateProjectResult result = null; try { result = executeCreateProject(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 deleteAccessPolicyAsync(DeleteAccessPolicyRequest request) { return deleteAccessPolicyAsync(request, null); } @Override public java.util.concurrent.Future deleteAccessPolicyAsync(final DeleteAccessPolicyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteAccessPolicyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteAccessPolicyResult call() throws Exception { DeleteAccessPolicyResult result = null; try { result = executeDeleteAccessPolicy(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 deleteAssetAsync(DeleteAssetRequest request) { return deleteAssetAsync(request, null); } @Override public java.util.concurrent.Future deleteAssetAsync(final DeleteAssetRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteAssetRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteAssetResult call() throws Exception { DeleteAssetResult result = null; try { result = executeDeleteAsset(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 deleteAssetModelAsync(DeleteAssetModelRequest request) { return deleteAssetModelAsync(request, null); } @Override public java.util.concurrent.Future deleteAssetModelAsync(final DeleteAssetModelRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteAssetModelRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteAssetModelResult call() throws Exception { DeleteAssetModelResult result = null; try { result = executeDeleteAssetModel(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 deleteDashboardAsync(DeleteDashboardRequest request) { return deleteDashboardAsync(request, null); } @Override public java.util.concurrent.Future deleteDashboardAsync(final DeleteDashboardRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteDashboardRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteDashboardResult call() throws Exception { DeleteDashboardResult result = null; try { result = executeDeleteDashboard(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 deleteGatewayAsync(DeleteGatewayRequest request) { return deleteGatewayAsync(request, null); } @Override public java.util.concurrent.Future deleteGatewayAsync(final DeleteGatewayRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteGatewayRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteGatewayResult call() throws Exception { DeleteGatewayResult result = null; try { result = executeDeleteGateway(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 deletePortalAsync(DeletePortalRequest request) { return deletePortalAsync(request, null); } @Override public java.util.concurrent.Future deletePortalAsync(final DeletePortalRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeletePortalRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeletePortalResult call() throws Exception { DeletePortalResult result = null; try { result = executeDeletePortal(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 deleteProjectAsync(DeleteProjectRequest request) { return deleteProjectAsync(request, null); } @Override public java.util.concurrent.Future deleteProjectAsync(final DeleteProjectRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteProjectRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteProjectResult call() throws Exception { DeleteProjectResult result = null; try { result = executeDeleteProject(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 deleteTimeSeriesAsync(DeleteTimeSeriesRequest request) { return deleteTimeSeriesAsync(request, null); } @Override public java.util.concurrent.Future deleteTimeSeriesAsync(final DeleteTimeSeriesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteTimeSeriesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteTimeSeriesResult call() throws Exception { DeleteTimeSeriesResult result = null; try { result = executeDeleteTimeSeries(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 describeAccessPolicyAsync(DescribeAccessPolicyRequest request) { return describeAccessPolicyAsync(request, null); } @Override public java.util.concurrent.Future describeAccessPolicyAsync(final DescribeAccessPolicyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAccessPolicyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAccessPolicyResult call() throws Exception { DescribeAccessPolicyResult result = null; try { result = executeDescribeAccessPolicy(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 describeAssetAsync(DescribeAssetRequest request) { return describeAssetAsync(request, null); } @Override public java.util.concurrent.Future describeAssetAsync(final DescribeAssetRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAssetRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAssetResult call() throws Exception { DescribeAssetResult result = null; try { result = executeDescribeAsset(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 describeAssetModelAsync(DescribeAssetModelRequest request) { return describeAssetModelAsync(request, null); } @Override public java.util.concurrent.Future describeAssetModelAsync(final DescribeAssetModelRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAssetModelRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAssetModelResult call() throws Exception { DescribeAssetModelResult result = null; try { result = executeDescribeAssetModel(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 describeAssetPropertyAsync(DescribeAssetPropertyRequest request) { return describeAssetPropertyAsync(request, null); } @Override public java.util.concurrent.Future describeAssetPropertyAsync(final DescribeAssetPropertyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAssetPropertyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAssetPropertyResult call() throws Exception { DescribeAssetPropertyResult result = null; try { result = executeDescribeAssetProperty(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 describeBulkImportJobAsync(DescribeBulkImportJobRequest request) { return describeBulkImportJobAsync(request, null); } @Override public java.util.concurrent.Future describeBulkImportJobAsync(final DescribeBulkImportJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeBulkImportJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeBulkImportJobResult call() throws Exception { DescribeBulkImportJobResult result = null; try { result = executeDescribeBulkImportJob(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 describeDashboardAsync(DescribeDashboardRequest request) { return describeDashboardAsync(request, null); } @Override public java.util.concurrent.Future describeDashboardAsync(final DescribeDashboardRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeDashboardRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeDashboardResult call() throws Exception { DescribeDashboardResult result = null; try { result = executeDescribeDashboard(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 describeDefaultEncryptionConfigurationAsync( DescribeDefaultEncryptionConfigurationRequest request) { return describeDefaultEncryptionConfigurationAsync(request, null); } @Override public java.util.concurrent.Future describeDefaultEncryptionConfigurationAsync( final DescribeDefaultEncryptionConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeDefaultEncryptionConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeDefaultEncryptionConfigurationResult call() throws Exception { DescribeDefaultEncryptionConfigurationResult result = null; try { result = executeDescribeDefaultEncryptionConfiguration(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 describeGatewayAsync(DescribeGatewayRequest request) { return describeGatewayAsync(request, null); } @Override public java.util.concurrent.Future describeGatewayAsync(final DescribeGatewayRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeGatewayRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeGatewayResult call() throws Exception { DescribeGatewayResult result = null; try { result = executeDescribeGateway(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 describeGatewayCapabilityConfigurationAsync( DescribeGatewayCapabilityConfigurationRequest request) { return describeGatewayCapabilityConfigurationAsync(request, null); } @Override public java.util.concurrent.Future describeGatewayCapabilityConfigurationAsync( final DescribeGatewayCapabilityConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeGatewayCapabilityConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeGatewayCapabilityConfigurationResult call() throws Exception { DescribeGatewayCapabilityConfigurationResult result = null; try { result = executeDescribeGatewayCapabilityConfiguration(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 describeLoggingOptionsAsync(DescribeLoggingOptionsRequest request) { return describeLoggingOptionsAsync(request, null); } @Override public java.util.concurrent.Future describeLoggingOptionsAsync(final DescribeLoggingOptionsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeLoggingOptionsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeLoggingOptionsResult call() throws Exception { DescribeLoggingOptionsResult result = null; try { result = executeDescribeLoggingOptions(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 describePortalAsync(DescribePortalRequest request) { return describePortalAsync(request, null); } @Override public java.util.concurrent.Future describePortalAsync(final DescribePortalRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribePortalRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribePortalResult call() throws Exception { DescribePortalResult result = null; try { result = executeDescribePortal(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 describeProjectAsync(DescribeProjectRequest request) { return describeProjectAsync(request, null); } @Override public java.util.concurrent.Future describeProjectAsync(final DescribeProjectRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeProjectRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeProjectResult call() throws Exception { DescribeProjectResult result = null; try { result = executeDescribeProject(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 describeStorageConfigurationAsync(DescribeStorageConfigurationRequest request) { return describeStorageConfigurationAsync(request, null); } @Override public java.util.concurrent.Future describeStorageConfigurationAsync(final DescribeStorageConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeStorageConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeStorageConfigurationResult call() throws Exception { DescribeStorageConfigurationResult result = null; try { result = executeDescribeStorageConfiguration(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 describeTimeSeriesAsync(DescribeTimeSeriesRequest request) { return describeTimeSeriesAsync(request, null); } @Override public java.util.concurrent.Future describeTimeSeriesAsync(final DescribeTimeSeriesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeTimeSeriesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeTimeSeriesResult call() throws Exception { DescribeTimeSeriesResult result = null; try { result = executeDescribeTimeSeries(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 disassociateAssetsAsync(DisassociateAssetsRequest request) { return disassociateAssetsAsync(request, null); } @Override public java.util.concurrent.Future disassociateAssetsAsync(final DisassociateAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DisassociateAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DisassociateAssetsResult call() throws Exception { DisassociateAssetsResult result = null; try { result = executeDisassociateAssets(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 disassociateTimeSeriesFromAssetPropertyAsync( DisassociateTimeSeriesFromAssetPropertyRequest request) { return disassociateTimeSeriesFromAssetPropertyAsync(request, null); } @Override public java.util.concurrent.Future disassociateTimeSeriesFromAssetPropertyAsync( final DisassociateTimeSeriesFromAssetPropertyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DisassociateTimeSeriesFromAssetPropertyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DisassociateTimeSeriesFromAssetPropertyResult call() throws Exception { DisassociateTimeSeriesFromAssetPropertyResult result = null; try { result = executeDisassociateTimeSeriesFromAssetProperty(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 getAssetPropertyAggregatesAsync(GetAssetPropertyAggregatesRequest request) { return getAssetPropertyAggregatesAsync(request, null); } @Override public java.util.concurrent.Future getAssetPropertyAggregatesAsync(final GetAssetPropertyAggregatesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetAssetPropertyAggregatesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetAssetPropertyAggregatesResult call() throws Exception { GetAssetPropertyAggregatesResult result = null; try { result = executeGetAssetPropertyAggregates(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 getAssetPropertyValueAsync(GetAssetPropertyValueRequest request) { return getAssetPropertyValueAsync(request, null); } @Override public java.util.concurrent.Future getAssetPropertyValueAsync(final GetAssetPropertyValueRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetAssetPropertyValueRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetAssetPropertyValueResult call() throws Exception { GetAssetPropertyValueResult result = null; try { result = executeGetAssetPropertyValue(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 getAssetPropertyValueHistoryAsync(GetAssetPropertyValueHistoryRequest request) { return getAssetPropertyValueHistoryAsync(request, null); } @Override public java.util.concurrent.Future getAssetPropertyValueHistoryAsync(final GetAssetPropertyValueHistoryRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetAssetPropertyValueHistoryRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetAssetPropertyValueHistoryResult call() throws Exception { GetAssetPropertyValueHistoryResult result = null; try { result = executeGetAssetPropertyValueHistory(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 getInterpolatedAssetPropertyValuesAsync( GetInterpolatedAssetPropertyValuesRequest request) { return getInterpolatedAssetPropertyValuesAsync(request, null); } @Override public java.util.concurrent.Future getInterpolatedAssetPropertyValuesAsync( final GetInterpolatedAssetPropertyValuesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final GetInterpolatedAssetPropertyValuesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public GetInterpolatedAssetPropertyValuesResult call() throws Exception { GetInterpolatedAssetPropertyValuesResult result = null; try { result = executeGetInterpolatedAssetPropertyValues(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 listAccessPoliciesAsync(ListAccessPoliciesRequest request) { return listAccessPoliciesAsync(request, null); } @Override public java.util.concurrent.Future listAccessPoliciesAsync(final ListAccessPoliciesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAccessPoliciesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAccessPoliciesResult call() throws Exception { ListAccessPoliciesResult result = null; try { result = executeListAccessPolicies(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 listAssetModelPropertiesAsync(ListAssetModelPropertiesRequest request) { return listAssetModelPropertiesAsync(request, null); } @Override public java.util.concurrent.Future listAssetModelPropertiesAsync(final ListAssetModelPropertiesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAssetModelPropertiesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAssetModelPropertiesResult call() throws Exception { ListAssetModelPropertiesResult result = null; try { result = executeListAssetModelProperties(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 listAssetModelsAsync(ListAssetModelsRequest request) { return listAssetModelsAsync(request, null); } @Override public java.util.concurrent.Future listAssetModelsAsync(final ListAssetModelsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAssetModelsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAssetModelsResult call() throws Exception { ListAssetModelsResult result = null; try { result = executeListAssetModels(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 listAssetPropertiesAsync(ListAssetPropertiesRequest request) { return listAssetPropertiesAsync(request, null); } @Override public java.util.concurrent.Future listAssetPropertiesAsync(final ListAssetPropertiesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAssetPropertiesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAssetPropertiesResult call() throws Exception { ListAssetPropertiesResult result = null; try { result = executeListAssetProperties(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 listAssetRelationshipsAsync(ListAssetRelationshipsRequest request) { return listAssetRelationshipsAsync(request, null); } @Override public java.util.concurrent.Future listAssetRelationshipsAsync(final ListAssetRelationshipsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAssetRelationshipsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAssetRelationshipsResult call() throws Exception { ListAssetRelationshipsResult result = null; try { result = executeListAssetRelationships(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 listAssetsAsync(ListAssetsRequest request) { return listAssetsAsync(request, null); } @Override public java.util.concurrent.Future listAssetsAsync(final ListAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAssetsResult call() throws Exception { ListAssetsResult result = null; try { result = executeListAssets(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 listAssociatedAssetsAsync(ListAssociatedAssetsRequest request) { return listAssociatedAssetsAsync(request, null); } @Override public java.util.concurrent.Future listAssociatedAssetsAsync(final ListAssociatedAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAssociatedAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAssociatedAssetsResult call() throws Exception { ListAssociatedAssetsResult result = null; try { result = executeListAssociatedAssets(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 listBulkImportJobsAsync(ListBulkImportJobsRequest request) { return listBulkImportJobsAsync(request, null); } @Override public java.util.concurrent.Future listBulkImportJobsAsync(final ListBulkImportJobsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListBulkImportJobsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListBulkImportJobsResult call() throws Exception { ListBulkImportJobsResult result = null; try { result = executeListBulkImportJobs(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 listDashboardsAsync(ListDashboardsRequest request) { return listDashboardsAsync(request, null); } @Override public java.util.concurrent.Future listDashboardsAsync(final ListDashboardsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListDashboardsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListDashboardsResult call() throws Exception { ListDashboardsResult result = null; try { result = executeListDashboards(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 listGatewaysAsync(ListGatewaysRequest request) { return listGatewaysAsync(request, null); } @Override public java.util.concurrent.Future listGatewaysAsync(final ListGatewaysRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListGatewaysRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListGatewaysResult call() throws Exception { ListGatewaysResult result = null; try { result = executeListGateways(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 listPortalsAsync(ListPortalsRequest request) { return listPortalsAsync(request, null); } @Override public java.util.concurrent.Future listPortalsAsync(final ListPortalsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListPortalsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListPortalsResult call() throws Exception { ListPortalsResult result = null; try { result = executeListPortals(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 listProjectAssetsAsync(ListProjectAssetsRequest request) { return listProjectAssetsAsync(request, null); } @Override public java.util.concurrent.Future listProjectAssetsAsync(final ListProjectAssetsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListProjectAssetsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListProjectAssetsResult call() throws Exception { ListProjectAssetsResult result = null; try { result = executeListProjectAssets(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 listProjectsAsync(ListProjectsRequest request) { return listProjectsAsync(request, null); } @Override public java.util.concurrent.Future listProjectsAsync(final ListProjectsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListProjectsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListProjectsResult call() throws Exception { ListProjectsResult result = null; try { result = executeListProjects(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 listTimeSeriesAsync(ListTimeSeriesRequest request) { return listTimeSeriesAsync(request, null); } @Override public java.util.concurrent.Future listTimeSeriesAsync(final ListTimeSeriesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListTimeSeriesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListTimeSeriesResult call() throws Exception { ListTimeSeriesResult result = null; try { result = executeListTimeSeries(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 putDefaultEncryptionConfigurationAsync( PutDefaultEncryptionConfigurationRequest request) { return putDefaultEncryptionConfigurationAsync(request, null); } @Override public java.util.concurrent.Future putDefaultEncryptionConfigurationAsync( final PutDefaultEncryptionConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final PutDefaultEncryptionConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public PutDefaultEncryptionConfigurationResult call() throws Exception { PutDefaultEncryptionConfigurationResult result = null; try { result = executePutDefaultEncryptionConfiguration(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 putLoggingOptionsAsync(PutLoggingOptionsRequest request) { return putLoggingOptionsAsync(request, null); } @Override public java.util.concurrent.Future putLoggingOptionsAsync(final PutLoggingOptionsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final PutLoggingOptionsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public PutLoggingOptionsResult call() throws Exception { PutLoggingOptionsResult result = null; try { result = executePutLoggingOptions(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 putStorageConfigurationAsync(PutStorageConfigurationRequest request) { return putStorageConfigurationAsync(request, null); } @Override public java.util.concurrent.Future putStorageConfigurationAsync(final PutStorageConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final PutStorageConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public PutStorageConfigurationResult call() throws Exception { PutStorageConfigurationResult result = null; try { result = executePutStorageConfiguration(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 updateAccessPolicyAsync(UpdateAccessPolicyRequest request) { return updateAccessPolicyAsync(request, null); } @Override public java.util.concurrent.Future updateAccessPolicyAsync(final UpdateAccessPolicyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAccessPolicyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAccessPolicyResult call() throws Exception { UpdateAccessPolicyResult result = null; try { result = executeUpdateAccessPolicy(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 updateAssetAsync(UpdateAssetRequest request) { return updateAssetAsync(request, null); } @Override public java.util.concurrent.Future updateAssetAsync(final UpdateAssetRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAssetRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAssetResult call() throws Exception { UpdateAssetResult result = null; try { result = executeUpdateAsset(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 updateAssetModelAsync(UpdateAssetModelRequest request) { return updateAssetModelAsync(request, null); } @Override public java.util.concurrent.Future updateAssetModelAsync(final UpdateAssetModelRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAssetModelRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAssetModelResult call() throws Exception { UpdateAssetModelResult result = null; try { result = executeUpdateAssetModel(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 updateAssetPropertyAsync(UpdateAssetPropertyRequest request) { return updateAssetPropertyAsync(request, null); } @Override public java.util.concurrent.Future updateAssetPropertyAsync(final UpdateAssetPropertyRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAssetPropertyRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAssetPropertyResult call() throws Exception { UpdateAssetPropertyResult result = null; try { result = executeUpdateAssetProperty(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 updateDashboardAsync(UpdateDashboardRequest request) { return updateDashboardAsync(request, null); } @Override public java.util.concurrent.Future updateDashboardAsync(final UpdateDashboardRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateDashboardRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateDashboardResult call() throws Exception { UpdateDashboardResult result = null; try { result = executeUpdateDashboard(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 updateGatewayAsync(UpdateGatewayRequest request) { return updateGatewayAsync(request, null); } @Override public java.util.concurrent.Future updateGatewayAsync(final UpdateGatewayRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateGatewayRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateGatewayResult call() throws Exception { UpdateGatewayResult result = null; try { result = executeUpdateGateway(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 updateGatewayCapabilityConfigurationAsync( UpdateGatewayCapabilityConfigurationRequest request) { return updateGatewayCapabilityConfigurationAsync(request, null); } @Override public java.util.concurrent.Future updateGatewayCapabilityConfigurationAsync( final UpdateGatewayCapabilityConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateGatewayCapabilityConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateGatewayCapabilityConfigurationResult call() throws Exception { UpdateGatewayCapabilityConfigurationResult result = null; try { result = executeUpdateGatewayCapabilityConfiguration(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 updatePortalAsync(UpdatePortalRequest request) { return updatePortalAsync(request, null); } @Override public java.util.concurrent.Future updatePortalAsync(final UpdatePortalRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdatePortalRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdatePortalResult call() throws Exception { UpdatePortalResult result = null; try { result = executeUpdatePortal(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 updateProjectAsync(UpdateProjectRequest request) { return updateProjectAsync(request, null); } @Override public java.util.concurrent.Future updateProjectAsync(final UpdateProjectRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateProjectRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateProjectResult call() throws Exception { UpdateProjectResult result = null; try { result = executeUpdateProject(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(); } }