/*
* 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