下面列出了怎么用org.apache.http.concurrent.BasicFuture的API类实例代码及写法,或者点击链接到github查看源代码。
void waitAndPrintChangeSetEvents(String stack, String changeSet, Waiter<DescribeChangeSetRequest> waiter, PollConfiguration pollConfiguration) throws ExecutionException {
final BasicFuture<AmazonWebServiceRequest> waitResult = new BasicFuture<>(null);
waiter.runAsync(new WaiterParameters<>(new DescribeChangeSetRequest().withStackName(stack).withChangeSetName(changeSet)).withPollingStrategy(this.pollingStrategy(pollConfiguration)), new WaiterHandler() {
@Override
public void onWaitSuccess(AmazonWebServiceRequest request) {
waitResult.completed(request);
}
@Override
public void onWaitFailure(Exception e) {
waitResult.failed(e);
}
});
this.waitAndPrintEvents(stack, pollConfiguration, waitResult);
}
void waitAndPrintStackEvents(String stack, Waiter<DescribeStacksRequest> waiter, PollConfiguration pollConfiguration) throws ExecutionException {
final BasicFuture<AmazonWebServiceRequest> waitResult = new BasicFuture<>(null);
waiter.runAsync(new WaiterParameters<>(new DescribeStacksRequest().withStackName(stack)).withPollingStrategy(this.pollingStrategy(pollConfiguration)), new WaiterHandler() {
@Override
public void onWaitSuccess(AmazonWebServiceRequest request) {
waitResult.completed(request);
}
@Override
public void onWaitFailure(Exception e) {
waitResult.failed(e);
}
});
this.waitAndPrintEvents(stack, pollConfiguration, waitResult);
}
private boolean isAsynchronousInvocation(final Object target, final Object[] args) {
if (!(target instanceof ResultFutureGetter)) {
logger.debug("Invalid target object. Need field accessor({}).", HttpClient4Constants.FIELD_RESULT_FUTURE);
return false;
}
BasicFuture<?> future = ((ResultFutureGetter) target)._$PINPOINT$_getResultFuture();
if (future == null) {
logger.debug("Invalid target object. field is null({}).", HttpClient4Constants.FIELD_RESULT_FUTURE);
return false;
}
if (!(future instanceof AsyncContextAccessor)) {
logger.debug("Invalid resultFuture field object. Need metadata accessor({}).", HttpClient4Constants.METADATA_ASYNC_CONTEXT);
return false;
}
return true;
}
@Test
public void test() throws Exception {
CloseableHttpAsyncClient httpClient = HttpAsyncClients.custom().useSystemProperties().build();
httpClient.start();
try {
HttpPost httpRequest = new HttpPost(webServer.getCallHttpUrl());
List<NameValuePair> params = new ArrayList<NameValuePair>();
params.add(new BasicNameValuePair("param1", "value1"));
httpRequest.setEntity(new UrlEncodedFormEntity(params, Consts.UTF_8.name()));
Future<HttpResponse> responseFuture = httpClient.execute(httpRequest, null);
HttpResponse response = (HttpResponse) responseFuture.get();
if ((response != null) && (response.getEntity() != null)) {
EntityUtils.consume(response.getEntity());
}
} finally {
httpClient.close();
}
PluginTestVerifier verifier = PluginTestVerifierHolder.getInstance();
verifier.printCache();
verifier.verifyTrace(event("HTTP_CLIENT_4_INTERNAL", CloseableHttpAsyncClient.class.getMethod("execute", HttpUriRequest.class, FutureCallback.class)));
final String destinationId = webServer.getHostAndPort();
final String httpUrl = webServer.getCallHttpUrl();
verifier.verifyTrace(async(
event("HTTP_CLIENT_4", Class.forName("org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl").getMethod("start"), null, null, destinationId,
annotation("http.url", httpUrl), annotation("http.entity", "param1=value1")),
event("ASYNC","Asynchronous Invocation"),
event("HTTP_CLIENT_4_INTERNAL", BasicFuture.class.getMethod("completed", Object.class))
));
verifier.verifyTrace(event("HTTP_CLIENT_4_INTERNAL", BasicFuture.class.getMethod("get")));
verifier.verifyTraceCount(0);
}
/**
* {@inheritDoc} <p/> <p> This implementation simulates a copyFile operation. </p> <p> This method copies files in-memory. </p> <p> The result {@link Copy}
* has the following properties: <dl> <p/> <dt>description</dt> <dd>"MockTransfer"</dd> <p/> <dt>state</dt> <dd>{@link TransferState#Completed}</dd> <p/>
* <dt>transferProgress.totalBytesToTransfer</dt> <dd>1024</dd> <p/> <dt>transferProgress.updateProgress</dt> <dd>1024</dd> <p/> </dl> <p/> All other
* properties are set as default. </p> <p> This operation takes the following hints when suffixed in copyObjectRequest.sourceKey: <dl> <p/>
* <dt>MOCK_S3_FILE_NAME_SERVICE_EXCEPTION</dt> <dd>Throws a AmazonServiceException</dd> <p/> </dl> </p>
*/
@Override
public Copy copyFile(final CopyObjectRequest copyObjectRequest, TransferManager transferManager)
{
LOGGER.debug(
"copyFile(): copyObjectRequest.getSourceBucketName() = " + copyObjectRequest.getSourceBucketName() + ", copyObjectRequest.getSourceKey() = " +
copyObjectRequest.getSourceKey() + ", copyObjectRequest.getDestinationBucketName() = " + copyObjectRequest.getDestinationBucketName() +
", copyObjectRequest.getDestinationKey() = " + copyObjectRequest.getDestinationKey());
if (copyObjectRequest.getSourceKey().endsWith(MOCK_S3_FILE_NAME_SERVICE_EXCEPTION))
{
throw new AmazonServiceException(null);
}
String sourceBucketName = copyObjectRequest.getSourceBucketName();
String sourceKey = copyObjectRequest.getSourceKey();
MockS3Bucket mockSourceS3Bucket = getOrCreateBucket(sourceBucketName);
MockS3Object mockSourceS3Object = mockSourceS3Bucket.getObjects().get(sourceKey);
if (mockSourceS3Object == null)
{
AmazonServiceException amazonServiceException = new AmazonServiceException(S3Operations.ERROR_CODE_NO_SUCH_KEY);
amazonServiceException.setErrorCode(S3Operations.ERROR_CODE_NO_SUCH_KEY);
throw amazonServiceException;
}
// Set the result CopyImpl and TransferProgress.
TransferProgress transferProgress = new TransferProgress();
transferProgress.setTotalBytesToTransfer(mockSourceS3Object.getObjectMetadata().getContentLength());
transferProgress.updateProgress(mockSourceS3Object.getObjectMetadata().getContentLength());
CopyImpl copy = new CopyImpl(MOCK_TRANSFER_DESCRIPTION, transferProgress, null, null);
copy.setState(TransferState.Completed);
// If an invalid KMS Id was passed in, mark the transfer as failed and return an exception via the transfer monitor.
if (copyObjectRequest.getSSEAwsKeyManagementParams() != null)
{
final String kmsId = copyObjectRequest.getSSEAwsKeyManagementParams().getAwsKmsKeyId();
if (kmsId.startsWith(MOCK_KMS_ID_FAILED_TRANSFER))
{
copy.setState(TransferState.Failed);
copy.setMonitor(new TransferMonitor()
{
@Override
public Future<?> getFuture()
{
if (!kmsId.equals(MOCK_KMS_ID_FAILED_TRANSFER_NO_EXCEPTION))
{
throw new AmazonServiceException("Key '" + copyObjectRequest.getSSEAwsKeyManagementParams().getAwsKmsKeyId() +
"' does not exist (Service: Amazon S3; Status Code: 400; Error Code: KMS.NotFoundException; Request ID: 1234567890123456)");
}
// We don't want an exception to be thrown so return a basic future that won't throw an exception.
BasicFuture<?> future = new BasicFuture<Void>(null);
future.completed(null);
return future;
}
@Override
public boolean isDone()
{
return true;
}
});
}
else if (kmsId.startsWith(MOCK_KMS_ID_CANCELED_TRANSFER))
{
// If the KMS indicates a cancelled transfer, just update the state to canceled.
copy.setState(TransferState.Canceled);
}
}
// If copy operation is marked as completed, perform the actual file copy in memory.
if (copy.getState().equals(TransferState.Completed))
{
String destinationBucketName = copyObjectRequest.getDestinationBucketName();
String destinationObjectKey = copyObjectRequest.getDestinationKey();
String destinationObjectVersion = MOCK_S3_BUCKET_NAME_VERSIONING_ENABLED.equals(destinationBucketName) ? UUID.randomUUID().toString() : null;
String destinationObjectKeyVersion = destinationObjectKey + (destinationObjectVersion != null ? destinationObjectVersion : "");
ObjectMetadata objectMetadata = copyObjectRequest.getNewObjectMetadata();
MockS3Object mockDestinationS3Object = new MockS3Object();
mockDestinationS3Object.setKey(destinationObjectKey);
mockDestinationS3Object.setVersion(destinationObjectVersion);
mockDestinationS3Object.setData(Arrays.copyOf(mockSourceS3Object.getData(), mockSourceS3Object.getData().length));
mockDestinationS3Object.setObjectMetadata(objectMetadata);
MockS3Bucket mockDestinationS3Bucket = getOrCreateBucket(destinationBucketName);
mockDestinationS3Bucket.getObjects().put(destinationObjectKey, mockDestinationS3Object);
mockDestinationS3Bucket.getVersions().put(destinationObjectKeyVersion, mockDestinationS3Object);
}
return copy;
}
@SuppressWarnings("rawtypes")
BasicFuture _$PINPOINT$_getResultFuture();