/*
* 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.pinpoint;
import static java.util.concurrent.Executors.newFixedThreadPool;
import javax.annotation.Generated;
import com.amazonaws.services.pinpoint.model.*;
import com.amazonaws.client.AwsAsyncClientParams;
import com.amazonaws.annotation.ThreadSafe;
import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.AWSCredentialsProvider;
import java.util.concurrent.ExecutorService;
import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;
/**
* Client for accessing Amazon Pinpoint 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.
*
*
* Doc Engage API - Amazon Pinpoint API
*
*/
@ThreadSafe
@Generated("com.amazonaws:aws-java-sdk-code-generator")
public class AmazonPinpointAsyncClient extends AmazonPinpointClient implements AmazonPinpointAsync {
private static final int DEFAULT_THREAD_POOL_SIZE = 50;
private final java.util.concurrent.ExecutorService executorService;
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint. A credentials provider chain
* will be used that searches for credentials in this order:
*
* - Environment Variables - AWS_ACCESS_KEY_ID and AWS_SECRET_KEY
* - Java System Properties - aws.accessKeyId and aws.secretKey
* - Credential profiles file at the default location (~/.aws/credentials) shared by all AWS SDKs and the AWS CLI
* - Instance profile credentials delivered through the Amazon EC2 metadata service
*
*
* Asynchronous methods are delegated to a fixed-size thread pool containing 50 threads (to match the default
* maximum number of concurrent connections to the service).
*
* @see com.amazonaws.auth.DefaultAWSCredentialsProviderChain
* @see java.util.concurrent.Executors#newFixedThreadPool(int)
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#defaultClient()}
*/
@Deprecated
public AmazonPinpointAsyncClient() {
this(DefaultAWSCredentialsProviderChain.getInstance());
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint. A credentials provider chain
* will be used that searches for credentials in this order:
*
* - Environment Variables - AWS_ACCESS_KEY_ID and AWS_SECRET_KEY
* - Java System Properties - aws.accessKeyId and aws.secretKey
* - Credential profiles file at the default location (~/.aws/credentials) shared by all AWS SDKs and the AWS CLI
* - Instance profile credentials delivered through the Amazon EC2 metadata service
*
*
* Asynchronous methods are delegated to a fixed-size thread pool containing a number of threads equal to the
* maximum number of concurrent connections configured via {@code ClientConfiguration.getMaxConnections()}.
*
* @param clientConfiguration
* The client configuration options controlling how this client connects to Amazon Pinpoint (ex: proxy
* settings, retry counts, etc).
*
* @see com.amazonaws.auth.DefaultAWSCredentialsProviderChain
* @see java.util.concurrent.Executors#newFixedThreadPool(int)
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withClientConfiguration(ClientConfiguration)}
*/
@Deprecated
public AmazonPinpointAsyncClient(ClientConfiguration clientConfiguration) {
this(DefaultAWSCredentialsProviderChain.getInstance(), clientConfiguration, newFixedThreadPool(clientConfiguration.getMaxConnections()));
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified AWS account
* credentials.
*
* Asynchronous methods are delegated to a fixed-size thread pool containing 50 threads (to match the default
* maximum number of concurrent connections to the service).
*
* @param awsCredentials
* The AWS credentials (access key ID and secret key) to use when authenticating with AWS services.
* @see java.util.concurrent.Executors#newFixedThreadPool(int)
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentials awsCredentials) {
this(awsCredentials, newFixedThreadPool(DEFAULT_THREAD_POOL_SIZE));
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified AWS account
* credentials and executor service. Default client settings will be used.
*
* @param awsCredentials
* The AWS credentials (access key ID and secret key) to use when authenticating with AWS services.
* @param executorService
* The executor service by which all asynchronous requests will be executed.
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and
* {@link AmazonPinpointAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentials awsCredentials, ExecutorService executorService) {
this(awsCredentials, configFactory.getConfig(), executorService);
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified AWS account
* credentials, executor service, and client configuration options.
*
* @param awsCredentials
* The AWS credentials (access key ID and secret key) to use when authenticating with AWS services.
* @param clientConfiguration
* Client configuration options (ex: max retry limit, proxy settings, etc).
* @param executorService
* The executor service by which all asynchronous requests will be executed.
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and
* {@link AmazonPinpointAsyncClientBuilder#withClientConfiguration(ClientConfiguration)} and
* {@link AmazonPinpointAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentials awsCredentials, ClientConfiguration clientConfiguration, ExecutorService executorService) {
super(awsCredentials, clientConfiguration);
this.executorService = executorService;
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified AWS account
* credentials provider. Default client settings will be used.
*
* Asynchronous methods are delegated to a fixed-size thread pool containing 50 threads (to match the default
* maximum number of concurrent connections to the service).
*
* @param awsCredentialsProvider
* The AWS credentials provider which will provide credentials to authenticate requests with AWS services.
* @see java.util.concurrent.Executors#newFixedThreadPool(int)
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentialsProvider awsCredentialsProvider) {
this(awsCredentialsProvider, newFixedThreadPool(DEFAULT_THREAD_POOL_SIZE));
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the provided AWS account
* credentials provider and client configuration options.
*
* Asynchronous methods are delegated to a fixed-size thread pool containing a number of threads equal to the
* maximum number of concurrent connections configured via {@code ClientConfiguration.getMaxConnections()}.
*
* @param awsCredentialsProvider
* The AWS credentials provider which will provide credentials to authenticate requests with AWS services.
* @param clientConfiguration
* Client configuration options (ex: max retry limit, proxy settings, etc).
*
* @see com.amazonaws.auth.DefaultAWSCredentialsProviderChain
* @see java.util.concurrent.Executors#newFixedThreadPool(int)
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and
* {@link AmazonPinpointAsyncClientBuilder#withClientConfiguration(ClientConfiguration)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentialsProvider awsCredentialsProvider, ClientConfiguration clientConfiguration) {
this(awsCredentialsProvider, clientConfiguration, newFixedThreadPool(clientConfiguration.getMaxConnections()));
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified AWS account
* credentials provider and executor service. Default client settings will be used.
*
* @param awsCredentialsProvider
* The AWS credentials provider which will provide credentials to authenticate requests with AWS services.
* @param executorService
* The executor service by which all asynchronous requests will be executed.
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and
* {@link AmazonPinpointAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentialsProvider awsCredentialsProvider, ExecutorService executorService) {
this(awsCredentialsProvider, configFactory.getConfig(), executorService);
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified AWS account
* credentials provider, executor service, and client configuration options.
*
* @param awsCredentialsProvider
* The AWS credentials provider which will provide credentials to authenticate requests with AWS services.
* @param clientConfiguration
* Client configuration options (ex: max retry limit, proxy settings, etc).
* @param executorService
* The executor service by which all asynchronous requests will be executed.
* @deprecated use {@link AmazonPinpointAsyncClientBuilder#withCredentials(AWSCredentialsProvider)} and
* {@link AmazonPinpointAsyncClientBuilder#withClientConfiguration(ClientConfiguration)} and
* {@link AmazonPinpointAsyncClientBuilder#withExecutorFactory(com.amazonaws.client.builder.ExecutorFactory)}
*/
@Deprecated
public AmazonPinpointAsyncClient(AWSCredentialsProvider awsCredentialsProvider, ClientConfiguration clientConfiguration, ExecutorService executorService) {
super(awsCredentialsProvider, clientConfiguration);
this.executorService = executorService;
}
public static AmazonPinpointAsyncClientBuilder asyncBuilder() {
return AmazonPinpointAsyncClientBuilder.standard();
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified parameters.
*
* @param asyncClientParams
* Object providing client parameters.
*/
AmazonPinpointAsyncClient(AwsAsyncClientParams asyncClientParams) {
this(asyncClientParams, false);
}
/**
* Constructs a new asynchronous client to invoke service methods on Amazon Pinpoint using the specified parameters.
*
* @param asyncClientParams
* Object providing client parameters.
* @param endpointDiscoveryEnabled
* true will enable endpoint discovery if the service supports it.
*/
AmazonPinpointAsyncClient(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 createAppAsync(CreateAppRequest request) {
return createAppAsync(request, null);
}
@Override
public java.util.concurrent.Future createAppAsync(final CreateAppRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAppRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAppResult call() throws Exception {
CreateAppResult result = null;
try {
result = executeCreateApp(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createCampaignAsync(CreateCampaignRequest request) {
return createCampaignAsync(request, null);
}
@Override
public java.util.concurrent.Future createCampaignAsync(final CreateCampaignRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateCampaignRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateCampaignResult call() throws Exception {
CreateCampaignResult result = null;
try {
result = executeCreateCampaign(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createEmailTemplateAsync(CreateEmailTemplateRequest request) {
return createEmailTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future createEmailTemplateAsync(final CreateEmailTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateEmailTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateEmailTemplateResult call() throws Exception {
CreateEmailTemplateResult result = null;
try {
result = executeCreateEmailTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createExportJobAsync(CreateExportJobRequest request) {
return createExportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createExportJobAsync(final CreateExportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateExportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateExportJobResult call() throws Exception {
CreateExportJobResult result = null;
try {
result = executeCreateExportJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createImportJobAsync(CreateImportJobRequest request) {
return createImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createImportJobAsync(final CreateImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateImportJobResult call() throws Exception {
CreateImportJobResult result = null;
try {
result = executeCreateImportJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createInAppTemplateAsync(CreateInAppTemplateRequest request) {
return createInAppTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future createInAppTemplateAsync(final CreateInAppTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateInAppTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateInAppTemplateResult call() throws Exception {
CreateInAppTemplateResult result = null;
try {
result = executeCreateInAppTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createJourneyAsync(CreateJourneyRequest request) {
return createJourneyAsync(request, null);
}
@Override
public java.util.concurrent.Future createJourneyAsync(final CreateJourneyRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateJourneyRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateJourneyResult call() throws Exception {
CreateJourneyResult result = null;
try {
result = executeCreateJourney(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createPushTemplateAsync(CreatePushTemplateRequest request) {
return createPushTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future createPushTemplateAsync(final CreatePushTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreatePushTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreatePushTemplateResult call() throws Exception {
CreatePushTemplateResult result = null;
try {
result = executeCreatePushTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createRecommenderConfigurationAsync(CreateRecommenderConfigurationRequest request) {
return createRecommenderConfigurationAsync(request, null);
}
@Override
public java.util.concurrent.Future createRecommenderConfigurationAsync(
final CreateRecommenderConfigurationRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateRecommenderConfigurationRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateRecommenderConfigurationResult call() throws Exception {
CreateRecommenderConfigurationResult result = null;
try {
result = executeCreateRecommenderConfiguration(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createSegmentAsync(CreateSegmentRequest request) {
return createSegmentAsync(request, null);
}
@Override
public java.util.concurrent.Future createSegmentAsync(final CreateSegmentRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateSegmentRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateSegmentResult call() throws Exception {
CreateSegmentResult result = null;
try {
result = executeCreateSegment(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createSmsTemplateAsync(CreateSmsTemplateRequest request) {
return createSmsTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future createSmsTemplateAsync(final CreateSmsTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateSmsTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateSmsTemplateResult call() throws Exception {
CreateSmsTemplateResult result = null;
try {
result = executeCreateSmsTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createVoiceTemplateAsync(CreateVoiceTemplateRequest request) {
return createVoiceTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future createVoiceTemplateAsync(final CreateVoiceTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateVoiceTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateVoiceTemplateResult call() throws Exception {
CreateVoiceTemplateResult result = null;
try {
result = executeCreateVoiceTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteAdmChannelAsync(DeleteAdmChannelRequest request) {
return deleteAdmChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteAdmChannelAsync(final DeleteAdmChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteAdmChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteAdmChannelResult call() throws Exception {
DeleteAdmChannelResult result = null;
try {
result = executeDeleteAdmChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteApnsChannelAsync(DeleteApnsChannelRequest request) {
return deleteApnsChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteApnsChannelAsync(final DeleteApnsChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteApnsChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteApnsChannelResult call() throws Exception {
DeleteApnsChannelResult result = null;
try {
result = executeDeleteApnsChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteApnsSandboxChannelAsync(DeleteApnsSandboxChannelRequest request) {
return deleteApnsSandboxChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteApnsSandboxChannelAsync(final DeleteApnsSandboxChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteApnsSandboxChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteApnsSandboxChannelResult call() throws Exception {
DeleteApnsSandboxChannelResult result = null;
try {
result = executeDeleteApnsSandboxChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteApnsVoipChannelAsync(DeleteApnsVoipChannelRequest request) {
return deleteApnsVoipChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteApnsVoipChannelAsync(final DeleteApnsVoipChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteApnsVoipChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteApnsVoipChannelResult call() throws Exception {
DeleteApnsVoipChannelResult result = null;
try {
result = executeDeleteApnsVoipChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteApnsVoipSandboxChannelAsync(DeleteApnsVoipSandboxChannelRequest request) {
return deleteApnsVoipSandboxChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteApnsVoipSandboxChannelAsync(final DeleteApnsVoipSandboxChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteApnsVoipSandboxChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteApnsVoipSandboxChannelResult call() throws Exception {
DeleteApnsVoipSandboxChannelResult result = null;
try {
result = executeDeleteApnsVoipSandboxChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteAppAsync(DeleteAppRequest request) {
return deleteAppAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteAppAsync(final DeleteAppRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteAppRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteAppResult call() throws Exception {
DeleteAppResult result = null;
try {
result = executeDeleteApp(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteBaiduChannelAsync(DeleteBaiduChannelRequest request) {
return deleteBaiduChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteBaiduChannelAsync(final DeleteBaiduChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteBaiduChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteBaiduChannelResult call() throws Exception {
DeleteBaiduChannelResult result = null;
try {
result = executeDeleteBaiduChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteCampaignAsync(DeleteCampaignRequest request) {
return deleteCampaignAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteCampaignAsync(final DeleteCampaignRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteCampaignRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteCampaignResult call() throws Exception {
DeleteCampaignResult result = null;
try {
result = executeDeleteCampaign(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteEmailChannelAsync(DeleteEmailChannelRequest request) {
return deleteEmailChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteEmailChannelAsync(final DeleteEmailChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteEmailChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteEmailChannelResult call() throws Exception {
DeleteEmailChannelResult result = null;
try {
result = executeDeleteEmailChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteEmailTemplateAsync(DeleteEmailTemplateRequest request) {
return deleteEmailTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteEmailTemplateAsync(final DeleteEmailTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteEmailTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteEmailTemplateResult call() throws Exception {
DeleteEmailTemplateResult result = null;
try {
result = executeDeleteEmailTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteEndpointAsync(DeleteEndpointRequest request) {
return deleteEndpointAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteEndpointAsync(final DeleteEndpointRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteEndpointRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteEndpointResult call() throws Exception {
DeleteEndpointResult result = null;
try {
result = executeDeleteEndpoint(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteEventStreamAsync(DeleteEventStreamRequest request) {
return deleteEventStreamAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteEventStreamAsync(final DeleteEventStreamRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteEventStreamRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteEventStreamResult call() throws Exception {
DeleteEventStreamResult result = null;
try {
result = executeDeleteEventStream(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteGcmChannelAsync(DeleteGcmChannelRequest request) {
return deleteGcmChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteGcmChannelAsync(final DeleteGcmChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteGcmChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteGcmChannelResult call() throws Exception {
DeleteGcmChannelResult result = null;
try {
result = executeDeleteGcmChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteInAppTemplateAsync(DeleteInAppTemplateRequest request) {
return deleteInAppTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteInAppTemplateAsync(final DeleteInAppTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteInAppTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteInAppTemplateResult call() throws Exception {
DeleteInAppTemplateResult result = null;
try {
result = executeDeleteInAppTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteJourneyAsync(DeleteJourneyRequest request) {
return deleteJourneyAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteJourneyAsync(final DeleteJourneyRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteJourneyRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteJourneyResult call() throws Exception {
DeleteJourneyResult result = null;
try {
result = executeDeleteJourney(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deletePushTemplateAsync(DeletePushTemplateRequest request) {
return deletePushTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future deletePushTemplateAsync(final DeletePushTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeletePushTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeletePushTemplateResult call() throws Exception {
DeletePushTemplateResult result = null;
try {
result = executeDeletePushTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteRecommenderConfigurationAsync(DeleteRecommenderConfigurationRequest request) {
return deleteRecommenderConfigurationAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteRecommenderConfigurationAsync(
final DeleteRecommenderConfigurationRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteRecommenderConfigurationRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteRecommenderConfigurationResult call() throws Exception {
DeleteRecommenderConfigurationResult result = null;
try {
result = executeDeleteRecommenderConfiguration(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteSegmentAsync(DeleteSegmentRequest request) {
return deleteSegmentAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteSegmentAsync(final DeleteSegmentRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteSegmentRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteSegmentResult call() throws Exception {
DeleteSegmentResult result = null;
try {
result = executeDeleteSegment(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteSmsChannelAsync(DeleteSmsChannelRequest request) {
return deleteSmsChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteSmsChannelAsync(final DeleteSmsChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteSmsChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteSmsChannelResult call() throws Exception {
DeleteSmsChannelResult result = null;
try {
result = executeDeleteSmsChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteSmsTemplateAsync(DeleteSmsTemplateRequest request) {
return deleteSmsTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteSmsTemplateAsync(final DeleteSmsTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteSmsTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteSmsTemplateResult call() throws Exception {
DeleteSmsTemplateResult result = null;
try {
result = executeDeleteSmsTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteUserEndpointsAsync(DeleteUserEndpointsRequest request) {
return deleteUserEndpointsAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteUserEndpointsAsync(final DeleteUserEndpointsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteUserEndpointsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteUserEndpointsResult call() throws Exception {
DeleteUserEndpointsResult result = null;
try {
result = executeDeleteUserEndpoints(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteVoiceChannelAsync(DeleteVoiceChannelRequest request) {
return deleteVoiceChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteVoiceChannelAsync(final DeleteVoiceChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteVoiceChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteVoiceChannelResult call() throws Exception {
DeleteVoiceChannelResult result = null;
try {
result = executeDeleteVoiceChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteVoiceTemplateAsync(DeleteVoiceTemplateRequest request) {
return deleteVoiceTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteVoiceTemplateAsync(final DeleteVoiceTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteVoiceTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteVoiceTemplateResult call() throws Exception {
DeleteVoiceTemplateResult result = null;
try {
result = executeDeleteVoiceTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getAdmChannelAsync(GetAdmChannelRequest request) {
return getAdmChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getAdmChannelAsync(final GetAdmChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetAdmChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetAdmChannelResult call() throws Exception {
GetAdmChannelResult result = null;
try {
result = executeGetAdmChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getApnsChannelAsync(GetApnsChannelRequest request) {
return getApnsChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getApnsChannelAsync(final GetApnsChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetApnsChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetApnsChannelResult call() throws Exception {
GetApnsChannelResult result = null;
try {
result = executeGetApnsChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getApnsSandboxChannelAsync(GetApnsSandboxChannelRequest request) {
return getApnsSandboxChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getApnsSandboxChannelAsync(final GetApnsSandboxChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetApnsSandboxChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetApnsSandboxChannelResult call() throws Exception {
GetApnsSandboxChannelResult result = null;
try {
result = executeGetApnsSandboxChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getApnsVoipChannelAsync(GetApnsVoipChannelRequest request) {
return getApnsVoipChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getApnsVoipChannelAsync(final GetApnsVoipChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetApnsVoipChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetApnsVoipChannelResult call() throws Exception {
GetApnsVoipChannelResult result = null;
try {
result = executeGetApnsVoipChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getApnsVoipSandboxChannelAsync(GetApnsVoipSandboxChannelRequest request) {
return getApnsVoipSandboxChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getApnsVoipSandboxChannelAsync(final GetApnsVoipSandboxChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetApnsVoipSandboxChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetApnsVoipSandboxChannelResult call() throws Exception {
GetApnsVoipSandboxChannelResult result = null;
try {
result = executeGetApnsVoipSandboxChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getAppAsync(GetAppRequest request) {
return getAppAsync(request, null);
}
@Override
public java.util.concurrent.Future getAppAsync(final GetAppRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetAppRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetAppResult call() throws Exception {
GetAppResult result = null;
try {
result = executeGetApp(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getApplicationDateRangeKpiAsync(GetApplicationDateRangeKpiRequest request) {
return getApplicationDateRangeKpiAsync(request, null);
}
@Override
public java.util.concurrent.Future getApplicationDateRangeKpiAsync(final GetApplicationDateRangeKpiRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetApplicationDateRangeKpiRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetApplicationDateRangeKpiResult call() throws Exception {
GetApplicationDateRangeKpiResult result = null;
try {
result = executeGetApplicationDateRangeKpi(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getApplicationSettingsAsync(GetApplicationSettingsRequest request) {
return getApplicationSettingsAsync(request, null);
}
@Override
public java.util.concurrent.Future getApplicationSettingsAsync(final GetApplicationSettingsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetApplicationSettingsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetApplicationSettingsResult call() throws Exception {
GetApplicationSettingsResult result = null;
try {
result = executeGetApplicationSettings(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getAppsAsync(GetAppsRequest request) {
return getAppsAsync(request, null);
}
@Override
public java.util.concurrent.Future getAppsAsync(final GetAppsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetAppsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetAppsResult call() throws Exception {
GetAppsResult result = null;
try {
result = executeGetApps(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getBaiduChannelAsync(GetBaiduChannelRequest request) {
return getBaiduChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getBaiduChannelAsync(final GetBaiduChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetBaiduChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetBaiduChannelResult call() throws Exception {
GetBaiduChannelResult result = null;
try {
result = executeGetBaiduChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getCampaignAsync(GetCampaignRequest request) {
return getCampaignAsync(request, null);
}
@Override
public java.util.concurrent.Future getCampaignAsync(final GetCampaignRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetCampaignRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetCampaignResult call() throws Exception {
GetCampaignResult result = null;
try {
result = executeGetCampaign(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getCampaignActivitiesAsync(GetCampaignActivitiesRequest request) {
return getCampaignActivitiesAsync(request, null);
}
@Override
public java.util.concurrent.Future getCampaignActivitiesAsync(final GetCampaignActivitiesRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetCampaignActivitiesRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetCampaignActivitiesResult call() throws Exception {
GetCampaignActivitiesResult result = null;
try {
result = executeGetCampaignActivities(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getCampaignDateRangeKpiAsync(GetCampaignDateRangeKpiRequest request) {
return getCampaignDateRangeKpiAsync(request, null);
}
@Override
public java.util.concurrent.Future getCampaignDateRangeKpiAsync(final GetCampaignDateRangeKpiRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetCampaignDateRangeKpiRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetCampaignDateRangeKpiResult call() throws Exception {
GetCampaignDateRangeKpiResult result = null;
try {
result = executeGetCampaignDateRangeKpi(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getCampaignVersionAsync(GetCampaignVersionRequest request) {
return getCampaignVersionAsync(request, null);
}
@Override
public java.util.concurrent.Future getCampaignVersionAsync(final GetCampaignVersionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetCampaignVersionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetCampaignVersionResult call() throws Exception {
GetCampaignVersionResult result = null;
try {
result = executeGetCampaignVersion(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getCampaignVersionsAsync(GetCampaignVersionsRequest request) {
return getCampaignVersionsAsync(request, null);
}
@Override
public java.util.concurrent.Future getCampaignVersionsAsync(final GetCampaignVersionsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetCampaignVersionsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetCampaignVersionsResult call() throws Exception {
GetCampaignVersionsResult result = null;
try {
result = executeGetCampaignVersions(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getCampaignsAsync(GetCampaignsRequest request) {
return getCampaignsAsync(request, null);
}
@Override
public java.util.concurrent.Future getCampaignsAsync(final GetCampaignsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetCampaignsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetCampaignsResult call() throws Exception {
GetCampaignsResult result = null;
try {
result = executeGetCampaigns(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getChannelsAsync(GetChannelsRequest request) {
return getChannelsAsync(request, null);
}
@Override
public java.util.concurrent.Future getChannelsAsync(final GetChannelsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetChannelsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetChannelsResult call() throws Exception {
GetChannelsResult result = null;
try {
result = executeGetChannels(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getEmailChannelAsync(GetEmailChannelRequest request) {
return getEmailChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getEmailChannelAsync(final GetEmailChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetEmailChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetEmailChannelResult call() throws Exception {
GetEmailChannelResult result = null;
try {
result = executeGetEmailChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getEmailTemplateAsync(GetEmailTemplateRequest request) {
return getEmailTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future getEmailTemplateAsync(final GetEmailTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetEmailTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetEmailTemplateResult call() throws Exception {
GetEmailTemplateResult result = null;
try {
result = executeGetEmailTemplate(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getEndpointAsync(GetEndpointRequest request) {
return getEndpointAsync(request, null);
}
@Override
public java.util.concurrent.Future getEndpointAsync(final GetEndpointRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetEndpointRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetEndpointResult call() throws Exception {
GetEndpointResult result = null;
try {
result = executeGetEndpoint(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getEventStreamAsync(GetEventStreamRequest request) {
return getEventStreamAsync(request, null);
}
@Override
public java.util.concurrent.Future getEventStreamAsync(final GetEventStreamRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetEventStreamRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetEventStreamResult call() throws Exception {
GetEventStreamResult result = null;
try {
result = executeGetEventStream(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getExportJobAsync(GetExportJobRequest request) {
return getExportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getExportJobAsync(final GetExportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetExportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetExportJobResult call() throws Exception {
GetExportJobResult result = null;
try {
result = executeGetExportJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getExportJobsAsync(GetExportJobsRequest request) {
return getExportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future getExportJobsAsync(final GetExportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetExportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetExportJobsResult call() throws Exception {
GetExportJobsResult result = null;
try {
result = executeGetExportJobs(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getGcmChannelAsync(GetGcmChannelRequest request) {
return getGcmChannelAsync(request, null);
}
@Override
public java.util.concurrent.Future getGcmChannelAsync(final GetGcmChannelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetGcmChannelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetGcmChannelResult call() throws Exception {
GetGcmChannelResult result = null;
try {
result = executeGetGcmChannel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getImportJobAsync(GetImportJobRequest request) {
return getImportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future getImportJobAsync(final GetImportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetImportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetImportJobResult call() throws Exception {
GetImportJobResult result = null;
try {
result = executeGetImportJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getImportJobsAsync(GetImportJobsRequest request) {
return getImportJobsAsync(request, null);
}
@Override
public java.util.concurrent.Future getImportJobsAsync(final GetImportJobsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetImportJobsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetImportJobsResult call() throws Exception {
GetImportJobsResult result = null;
try {
result = executeGetImportJobs(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getInAppMessagesAsync(GetInAppMessagesRequest request) {
return getInAppMessagesAsync(request, null);
}
@Override
public java.util.concurrent.Future getInAppMessagesAsync(final GetInAppMessagesRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetInAppMessagesRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public GetInAppMessagesResult call() throws Exception {
GetInAppMessagesResult result = null;
try {
result = executeGetInAppMessages(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future getInAppTemplateAsync(GetInAppTemplateRequest request) {
return getInAppTemplateAsync(request, null);
}
@Override
public java.util.concurrent.Future getInAppTemplateAsync(final GetInAppTemplateRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final GetInAppTemplateRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable