/*
* 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.omics;
import javax.annotation.Generated;
import com.amazonaws.services.omics.model.*;
import com.amazonaws.client.AwsAsyncClientParams;
import com.amazonaws.annotation.ThreadSafe;
import java.util.concurrent.ExecutorService;
/**
* Client for accessing Amazon Omics 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.
*
*
* This is the AWS HealthOmics API Reference. For an introduction to the service, see What is AWS HealthOmics? in the AWS HealthOmics User
* Guide.
*
*/
@ThreadSafe
@Generated("com.amazonaws:aws-java-sdk-code-generator")
public class AmazonOmicsAsyncClient extends AmazonOmicsClient implements AmazonOmicsAsync {
private static final int DEFAULT_THREAD_POOL_SIZE = 50;
private final java.util.concurrent.ExecutorService executorService;
public static AmazonOmicsAsyncClientBuilder asyncBuilder() {
return AmazonOmicsAsyncClientBuilder.standard();
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Omics using the specified parameters.
*
* @param asyncClientParams
* Object providing client parameters.
*/
AmazonOmicsAsyncClient(AwsAsyncClientParams asyncClientParams) {
this(asyncClientParams, false);
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Omics using the specified parameters.
*
* @param asyncClientParams
* Object providing client parameters.
* @param endpointDiscoveryEnabled
* true will enable endpoint discovery if the service supports it.
*/
AmazonOmicsAsyncClient(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 abortMultipartReadSetUploadAsync(AbortMultipartReadSetUploadRequest request) {
return abortMultipartReadSetUploadAsync(request, null);
}
@Override
public java.util.concurrent.Future abortMultipartReadSetUploadAsync(final AbortMultipartReadSetUploadRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final AbortMultipartReadSetUploadRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public AbortMultipartReadSetUploadResult call() throws Exception {
AbortMultipartReadSetUploadResult result = null;
try {
result = executeAbortMultipartReadSetUpload(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 batchDeleteReadSetAsync(BatchDeleteReadSetRequest request) {
return batchDeleteReadSetAsync(request, null);
}
@Override
public java.util.concurrent.Future batchDeleteReadSetAsync(final BatchDeleteReadSetRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final BatchDeleteReadSetRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public BatchDeleteReadSetResult call() throws Exception {
BatchDeleteReadSetResult result = null;
try {
result = executeBatchDeleteReadSet(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 cancelAnnotationImportJobAsync(CancelAnnotationImportJobRequest request) {
return cancelAnnotationImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future cancelAnnotationImportJobAsync(final CancelAnnotationImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CancelAnnotationImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CancelAnnotationImportJobResult call() throws Exception {
CancelAnnotationImportJobResult result = null;
try {
result = executeCancelAnnotationImportJob(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 cancelRunAsync(CancelRunRequest request) {
return cancelRunAsync(request, null);
}
@Override
public java.util.concurrent.Future cancelRunAsync(final CancelRunRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CancelRunRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CancelRunResult call() throws Exception {
CancelRunResult result = null;
try {
result = executeCancelRun(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 cancelVariantImportJobAsync(CancelVariantImportJobRequest request) {
return cancelVariantImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future cancelVariantImportJobAsync(final CancelVariantImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CancelVariantImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CancelVariantImportJobResult call() throws Exception {
CancelVariantImportJobResult result = null;
try {
result = executeCancelVariantImportJob(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 completeMultipartReadSetUploadAsync(CompleteMultipartReadSetUploadRequest request) {
return completeMultipartReadSetUploadAsync(request, null);
}
@Override
public java.util.concurrent.Future completeMultipartReadSetUploadAsync(
final CompleteMultipartReadSetUploadRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CompleteMultipartReadSetUploadRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CompleteMultipartReadSetUploadResult call() throws Exception {
CompleteMultipartReadSetUploadResult result = null;
try {
result = executeCompleteMultipartReadSetUpload(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 createAnnotationStoreAsync(CreateAnnotationStoreRequest request) {
return createAnnotationStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future createAnnotationStoreAsync(final CreateAnnotationStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAnnotationStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAnnotationStoreResult call() throws Exception {
CreateAnnotationStoreResult result = null;
try {
result = executeCreateAnnotationStore(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 createMultipartReadSetUploadAsync(CreateMultipartReadSetUploadRequest request) {
return createMultipartReadSetUploadAsync(request, null);
}
@Override
public java.util.concurrent.Future createMultipartReadSetUploadAsync(final CreateMultipartReadSetUploadRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateMultipartReadSetUploadRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateMultipartReadSetUploadResult call() throws Exception {
CreateMultipartReadSetUploadResult result = null;
try {
result = executeCreateMultipartReadSetUpload(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 createReferenceStoreAsync(CreateReferenceStoreRequest request) {
return createReferenceStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future createReferenceStoreAsync(final CreateReferenceStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateReferenceStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateReferenceStoreResult call() throws Exception {
CreateReferenceStoreResult result = null;
try {
result = executeCreateReferenceStore(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 createRunGroupAsync(CreateRunGroupRequest request) {
return createRunGroupAsync(request, null);
}
@Override
public java.util.concurrent.Future createRunGroupAsync(final CreateRunGroupRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateRunGroupRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateRunGroupResult call() throws Exception {
CreateRunGroupResult result = null;
try {
result = executeCreateRunGroup(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 createSequenceStoreAsync(CreateSequenceStoreRequest request) {
return createSequenceStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future createSequenceStoreAsync(final CreateSequenceStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateSequenceStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateSequenceStoreResult call() throws Exception {
CreateSequenceStoreResult result = null;
try {
result = executeCreateSequenceStore(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 createVariantStoreAsync(CreateVariantStoreRequest request) {
return createVariantStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future createVariantStoreAsync(final CreateVariantStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateVariantStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateVariantStoreResult call() throws Exception {
CreateVariantStoreResult result = null;
try {
result = executeCreateVariantStore(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 createWorkflowAsync(CreateWorkflowRequest request) {
return createWorkflowAsync(request, null);
}
@Override
public java.util.concurrent.Future createWorkflowAsync(final CreateWorkflowRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateWorkflowRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateWorkflowResult call() throws Exception {
CreateWorkflowResult result = null;
try {
result = executeCreateWorkflow(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 deleteAnnotationStoreAsync(DeleteAnnotationStoreRequest request) {
return deleteAnnotationStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteAnnotationStoreAsync(final DeleteAnnotationStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteAnnotationStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteAnnotationStoreResult call() throws Exception {
DeleteAnnotationStoreResult result = null;
try {
result = executeDeleteAnnotationStore(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 deleteReferenceAsync(DeleteReferenceRequest request) {
return deleteReferenceAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteReferenceAsync(final DeleteReferenceRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteReferenceRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteReferenceResult call() throws Exception {
DeleteReferenceResult result = null;
try {
result = executeDeleteReference(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 deleteReferenceStoreAsync(DeleteReferenceStoreRequest request) {
return deleteReferenceStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteReferenceStoreAsync(final DeleteReferenceStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteReferenceStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteReferenceStoreResult call() throws Exception {
DeleteReferenceStoreResult result = null;
try {
result = executeDeleteReferenceStore(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 deleteRunAsync(DeleteRunRequest request) {
return deleteRunAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteRunAsync(final DeleteRunRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteRunRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteRunResult call() throws Exception {
DeleteRunResult result = null;
try {
result = executeDeleteRun(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 deleteRunGroupAsync(DeleteRunGroupRequest request) {
return deleteRunGroupAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteRunGroupAsync(final DeleteRunGroupRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteRunGroupRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteRunGroupResult call() throws Exception {
DeleteRunGroupResult result = null;
try {
result = executeDeleteRunGroup(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 deleteSequenceStoreAsync(DeleteSequenceStoreRequest request) {
return deleteSequenceStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteSequenceStoreAsync(final DeleteSequenceStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteSequenceStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteSequenceStoreResult call() throws Exception {
DeleteSequenceStoreResult result = null;
try {
result = executeDeleteSequenceStore(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 deleteVariantStoreAsync(DeleteVariantStoreRequest request) {
return deleteVariantStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteVariantStoreAsync(final DeleteVariantStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteVariantStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteVariantStoreResult call() throws Exception {
DeleteVariantStoreResult result = null;
try {
result = executeDeleteVariantStore(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 deleteWorkflowAsync(DeleteWorkflowRequest request) {
return deleteWorkflowAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteWorkflowAsync(final DeleteWorkflowRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteWorkflowRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteWorkflowResult call() throws Exception {
DeleteWorkflowResult result = null;
try {
result = executeDeleteWorkflow(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 getAnnotationImportJobAsync(GetAnnotationImportJobRequest request) {
return getAnnotationImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getAnnotationImportJobAsync(final GetAnnotationImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetAnnotationImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetAnnotationImportJobResult call() throws Exception {
GetAnnotationImportJobResult result = null;
try {
result = executeGetAnnotationImportJob(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 getAnnotationStoreAsync(GetAnnotationStoreRequest request) {
return getAnnotationStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future getAnnotationStoreAsync(final GetAnnotationStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetAnnotationStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetAnnotationStoreResult call() throws Exception {
GetAnnotationStoreResult result = null;
try {
result = executeGetAnnotationStore(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 getReadSetAsync(GetReadSetRequest request) {
return getReadSetAsync(request, null);
}
@Override
public java.util.concurrent.Future getReadSetAsync(final GetReadSetRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReadSetRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReadSetResult call() throws Exception {
GetReadSetResult result = null;
try {
result = executeGetReadSet(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 getReadSetActivationJobAsync(GetReadSetActivationJobRequest request) {
return getReadSetActivationJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getReadSetActivationJobAsync(final GetReadSetActivationJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReadSetActivationJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReadSetActivationJobResult call() throws Exception {
GetReadSetActivationJobResult result = null;
try {
result = executeGetReadSetActivationJob(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 getReadSetExportJobAsync(GetReadSetExportJobRequest request) {
return getReadSetExportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getReadSetExportJobAsync(final GetReadSetExportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReadSetExportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReadSetExportJobResult call() throws Exception {
GetReadSetExportJobResult result = null;
try {
result = executeGetReadSetExportJob(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 getReadSetImportJobAsync(GetReadSetImportJobRequest request) {
return getReadSetImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getReadSetImportJobAsync(final GetReadSetImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReadSetImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReadSetImportJobResult call() throws Exception {
GetReadSetImportJobResult result = null;
try {
result = executeGetReadSetImportJob(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 getReadSetMetadataAsync(GetReadSetMetadataRequest request) {
return getReadSetMetadataAsync(request, null);
}
@Override
public java.util.concurrent.Future getReadSetMetadataAsync(final GetReadSetMetadataRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReadSetMetadataRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReadSetMetadataResult call() throws Exception {
GetReadSetMetadataResult result = null;
try {
result = executeGetReadSetMetadata(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 getReferenceAsync(GetReferenceRequest request) {
return getReferenceAsync(request, null);
}
@Override
public java.util.concurrent.Future getReferenceAsync(final GetReferenceRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReferenceRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReferenceResult call() throws Exception {
GetReferenceResult result = null;
try {
result = executeGetReference(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 getReferenceImportJobAsync(GetReferenceImportJobRequest request) {
return getReferenceImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getReferenceImportJobAsync(final GetReferenceImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReferenceImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReferenceImportJobResult call() throws Exception {
GetReferenceImportJobResult result = null;
try {
result = executeGetReferenceImportJob(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 getReferenceMetadataAsync(GetReferenceMetadataRequest request) {
return getReferenceMetadataAsync(request, null);
}
@Override
public java.util.concurrent.Future getReferenceMetadataAsync(final GetReferenceMetadataRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReferenceMetadataRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReferenceMetadataResult call() throws Exception {
GetReferenceMetadataResult result = null;
try {
result = executeGetReferenceMetadata(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 getReferenceStoreAsync(GetReferenceStoreRequest request) {
return getReferenceStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future getReferenceStoreAsync(final GetReferenceStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetReferenceStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetReferenceStoreResult call() throws Exception {
GetReferenceStoreResult result = null;
try {
result = executeGetReferenceStore(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 getRunAsync(GetRunRequest request) {
return getRunAsync(request, null);
}
@Override
public java.util.concurrent.Future getRunAsync(final GetRunRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetRunRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetRunResult call() throws Exception {
GetRunResult result = null;
try {
result = executeGetRun(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 getRunGroupAsync(GetRunGroupRequest request) {
return getRunGroupAsync(request, null);
}
@Override
public java.util.concurrent.Future getRunGroupAsync(final GetRunGroupRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetRunGroupRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetRunGroupResult call() throws Exception {
GetRunGroupResult result = null;
try {
result = executeGetRunGroup(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 getRunTaskAsync(GetRunTaskRequest request) {
return getRunTaskAsync(request, null);
}
@Override
public java.util.concurrent.Future getRunTaskAsync(final GetRunTaskRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetRunTaskRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetRunTaskResult call() throws Exception {
GetRunTaskResult result = null;
try {
result = executeGetRunTask(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 getSequenceStoreAsync(GetSequenceStoreRequest request) {
return getSequenceStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future getSequenceStoreAsync(final GetSequenceStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetSequenceStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetSequenceStoreResult call() throws Exception {
GetSequenceStoreResult result = null;
try {
result = executeGetSequenceStore(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 getVariantImportJobAsync(GetVariantImportJobRequest request) {
return getVariantImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getVariantImportJobAsync(final GetVariantImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetVariantImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetVariantImportJobResult call() throws Exception {
GetVariantImportJobResult result = null;
try {
result = executeGetVariantImportJob(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 getVariantStoreAsync(GetVariantStoreRequest request) {
return getVariantStoreAsync(request, null);
}
@Override
public java.util.concurrent.Future getVariantStoreAsync(final GetVariantStoreRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetVariantStoreRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetVariantStoreResult call() throws Exception {
GetVariantStoreResult result = null;
try {
result = executeGetVariantStore(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 getWorkflowAsync(GetWorkflowRequest request) {
return getWorkflowAsync(request, null);
}
@Override
public java.util.concurrent.Future getWorkflowAsync(final GetWorkflowRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetWorkflowRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetWorkflowResult call() throws Exception {
GetWorkflowResult result = null;
try {
result = executeGetWorkflow(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 listAnnotationImportJobsAsync(ListAnnotationImportJobsRequest request) {
return listAnnotationImportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future listAnnotationImportJobsAsync(final ListAnnotationImportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListAnnotationImportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListAnnotationImportJobsResult call() throws Exception {
ListAnnotationImportJobsResult result = null;
try {
result = executeListAnnotationImportJobs(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 listAnnotationStoresAsync(ListAnnotationStoresRequest request) {
return listAnnotationStoresAsync(request, null);
}
@Override
public java.util.concurrent.Future listAnnotationStoresAsync(final ListAnnotationStoresRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListAnnotationStoresRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListAnnotationStoresResult call() throws Exception {
ListAnnotationStoresResult result = null;
try {
result = executeListAnnotationStores(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 listMultipartReadSetUploadsAsync(ListMultipartReadSetUploadsRequest request) {
return listMultipartReadSetUploadsAsync(request, null);
}
@Override
public java.util.concurrent.Future listMultipartReadSetUploadsAsync(final ListMultipartReadSetUploadsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListMultipartReadSetUploadsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListMultipartReadSetUploadsResult call() throws Exception {
ListMultipartReadSetUploadsResult result = null;
try {
result = executeListMultipartReadSetUploads(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 listReadSetActivationJobsAsync(ListReadSetActivationJobsRequest request) {
return listReadSetActivationJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future listReadSetActivationJobsAsync(final ListReadSetActivationJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReadSetActivationJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReadSetActivationJobsResult call() throws Exception {
ListReadSetActivationJobsResult result = null;
try {
result = executeListReadSetActivationJobs(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 listReadSetExportJobsAsync(ListReadSetExportJobsRequest request) {
return listReadSetExportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future listReadSetExportJobsAsync(final ListReadSetExportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReadSetExportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReadSetExportJobsResult call() throws Exception {
ListReadSetExportJobsResult result = null;
try {
result = executeListReadSetExportJobs(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 listReadSetImportJobsAsync(ListReadSetImportJobsRequest request) {
return listReadSetImportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future listReadSetImportJobsAsync(final ListReadSetImportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReadSetImportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReadSetImportJobsResult call() throws Exception {
ListReadSetImportJobsResult result = null;
try {
result = executeListReadSetImportJobs(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 listReadSetUploadPartsAsync(ListReadSetUploadPartsRequest request) {
return listReadSetUploadPartsAsync(request, null);
}
@Override
public java.util.concurrent.Future listReadSetUploadPartsAsync(final ListReadSetUploadPartsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReadSetUploadPartsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReadSetUploadPartsResult call() throws Exception {
ListReadSetUploadPartsResult result = null;
try {
result = executeListReadSetUploadParts(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 listReadSetsAsync(ListReadSetsRequest request) {
return listReadSetsAsync(request, null);
}
@Override
public java.util.concurrent.Future listReadSetsAsync(final ListReadSetsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReadSetsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReadSetsResult call() throws Exception {
ListReadSetsResult result = null;
try {
result = executeListReadSets(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 listReferenceImportJobsAsync(ListReferenceImportJobsRequest request) {
return listReferenceImportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future listReferenceImportJobsAsync(final ListReferenceImportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReferenceImportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReferenceImportJobsResult call() throws Exception {
ListReferenceImportJobsResult result = null;
try {
result = executeListReferenceImportJobs(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 listReferenceStoresAsync(ListReferenceStoresRequest request) {
return listReferenceStoresAsync(request, null);
}
@Override
public java.util.concurrent.Future listReferenceStoresAsync(final ListReferenceStoresRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReferenceStoresRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReferenceStoresResult call() throws Exception {
ListReferenceStoresResult result = null;
try {
result = executeListReferenceStores(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 listReferencesAsync(ListReferencesRequest request) {
return listReferencesAsync(request, null);
}
@Override
public java.util.concurrent.Future listReferencesAsync(final ListReferencesRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListReferencesRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListReferencesResult call() throws Exception {
ListReferencesResult result = null;
try {
result = executeListReferences(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 listRunGroupsAsync(ListRunGroupsRequest request) {
return listRunGroupsAsync(request, null);
}
@Override
public java.util.concurrent.Future listRunGroupsAsync(final ListRunGroupsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListRunGroupsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListRunGroupsResult call() throws Exception {
ListRunGroupsResult result = null;
try {
result = executeListRunGroups(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 listRunTasksAsync(ListRunTasksRequest request) {
return listRunTasksAsync(request, null);
}
@Override
public java.util.concurrent.Future listRunTasksAsync(final ListRunTasksRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListRunTasksRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListRunTasksResult call() throws Exception {
ListRunTasksResult result = null;
try {
result = executeListRunTasks(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 listRunsAsync(ListRunsRequest request) {
return listRunsAsync(request, null);
}
@Override
public java.util.concurrent.Future listRunsAsync(final ListRunsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListRunsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListRunsResult call() throws Exception {
ListRunsResult result = null;
try {
result = executeListRuns(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 listSequenceStoresAsync(ListSequenceStoresRequest request) {
return listSequenceStoresAsync(request, null);
}
@Override
public java.util.concurrent.Future listSequenceStoresAsync(final ListSequenceStoresRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListSequenceStoresRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListSequenceStoresResult call() throws Exception {
ListSequenceStoresResult result = null;
try {
result = executeListSequenceStores(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 listVariantImportJobsAsync(ListVariantImportJobsRequest request) {
return listVariantImportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future listVariantImportJobsAsync(final ListVariantImportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListVariantImportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListVariantImportJobsResult call() throws Exception {
ListVariantImportJobsResult result = null;
try {
result = executeListVariantImportJobs(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 listVariantStoresAsync(ListVariantStoresRequest request) {
return listVariantStoresAsync(request, null);
}
@Override
public java.util.concurrent.Future listVariantStoresAsync(final ListVariantStoresRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListVariantStoresRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListVariantStoresResult call() throws Exception {
ListVariantStoresResult result = null;
try {
result = executeListVariantStores(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 listWorkflowsAsync(ListWorkflowsRequest request) {
return listWorkflowsAsync(request, null);
}
@Override
public java.util.concurrent.Future listWorkflowsAsync(final ListWorkflowsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final ListWorkflowsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public ListWorkflowsResult call() throws Exception {
ListWorkflowsResult result = null;
try {
result = executeListWorkflows(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 startAnnotationImportJobAsync(StartAnnotationImportJobRequest request) {
return startAnnotationImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future startAnnotationImportJobAsync(final StartAnnotationImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final StartAnnotationImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public StartAnnotationImportJobResult call() throws Exception {
StartAnnotationImportJobResult result = null;
try {
result = executeStartAnnotationImportJob(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 startReadSetActivationJobAsync(StartReadSetActivationJobRequest request) {
return startReadSetActivationJobAsync(request, null);
}
@Override
public java.util.concurrent.Future startReadSetActivationJobAsync(final StartReadSetActivationJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final StartReadSetActivationJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public StartReadSetActivationJobResult call() throws Exception {
StartReadSetActivationJobResult result = null;
try {
result = executeStartReadSetActivationJob(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 startReadSetExportJobAsync(StartReadSetExportJobRequest request) {
return startReadSetExportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future startReadSetExportJobAsync(final StartReadSetExportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final StartReadSetExportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public StartReadSetExportJobResult call() throws Exception {
StartReadSetExportJobResult result = null;
try {
result = executeStartReadSetExportJob(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 startReadSetImportJobAsync(StartReadSetImportJobRequest request) {
return startReadSetImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future startReadSetImportJobAsync(final StartReadSetImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final StartReadSetImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public StartReadSetImportJobResult call() throws Exception {
StartReadSetImportJobResult result = null;
try {
result = executeStartReadSetImportJob(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 startReferenceImportJobAsync(StartReferenceImportJobRequest request) {
return startReferenceImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future startReferenceImportJobAsync(final StartReferenceImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final StartReferenceImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public StartReferenceImportJobResult call() throws Exception {
StartReferenceImportJobResult result = null;
try {
result = executeStartReferenceImportJob(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 startRunAsync(StartRunRequest request) {
return startRunAsync(request, null);
}
@Override
public java.util.concurrent.Future