/* * 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 startRunAsync(final StartRunRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StartRunRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StartRunResult call() throws Exception { StartRunResult result = null; try { result = executeStartRun(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future startVariantImportJobAsync(StartVariantImportJobRequest request) { return startVariantImportJobAsync(request, null); } @Override public java.util.concurrent.Future startVariantImportJobAsync(final StartVariantImportJobRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final StartVariantImportJobRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public StartVariantImportJobResult call() throws Exception { StartVariantImportJobResult result = null; try { result = executeStartVariantImportJob(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future tagResourceAsync(TagResourceRequest request) { return tagResourceAsync(request, null); } @Override public java.util.concurrent.Future tagResourceAsync(final TagResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final TagResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public TagResourceResult call() throws Exception { TagResourceResult result = null; try { result = executeTagResource(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future untagResourceAsync(UntagResourceRequest request) { return untagResourceAsync(request, null); } @Override public java.util.concurrent.Future untagResourceAsync(final UntagResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UntagResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UntagResourceResult call() throws Exception { UntagResourceResult result = null; try { result = executeUntagResource(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateAnnotationStoreAsync(UpdateAnnotationStoreRequest request) { return updateAnnotationStoreAsync(request, null); } @Override public java.util.concurrent.Future updateAnnotationStoreAsync(final UpdateAnnotationStoreRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAnnotationStoreRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAnnotationStoreResult call() throws Exception { UpdateAnnotationStoreResult result = null; try { result = executeUpdateAnnotationStore(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateRunGroupAsync(UpdateRunGroupRequest request) { return updateRunGroupAsync(request, null); } @Override public java.util.concurrent.Future updateRunGroupAsync(final UpdateRunGroupRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateRunGroupRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateRunGroupResult call() throws Exception { UpdateRunGroupResult result = null; try { result = executeUpdateRunGroup(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateVariantStoreAsync(UpdateVariantStoreRequest request) { return updateVariantStoreAsync(request, null); } @Override public java.util.concurrent.Future updateVariantStoreAsync(final UpdateVariantStoreRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateVariantStoreRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateVariantStoreResult call() throws Exception { UpdateVariantStoreResult result = null; try { result = executeUpdateVariantStore(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateWorkflowAsync(UpdateWorkflowRequest request) { return updateWorkflowAsync(request, null); } @Override public java.util.concurrent.Future updateWorkflowAsync(final UpdateWorkflowRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateWorkflowRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateWorkflowResult call() throws Exception { UpdateWorkflowResult result = null; try { result = executeUpdateWorkflow(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future uploadReadSetPartAsync(UploadReadSetPartRequest request) { return uploadReadSetPartAsync(request, null); } @Override public java.util.concurrent.Future uploadReadSetPartAsync(final UploadReadSetPartRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UploadReadSetPartRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UploadReadSetPartResult call() throws Exception { UploadReadSetPartResult result = null; try { result = executeUploadReadSetPart(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } /** * Shuts down the client, releasing all managed resources. This includes forcibly terminating all pending * asynchronous service calls. Clients who wish to give pending asynchronous service calls time to complete should * call {@code getExecutorService().shutdown()} followed by {@code getExecutorService().awaitTermination()} prior to * calling this method. */ @Override public void shutdown() { super.shutdown(); executorService.shutdownNow(); } }