/* * 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.appintegrations; import org.w3c.dom.*; import java.net.*; import java.util.*; import javax.annotation.Generated; import org.apache.commons.logging.*; import com.amazonaws.*; import com.amazonaws.annotation.SdkInternalApi; import com.amazonaws.auth.*; import com.amazonaws.handlers.*; import com.amazonaws.http.*; import com.amazonaws.internal.*; import com.amazonaws.internal.auth.*; import com.amazonaws.metrics.*; import com.amazonaws.regions.*; import com.amazonaws.transform.*; import com.amazonaws.util.*; import com.amazonaws.protocol.json.*; import com.amazonaws.util.AWSRequestMetrics.Field; import com.amazonaws.annotation.ThreadSafe; import com.amazonaws.client.AwsSyncClientParams; import com.amazonaws.client.builder.AdvancedConfig; import com.amazonaws.services.appintegrations.AmazonAppIntegrationsClientBuilder; import com.amazonaws.AmazonServiceException; import com.amazonaws.services.appintegrations.model.*; import com.amazonaws.services.appintegrations.model.transform.*; /** * Client for accessing Amazon AppIntegrations Service. All service calls made using this client are blocking, and will * not return until the service call completes. *

*

* The Amazon AppIntegrations service enables you to configure and reuse connections to external applications. *

*

* For information about how you can use external applications with Amazon Connect, see Set up pre-built integrations and Deliver information to agents * using Amazon Connect Wisdom in the Amazon Connect Administrator Guide. *

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AmazonAppIntegrationsClient extends AmazonWebServiceClient implements AmazonAppIntegrations { /** Provider for AWS credentials. */ private final AWSCredentialsProvider awsCredentialsProvider; private static final Log log = LogFactory.getLog(AmazonAppIntegrations.class); /** Default signing name for the service. */ private static final String DEFAULT_SIGNING_NAME = "app-integrations"; /** Client configuration factory providing ClientConfigurations tailored to this client */ protected static final ClientConfigurationFactory configFactory = new ClientConfigurationFactory(); private final AdvancedConfig advancedConfig; private static final com.amazonaws.protocol.json.SdkJsonProtocolFactory protocolFactory = new com.amazonaws.protocol.json.SdkJsonProtocolFactory( new JsonClientMetadata() .withProtocolVersion("1.1") .withSupportsCbor(false) .withSupportsIon(false) .withContentTypeOverride("application/json") .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("AccessDeniedException").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.AccessDeniedExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("InternalServiceError").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.InternalServiceErrorExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("InvalidRequestException").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.InvalidRequestExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ResourceNotFoundException").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.ResourceNotFoundExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("DuplicateResourceException").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.DuplicateResourceExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ResourceQuotaExceededException").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.ResourceQuotaExceededExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ThrottlingException").withExceptionUnmarshaller( com.amazonaws.services.appintegrations.model.transform.ThrottlingExceptionUnmarshaller.getInstance())) .withBaseServiceExceptionClass(com.amazonaws.services.appintegrations.model.AmazonAppIntegrationsException.class)); public static AmazonAppIntegrationsClientBuilder builder() { return AmazonAppIntegrationsClientBuilder.standard(); } /** * Constructs a new client to invoke service methods on Amazon AppIntegrations Service using the specified * parameters. * *

* All service calls made using this new client object are blocking, and will not return until the service call * completes. * * @param clientParams * Object providing client parameters. */ AmazonAppIntegrationsClient(AwsSyncClientParams clientParams) { this(clientParams, false); } /** * Constructs a new client to invoke service methods on Amazon AppIntegrations Service using the specified * parameters. * *

* All service calls made using this new client object are blocking, and will not return until the service call * completes. * * @param clientParams * Object providing client parameters. */ AmazonAppIntegrationsClient(AwsSyncClientParams clientParams, boolean endpointDiscoveryEnabled) { super(clientParams); this.awsCredentialsProvider = clientParams.getCredentialsProvider(); this.advancedConfig = clientParams.getAdvancedConfig(); init(); } private void init() { setServiceNameIntern(DEFAULT_SIGNING_NAME); setEndpointPrefix(ENDPOINT_PREFIX); // calling this.setEndPoint(...) will also modify the signer accordingly setEndpoint("app-integrations.us-east-1.amazonaws.com"); HandlerChainFactory chainFactory = new HandlerChainFactory(); requestHandler2s.addAll(chainFactory.newRequestHandlerChain("/com/amazonaws/services/appintegrations/request.handlers")); requestHandler2s.addAll(chainFactory.newRequestHandler2Chain("/com/amazonaws/services/appintegrations/request.handler2s")); requestHandler2s.addAll(chainFactory.getGlobalHandlers()); } /** *

* Creates and persists a DataIntegration resource. *

* *

* You cannot create a DataIntegration association for a DataIntegration that has been previously associated. Use a * different DataIntegration, or recreate the DataIntegration using the CreateDataIntegration API. *

*
* * @param createDataIntegrationRequest * @return Result of the CreateDataIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ResourceQuotaExceededException * The allowed quota for the resource has been exceeded. * @throws DuplicateResourceException * A resource with the specified name already exists. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.CreateDataIntegration * @see AWS API Documentation */ @Override public CreateDataIntegrationResult createDataIntegration(CreateDataIntegrationRequest request) { request = beforeClientExecution(request); return executeCreateDataIntegration(request); } @SdkInternalApi final CreateDataIntegrationResult executeCreateDataIntegration(CreateDataIntegrationRequest createDataIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(createDataIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new CreateDataIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(createDataIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateDataIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory .createResponseHandler(new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new CreateDataIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Creates an EventIntegration, given a specified name, description, and a reference to an Amazon EventBridge bus in * your account and a partner event source that pushes events to that bus. No objects are created in the your * account, only metadata that is persisted on the EventIntegration control plane. *

* * @param createEventIntegrationRequest * @return Result of the CreateEventIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ResourceQuotaExceededException * The allowed quota for the resource has been exceeded. * @throws DuplicateResourceException * A resource with the specified name already exists. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.CreateEventIntegration * @see AWS API Documentation */ @Override public CreateEventIntegrationResult createEventIntegration(CreateEventIntegrationRequest request) { request = beforeClientExecution(request); return executeCreateEventIntegration(request); } @SdkInternalApi final CreateEventIntegrationResult executeCreateEventIntegration(CreateEventIntegrationRequest createEventIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(createEventIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new CreateEventIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(createEventIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateEventIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new CreateEventIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Deletes the DataIntegration. Only DataIntegrations that don't have any DataIntegrationAssociations can be * deleted. Deleting a DataIntegration also deletes the underlying Amazon AppFlow flow and service linked role. *

* *

* You cannot create a DataIntegration association for a DataIntegration that has been previously associated. Use a * different DataIntegration, or recreate the DataIntegration using the CreateDataIntegration API. *

*
* * @param deleteDataIntegrationRequest * @return Result of the DeleteDataIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.DeleteDataIntegration * @see AWS API Documentation */ @Override public DeleteDataIntegrationResult deleteDataIntegration(DeleteDataIntegrationRequest request) { request = beforeClientExecution(request); return executeDeleteDataIntegration(request); } @SdkInternalApi final DeleteDataIntegrationResult executeDeleteDataIntegration(DeleteDataIntegrationRequest deleteDataIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(deleteDataIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new DeleteDataIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(deleteDataIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DeleteDataIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory .createResponseHandler(new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new DeleteDataIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Deletes the specified existing event integration. If the event integration is associated with clients, the * request is rejected. *

* * @param deleteEventIntegrationRequest * @return Result of the DeleteEventIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.DeleteEventIntegration * @see AWS API Documentation */ @Override public DeleteEventIntegrationResult deleteEventIntegration(DeleteEventIntegrationRequest request) { request = beforeClientExecution(request); return executeDeleteEventIntegration(request); } @SdkInternalApi final DeleteEventIntegrationResult executeDeleteEventIntegration(DeleteEventIntegrationRequest deleteEventIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(deleteEventIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new DeleteEventIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(deleteEventIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DeleteEventIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new DeleteEventIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Returns information about the DataIntegration. *

* *

* You cannot create a DataIntegration association for a DataIntegration that has been previously associated. Use a * different DataIntegration, or recreate the DataIntegration using the CreateDataIntegration API. *

*
* * @param getDataIntegrationRequest * @return Result of the GetDataIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.GetDataIntegration * @see AWS API Documentation */ @Override public GetDataIntegrationResult getDataIntegration(GetDataIntegrationRequest request) { request = beforeClientExecution(request); return executeGetDataIntegration(request); } @SdkInternalApi final GetDataIntegrationResult executeGetDataIntegration(GetDataIntegrationRequest getDataIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(getDataIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new GetDataIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(getDataIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "GetDataIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new GetDataIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Returns information about the event integration. *

* * @param getEventIntegrationRequest * @return Result of the GetEventIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.GetEventIntegration * @see AWS API Documentation */ @Override public GetEventIntegrationResult getEventIntegration(GetEventIntegrationRequest request) { request = beforeClientExecution(request); return executeGetEventIntegration(request); } @SdkInternalApi final GetEventIntegrationResult executeGetEventIntegration(GetEventIntegrationRequest getEventIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(getEventIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new GetEventIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(getEventIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "GetEventIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new GetEventIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Returns a paginated list of DataIntegration associations in the account. *

* *

* You cannot create a DataIntegration association for a DataIntegration that has been previously associated. Use a * different DataIntegration, or recreate the DataIntegration using the CreateDataIntegration API. *

*
* * @param listDataIntegrationAssociationsRequest * @return Result of the ListDataIntegrationAssociations operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.ListDataIntegrationAssociations * @see AWS API Documentation */ @Override public ListDataIntegrationAssociationsResult listDataIntegrationAssociations(ListDataIntegrationAssociationsRequest request) { request = beforeClientExecution(request); return executeListDataIntegrationAssociations(request); } @SdkInternalApi final ListDataIntegrationAssociationsResult executeListDataIntegrationAssociations( ListDataIntegrationAssociationsRequest listDataIntegrationAssociationsRequest) { ExecutionContext executionContext = createExecutionContext(listDataIntegrationAssociationsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new ListDataIntegrationAssociationsRequestProtocolMarshaller(protocolFactory).marshall(super .beforeMarshalling(listDataIntegrationAssociationsRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListDataIntegrationAssociations"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new ListDataIntegrationAssociationsResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Returns a paginated list of DataIntegrations in the account. *

* *

* You cannot create a DataIntegration association for a DataIntegration that has been previously associated. Use a * different DataIntegration, or recreate the DataIntegration using the CreateDataIntegration API. *

*
* * @param listDataIntegrationsRequest * @return Result of the ListDataIntegrations operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.ListDataIntegrations * @see AWS API Documentation */ @Override public ListDataIntegrationsResult listDataIntegrations(ListDataIntegrationsRequest request) { request = beforeClientExecution(request); return executeListDataIntegrations(request); } @SdkInternalApi final ListDataIntegrationsResult executeListDataIntegrations(ListDataIntegrationsRequest listDataIntegrationsRequest) { ExecutionContext executionContext = createExecutionContext(listDataIntegrationsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new ListDataIntegrationsRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(listDataIntegrationsRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListDataIntegrations"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new ListDataIntegrationsResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Returns a paginated list of event integration associations in the account. *

* * @param listEventIntegrationAssociationsRequest * @return Result of the ListEventIntegrationAssociations operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.ListEventIntegrationAssociations * @see AWS API Documentation */ @Override public ListEventIntegrationAssociationsResult listEventIntegrationAssociations(ListEventIntegrationAssociationsRequest request) { request = beforeClientExecution(request); return executeListEventIntegrationAssociations(request); } @SdkInternalApi final ListEventIntegrationAssociationsResult executeListEventIntegrationAssociations( ListEventIntegrationAssociationsRequest listEventIntegrationAssociationsRequest) { ExecutionContext executionContext = createExecutionContext(listEventIntegrationAssociationsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new ListEventIntegrationAssociationsRequestProtocolMarshaller(protocolFactory).marshall(super .beforeMarshalling(listEventIntegrationAssociationsRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListEventIntegrationAssociations"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new ListEventIntegrationAssociationsResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Returns a paginated list of event integrations in the account. *

* * @param listEventIntegrationsRequest * @return Result of the ListEventIntegrations operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.ListEventIntegrations * @see AWS API Documentation */ @Override public ListEventIntegrationsResult listEventIntegrations(ListEventIntegrationsRequest request) { request = beforeClientExecution(request); return executeListEventIntegrations(request); } @SdkInternalApi final ListEventIntegrationsResult executeListEventIntegrations(ListEventIntegrationsRequest listEventIntegrationsRequest) { ExecutionContext executionContext = createExecutionContext(listEventIntegrationsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new ListEventIntegrationsRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(listEventIntegrationsRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListEventIntegrations"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory .createResponseHandler(new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new ListEventIntegrationsResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Lists the tags for the specified resource. *

* * @param listTagsForResourceRequest * @return Result of the ListTagsForResource operation returned by the service. * @throws InvalidRequestException * The request is not valid. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ResourceNotFoundException * The specified resource was not found. * @throws ThrottlingException * The throttling limit has been exceeded. * @sample AmazonAppIntegrations.ListTagsForResource * @see AWS API Documentation */ @Override public ListTagsForResourceResult listTagsForResource(ListTagsForResourceRequest request) { request = beforeClientExecution(request); return executeListTagsForResource(request); } @SdkInternalApi final ListTagsForResourceResult executeListTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest) { ExecutionContext executionContext = createExecutionContext(listTagsForResourceRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new ListTagsForResourceRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(listTagsForResourceRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListTagsForResource"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new ListTagsForResourceResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Adds the specified tags to the specified resource. *

* * @param tagResourceRequest * @return Result of the TagResource operation returned by the service. * @throws InvalidRequestException * The request is not valid. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ResourceNotFoundException * The specified resource was not found. * @throws ThrottlingException * The throttling limit has been exceeded. * @sample AmazonAppIntegrations.TagResource * @see AWS * API Documentation */ @Override public TagResourceResult tagResource(TagResourceRequest request) { request = beforeClientExecution(request); return executeTagResource(request); } @SdkInternalApi final TagResourceResult executeTagResource(TagResourceRequest tagResourceRequest) { ExecutionContext executionContext = createExecutionContext(tagResourceRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new TagResourceRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(tagResourceRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "TagResource"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new TagResourceResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Removes the specified tags from the specified resource. *

* * @param untagResourceRequest * @return Result of the UntagResource operation returned by the service. * @throws InvalidRequestException * The request is not valid. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ResourceNotFoundException * The specified resource was not found. * @throws ThrottlingException * The throttling limit has been exceeded. * @sample AmazonAppIntegrations.UntagResource * @see AWS * API Documentation */ @Override public UntagResourceResult untagResource(UntagResourceRequest request) { request = beforeClientExecution(request); return executeUntagResource(request); } @SdkInternalApi final UntagResourceResult executeUntagResource(UntagResourceRequest untagResourceRequest) { ExecutionContext executionContext = createExecutionContext(untagResourceRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new UntagResourceRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(untagResourceRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "UntagResource"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new UntagResourceResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Updates the description of a DataIntegration. *

* *

* You cannot create a DataIntegration association for a DataIntegration that has been previously associated. Use a * different DataIntegration, or recreate the DataIntegration using the CreateDataIntegration API. *

*
* * @param updateDataIntegrationRequest * @return Result of the UpdateDataIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.UpdateDataIntegration * @see AWS API Documentation */ @Override public UpdateDataIntegrationResult updateDataIntegration(UpdateDataIntegrationRequest request) { request = beforeClientExecution(request); return executeUpdateDataIntegration(request); } @SdkInternalApi final UpdateDataIntegrationResult executeUpdateDataIntegration(UpdateDataIntegrationRequest updateDataIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(updateDataIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new UpdateDataIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(updateDataIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "UpdateDataIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory .createResponseHandler(new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new UpdateDataIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** *

* Updates the description of an event integration. *

* * @param updateEventIntegrationRequest * @return Result of the UpdateEventIntegration operation returned by the service. * @throws InternalServiceErrorException * Request processing failed due to an error or failure with the service. * @throws ThrottlingException * The throttling limit has been exceeded. * @throws ResourceNotFoundException * The specified resource was not found. * @throws InvalidRequestException * The request is not valid. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AmazonAppIntegrations.UpdateEventIntegration * @see AWS API Documentation */ @Override public UpdateEventIntegrationResult updateEventIntegration(UpdateEventIntegrationRequest request) { request = beforeClientExecution(request); return executeUpdateEventIntegration(request); } @SdkInternalApi final UpdateEventIntegrationResult executeUpdateEventIntegration(UpdateEventIntegrationRequest updateEventIntegrationRequest) { ExecutionContext executionContext = createExecutionContext(updateEventIntegrationRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request request = null; Response response = null; try { awsRequestMetrics.startEvent(Field.RequestMarshallTime); try { request = new UpdateEventIntegrationRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(updateEventIntegrationRequest)); // Binds the request metrics to the current request. request.setAWSRequestMetrics(awsRequestMetrics); request.addHandlerContext(HandlerContextKey.CLIENT_ENDPOINT, endpoint); request.addHandlerContext(HandlerContextKey.ENDPOINT_OVERRIDDEN, isEndpointOverridden()); request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion()); request.addHandlerContext(HandlerContextKey.SERVICE_ID, "AppIntegrations"); request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "UpdateEventIntegration"); request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig); } finally { awsRequestMetrics.endEvent(Field.RequestMarshallTime); } HttpResponseHandler> responseHandler = protocolFactory.createResponseHandler( new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new UpdateEventIntegrationResultJsonUnmarshaller()); response = invoke(request, responseHandler, executionContext); return response.getAwsResponse(); } finally { endClientExecution(awsRequestMetrics, request, response); } } /** * Returns additional metadata for a previously executed successful, request, typically used for debugging issues * where a service isn't acting as expected. This data isn't considered part of the result data returned by an * operation, so it's available through this separate, diagnostic interface. *

* Response metadata is only cached for a limited period of time, so if you need to access this extra diagnostic * information for an executed request, you should use this method to retrieve it as soon as possible after * executing the request. * * @param request * The originally executed request * * @return The response metadata for the specified request, or null if none is available. */ public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request) { return client.getResponseMetadataForRequest(request); } /** * Normal invoke with authentication. Credentials are required and may be overriden at the request level. **/ private Response invoke(Request request, HttpResponseHandler> responseHandler, ExecutionContext executionContext) { return invoke(request, responseHandler, executionContext, null, null); } /** * Normal invoke with authentication. Credentials are required and may be overriden at the request level. **/ private Response invoke(Request request, HttpResponseHandler> responseHandler, ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) { executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider)); return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait); } /** * Invoke with no authentication. Credentials are not required and any credentials set on the client or request will * be ignored for this operation. **/ private Response anonymousInvoke(Request request, HttpResponseHandler> responseHandler, ExecutionContext executionContext) { return doInvoke(request, responseHandler, executionContext, null, null); } /** * Invoke the request using the http client. Assumes credentials (or lack thereof) have been configured in the * ExecutionContext beforehand. **/ private Response doInvoke(Request request, HttpResponseHandler> responseHandler, ExecutionContext executionContext, URI discoveredEndpoint, URI uriFromEndpointTrait) { if (discoveredEndpoint != null) { request.setEndpoint(discoveredEndpoint); request.getOriginalRequest().getRequestClientOptions().appendUserAgent("endpoint-discovery"); } else if (uriFromEndpointTrait != null) { request.setEndpoint(uriFromEndpointTrait); } else { request.setEndpoint(endpoint); } request.setTimeOffset(timeOffset); HttpResponseHandler errorResponseHandler = protocolFactory.createErrorResponseHandler(new JsonErrorResponseMetadata()); return client.execute(request, responseHandler, errorResponseHandler, executionContext); } @com.amazonaws.annotation.SdkInternalApi static com.amazonaws.protocol.json.SdkJsonProtocolFactory getProtocolFactory() { return protocolFactory; } @Override public void shutdown() { super.shutdown(); } }