com.amazonaws.http.ExecutionContext类的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(22.5k)|赞(0)|评价(0)|浏览(130)

本文整理了Java中com.amazonaws.http.ExecutionContext类的一些代码示例,展示了ExecutionContext类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ExecutionContext类的具体详情如下:
包路径:com.amazonaws.http.ExecutionContext
类名称:ExecutionContext

ExecutionContext介绍

暂无

代码示例

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final DescribeBackupsResult executeDescribeBackups(DescribeBackupsRequest describeBackupsRequest) {
  ExecutionContext executionContext = createExecutionContext(describeBackupsRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DescribeBackupsRequest> request = null;
  Response<DescribeBackupsResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DescribeBackupsRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(describeBackupsRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "FSx");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DescribeBackups");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<DescribeBackupsResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new DescribeBackupsResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final ListTagsForResourceResult executeListTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest) {
  ExecutionContext executionContext = createExecutionContext(listTagsForResourceRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<ListTagsForResourceRequest> request = null;
  Response<ListTagsForResourceResult> 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.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "FSx");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListTagsForResource");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<ListTagsForResourceResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new ListTagsForResourceResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final TagResourceResult executeTagResource(TagResourceRequest tagResourceRequest) {
  ExecutionContext executionContext = createExecutionContext(tagResourceRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<TagResourceRequest> request = null;
  Response<TagResourceResult> 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.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "FSx");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "TagResource");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<TagResourceResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new TagResourceResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final UpdateFileSystemResult executeUpdateFileSystem(UpdateFileSystemRequest updateFileSystemRequest) {
  ExecutionContext executionContext = createExecutionContext(updateFileSystemRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<UpdateFileSystemRequest> request = null;
  Response<UpdateFileSystemResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new UpdateFileSystemRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(updateFileSystemRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "FSx");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "UpdateFileSystem");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<UpdateFileSystemResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new UpdateFileSystemResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final EnableRuleResult executeEnableRule(EnableRuleRequest enableRuleRequest) {
  ExecutionContext executionContext = createExecutionContext(enableRuleRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<EnableRuleRequest> request = null;
  Response<EnableRuleResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new EnableRuleRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(enableRuleRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "CloudWatch Events");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "EnableRule");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<EnableRuleResult>> responseHandler = protocolFactory.createResponseHandler(new JsonOperationMetadata()
        .withPayloadJson(true).withHasStreamingSuccessResponse(false), new EnableRuleResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final DeleteClusterResult executeDeleteCluster(DeleteClusterRequest deleteClusterRequest) {
  ExecutionContext executionContext = createExecutionContext(deleteClusterRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DeleteClusterRequest> request = null;
  Response<DeleteClusterResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DeleteClusterRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(deleteClusterRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EKS");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DeleteCluster");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<DeleteClusterResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new DeleteClusterResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final DescribeUpdateResult executeDescribeUpdate(DescribeUpdateRequest describeUpdateRequest) {
  ExecutionContext executionContext = createExecutionContext(describeUpdateRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DescribeUpdateRequest> request = null;
  Response<DescribeUpdateResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DescribeUpdateRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(describeUpdateRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EKS");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DescribeUpdate");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<DescribeUpdateResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new DescribeUpdateResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final BatchDeleteTableResult executeBatchDeleteTable(BatchDeleteTableRequest batchDeleteTableRequest) {
  ExecutionContext executionContext = createExecutionContext(batchDeleteTableRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<BatchDeleteTableRequest> request = null;
  Response<BatchDeleteTableResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new BatchDeleteTableRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(batchDeleteTableRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Glue");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "BatchDeleteTable");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<BatchDeleteTableResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new BatchDeleteTableResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final CreateDatabaseResult executeCreateDatabase(CreateDatabaseRequest createDatabaseRequest) {
  ExecutionContext executionContext = createExecutionContext(createDatabaseRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CreateDatabaseRequest> request = null;
  Response<CreateDatabaseResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CreateDatabaseRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(createDatabaseRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Glue");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateDatabase");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<CreateDatabaseResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new CreateDatabaseResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final CreateJobResult executeCreateJob(CreateJobRequest createJobRequest) {
  ExecutionContext executionContext = createExecutionContext(createJobRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CreateJobRequest> request = null;
  Response<CreateJobResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CreateJobRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(createJobRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Glue");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateJob");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<CreateJobResult>> responseHandler = protocolFactory.createResponseHandler(new JsonOperationMetadata()
        .withPayloadJson(true).withHasStreamingSuccessResponse(false), new CreateJobResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

代码示例来源:origin: aws/aws-sdk-java

/**
 * Normal invoke with authentication. Credentials are required and may be overriden at the request level.
 **/
private <X, Y extends AmazonWebServiceRequest> Response<X> invoke(Request<Y> request, HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
    ExecutionContext executionContext, URI cachedEndpoint, URI uriFromEndpointTrait) {
  executionContext.setCredentialsProvider(CredentialUtils.getCredentialsProvider(request.getOriginalRequest(), awsCredentialsProvider));
  return doInvoke(request, responseHandler, executionContext, cachedEndpoint, uriFromEndpointTrait);
}

代码示例来源:origin: aws/aws-sdk-java

@SdkInternalApi
final DeleteResourcePolicyResult executeDeleteResourcePolicy(DeleteResourcePolicyRequest deleteResourcePolicyRequest) {
  ExecutionContext executionContext = createExecutionContext(deleteResourcePolicyRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DeleteResourcePolicyRequest> request = null;
  Response<DeleteResourcePolicyResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DeleteResourcePolicyRequestProtocolMarshaller(protocolFactory).marshall(super.beforeMarshalling(deleteResourcePolicyRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Glue");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DeleteResourcePolicy");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    HttpResponseHandler<AmazonWebServiceResponse<DeleteResourcePolicyResult>> responseHandler = protocolFactory.createResponseHandler(
        new JsonOperationMetadata().withPayloadJson(true).withHasStreamingSuccessResponse(false), new DeleteResourcePolicyResultJsonUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

相关文章