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

StaxResponseHandler.<init>介绍

[英]Constructs a new response handler that will use the specified StAX unmarshaller to unmarshall the service response and uses the specified response element path to find the root of the business data in the service's response.
[中]构造一个新的响应处理程序，该处理程序将使用指定的StAX解组器来解组服务响应，并使用指定的响应元素路径来查找服务响应中业务数据的根。

代码示例

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

@SdkInternalApi
final GetStatusResult executeGetStatus(GetStatusRequest getStatusRequest) {
  ExecutionContext executionContext = createExecutionContext(getStatusRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<GetStatusRequest> request = null;
  Response<GetStatusResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new GetStatusRequestMarshaller().marshall(super.beforeMarshalling(getStatusRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "ImportExport");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "GetStatus");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<GetStatusResult> responseHandler = new StaxResponseHandler<GetStatusResult>(new GetStatusResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final CreateRuleResult executeCreateRule(CreateRuleRequest createRuleRequest) {
  ExecutionContext executionContext = createExecutionContext(createRuleRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CreateRuleRequest> request = null;
  Response<CreateRuleResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CreateRuleRequestMarshaller().marshall(super.beforeMarshalling(createRuleRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Elastic Load Balancing");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateRule");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<CreateRuleResult> responseHandler = new StaxResponseHandler<CreateRuleResult>(new CreateRuleResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final ReplicationGroup executeCreateReplicationGroup(CreateReplicationGroupRequest createReplicationGroupRequest) {
  ExecutionContext executionContext = createExecutionContext(createReplicationGroupRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CreateReplicationGroupRequest> request = null;
  Response<ReplicationGroup> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CreateReplicationGroupRequestMarshaller().marshall(super.beforeMarshalling(createReplicationGroupRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "ElastiCache");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateReplicationGroup");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<ReplicationGroup> responseHandler = new StaxResponseHandler<ReplicationGroup>(new ReplicationGroupStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final Snapshot executeCreateSnapshot(CreateSnapshotRequest createSnapshotRequest) {
  ExecutionContext executionContext = createExecutionContext(createSnapshotRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CreateSnapshotRequest> request = null;
  Response<Snapshot> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CreateSnapshotRequestMarshaller().marshall(super.beforeMarshalling(createSnapshotRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "ElastiCache");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateSnapshot");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<Snapshot> responseHandler = new StaxResponseHandler<Snapshot>(new SnapshotStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final ReplicationGroup executeDecreaseReplicaCount(DecreaseReplicaCountRequest decreaseReplicaCountRequest) {
  ExecutionContext executionContext = createExecutionContext(decreaseReplicaCountRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DecreaseReplicaCountRequest> request = null;
  Response<ReplicationGroup> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DecreaseReplicaCountRequestMarshaller().marshall(super.beforeMarshalling(decreaseReplicaCountRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "ElastiCache");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DecreaseReplicaCount");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<ReplicationGroup> responseHandler = new StaxResponseHandler<ReplicationGroup>(new ReplicationGroupStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final CacheCluster executeDeleteCacheCluster(DeleteCacheClusterRequest deleteCacheClusterRequest) {
  ExecutionContext executionContext = createExecutionContext(deleteCacheClusterRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DeleteCacheClusterRequest> request = null;
  Response<CacheCluster> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DeleteCacheClusterRequestMarshaller().marshall(super.beforeMarshalling(deleteCacheClusterRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "ElastiCache");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DeleteCacheCluster");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<CacheCluster> responseHandler = new StaxResponseHandler<CacheCluster>(new CacheClusterStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final EngineDefaults executeDescribeEngineDefaultParameters(DescribeEngineDefaultParametersRequest describeEngineDefaultParametersRequest) {
  ExecutionContext executionContext = createExecutionContext(describeEngineDefaultParametersRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DescribeEngineDefaultParametersRequest> request = null;
  Response<EngineDefaults> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DescribeEngineDefaultParametersRequestMarshaller().marshall(super.beforeMarshalling(describeEngineDefaultParametersRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Neptune");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DescribeEngineDefaultParameters");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<EngineDefaults> responseHandler = new StaxResponseHandler<EngineDefaults>(new EngineDefaultsStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final CopyFpgaImageResult executeCopyFpgaImage(CopyFpgaImageRequest copyFpgaImageRequest) {
  ExecutionContext executionContext = createExecutionContext(copyFpgaImageRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CopyFpgaImageRequest> request = null;
  Response<CopyFpgaImageResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CopyFpgaImageRequestMarshaller().marshall(super.beforeMarshalling(copyFpgaImageRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EC2");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CopyFpgaImage");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<CopyFpgaImageResult> responseHandler = new StaxResponseHandler<CopyFpgaImageResult>(new CopyFpgaImageResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final DeleteSubnetResult executeDeleteSubnet(DeleteSubnetRequest deleteSubnetRequest) {
  ExecutionContext executionContext = createExecutionContext(deleteSubnetRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DeleteSubnetRequest> request = null;
  Response<DeleteSubnetResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DeleteSubnetRequestMarshaller().marshall(super.beforeMarshalling(deleteSubnetRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EC2");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DeleteSubnet");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<DeleteSubnetResult> responseHandler = new StaxResponseHandler<DeleteSubnetResult>(new DeleteSubnetResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final DescribeHostsResult executeDescribeHosts(DescribeHostsRequest describeHostsRequest) {
  ExecutionContext executionContext = createExecutionContext(describeHostsRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DescribeHostsRequest> request = null;
  Response<DescribeHostsResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DescribeHostsRequestMarshaller().marshall(super.beforeMarshalling(describeHostsRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EC2");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DescribeHosts");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<DescribeHostsResult> responseHandler = new StaxResponseHandler<DescribeHostsResult>(new DescribeHostsResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final DescribeTagsResult executeDescribeTags(DescribeTagsRequest describeTagsRequest) {
  ExecutionContext executionContext = createExecutionContext(describeTagsRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DescribeTagsRequest> request = null;
  Response<DescribeTagsResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DescribeTagsRequestMarshaller().marshall(super.beforeMarshalling(describeTagsRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EC2");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DescribeTags");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<DescribeTagsResult> responseHandler = new StaxResponseHandler<DescribeTagsResult>(new DescribeTagsResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final DetachVolumeResult executeDetachVolume(DetachVolumeRequest detachVolumeRequest) {
  ExecutionContext executionContext = createExecutionContext(detachVolumeRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<DetachVolumeRequest> request = null;
  Response<DetachVolumeResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new DetachVolumeRequestMarshaller().marshall(super.beforeMarshalling(detachVolumeRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EC2");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "DetachVolume");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<DetachVolumeResult> responseHandler = new StaxResponseHandler<DetachVolumeResult>(new DetachVolumeResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final ModifyVolumeResult executeModifyVolume(ModifyVolumeRequest modifyVolumeRequest) {
  ExecutionContext executionContext = createExecutionContext(modifyVolumeRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<ModifyVolumeRequest> request = null;
  Response<ModifyVolumeResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new ModifyVolumeRequestMarshaller().marshall(super.beforeMarshalling(modifyVolumeRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "EC2");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ModifyVolume");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<ModifyVolumeResult> responseHandler = new StaxResponseHandler<ModifyVolumeResult>(new ModifyVolumeResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final AddTagsResult executeAddTags(AddTagsRequest addTagsRequest) {
  ExecutionContext executionContext = createExecutionContext(addTagsRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<AddTagsRequest> request = null;
  Response<AddTagsResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new AddTagsRequestMarshaller().marshall(super.beforeMarshalling(addTagsRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "Elastic Load Balancing");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "AddTags");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<AddTagsResult> responseHandler = new StaxResponseHandler<AddTagsResult>(new AddTagsResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final CreateGroupResult executeCreateGroup(CreateGroupRequest createGroupRequest) {
  ExecutionContext executionContext = createExecutionContext(createGroupRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<CreateGroupRequest> request = null;
  Response<CreateGroupResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new CreateGroupRequestMarshaller().marshall(super.beforeMarshalling(createGroupRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "IAM");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CreateGroup");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<CreateGroupResult> responseHandler = new StaxResponseHandler<CreateGroupResult>(new CreateGroupResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final GetPolicyResult executeGetPolicy(GetPolicyRequest getPolicyRequest) {
  ExecutionContext executionContext = createExecutionContext(getPolicyRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<GetPolicyRequest> request = null;
  Response<GetPolicyResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new GetPolicyRequestMarshaller().marshall(super.beforeMarshalling(getPolicyRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "IAM");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "GetPolicy");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<GetPolicyResult> responseHandler = new StaxResponseHandler<GetPolicyResult>(new GetPolicyResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final ListPoliciesResult executeListPolicies(ListPoliciesRequest listPoliciesRequest) {
  ExecutionContext executionContext = createExecutionContext(listPoliciesRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<ListPoliciesRequest> request = null;
  Response<ListPoliciesResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new ListPoliciesRequestMarshaller().marshall(super.beforeMarshalling(listPoliciesRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "IAM");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListPolicies");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<ListPoliciesResult> responseHandler = new StaxResponseHandler<ListPoliciesResult>(new ListPoliciesResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final ListRolesResult executeListRoles(ListRolesRequest listRolesRequest) {
  ExecutionContext executionContext = createExecutionContext(listRolesRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<ListRolesRequest> request = null;
  Response<ListRolesResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new ListRolesRequestMarshaller().marshall(super.beforeMarshalling(listRolesRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "IAM");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListRoles");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<ListRolesResult> responseHandler = new StaxResponseHandler<ListRolesResult>(new ListRolesResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

@SdkInternalApi
final ListUsersResult executeListUsers(ListUsersRequest listUsersRequest) {
  ExecutionContext executionContext = createExecutionContext(listUsersRequest);
  AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  awsRequestMetrics.startEvent(Field.ClientExecuteTime);
  Request<ListUsersRequest> request = null;
  Response<ListUsersResult> response = null;
  try {
    awsRequestMetrics.startEvent(Field.RequestMarshallTime);
    try {
      request = new ListUsersRequestMarshaller().marshall(super.beforeMarshalling(listUsersRequest));
      // Binds the request metrics to the current request.
      request.setAWSRequestMetrics(awsRequestMetrics);
      request.addHandlerContext(HandlerContextKey.SIGNING_REGION, getSigningRegion());
      request.addHandlerContext(HandlerContextKey.SERVICE_ID, "IAM");
      request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "ListUsers");
      request.addHandlerContext(HandlerContextKey.ADVANCED_CONFIG, advancedConfig);
    } finally {
      awsRequestMetrics.endEvent(Field.RequestMarshallTime);
    }
    StaxResponseHandler<ListUsersResult> responseHandler = new StaxResponseHandler<ListUsersResult>(new ListUsersResultStaxUnmarshaller());
    response = invoke(request, responseHandler, executionContext);
    return response.getAwsResponse();
  } finally {
    endClientExecution(awsRequestMetrics, request, response);
  }
}

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

/**
   * Confirms a subscription by visiting the provided URL.
   *
   * @param httpClient Client to use to visit URL.
   * @param subscribeUrl Confirmation URL.
   * @return Result of subscription confirmation.
   */
  static ConfirmSubscriptionResult confirmSubscription(HttpClient httpClient, String subscribeUrl) {
    try {
      HttpGet request = new HttpGet(subscribeUrl);
      HttpResponse response = httpClient.execute(request);
      if (ApacheUtils.isRequestSuccessful(response)) {
        return new StaxResponseHandler<ConfirmSubscriptionResult>(ConfirmSubscriptionResultStaxUnmarshaller.getInstance())
          .handle(ApacheUtils.createResponse(null, request, response, null)).getResult();
      } else {
        throw new HttpException("Could not confirm subscription", response);
      }
    } catch (Exception e) {
      throw new SdkClientException(e);
    }
  }
}