本文整理了Java中com.amazonaws.http.HttpResponse.<init>()
方法的一些代码示例,展示了HttpResponse.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpResponse.<init>()
方法的具体详情如下:
包路径:com.amazonaws.http.HttpResponse
类名称:HttpResponse
方法名:<init>
[英]Constructs a new HttpResponse associated with the specified request.
[中]构造与指定请求关联的新HttpResponse。
代码示例来源:origin: aws/aws-sdk-java
public ErrorUnmarshallingHandler(PutMediaResponseHandler responseHandler,
HttpResponseHandler<AmazonServiceException> errorResponseHandler,
Request<?> request) {
this.responseHandler = responseHandler;
this.errorResponseHandler = errorResponseHandler;
// Eagerly create the error response to serve as a container for dumping HTTP data into
this.errorResponse = new com.amazonaws.http.HttpResponse(request, null);
}
代码示例来源:origin: aws/aws-sdk-java
/**
* Creates and initializes an HttpResponse object suitable to be passed to an HTTP response
* handler object.
*
* @param request Marshalled request object.
* @param method The HTTP method that was invoked to get the response.
* @param context The HTTP context associated with the request and response.
* @return The new, initialized HttpResponse object ready to be passed to an HTTP response
* handler object.
* @throws IOException If there were any problems getting any response information from the
* HttpClient method object.
*/
public static HttpResponse createResponse(Request<?> request,
HttpRequestBase method,
org.apache.http.HttpResponse apacheHttpResponse,
HttpContext context) throws IOException {
HttpResponse httpResponse = new HttpResponse(request, method, context);
if (apacheHttpResponse.getEntity() != null) {
httpResponse.setContent(apacheHttpResponse.getEntity().getContent());
}
httpResponse.setStatusCode(apacheHttpResponse.getStatusLine().getStatusCode());
httpResponse.setStatusText(apacheHttpResponse.getStatusLine().getReasonPhrase());
for (Header header : apacheHttpResponse.getAllHeaders()) {
httpResponse.addHeader(header.getName(), header.getValue());
}
return httpResponse;
}
代码示例来源:origin: aws-amplify/aws-sdk-android
/**
* Builds an instance of {@link HttpResponse}
*
* @return a new instance of {@link HttpResponse}
*/
public HttpResponse build() {
return new HttpResponse(statusText, statusCode,
Collections.unmodifiableMap(headers), content);
}
}
代码示例来源:origin: com.amazonaws/aws-java-sdk-core
/**
* Creates and initializes an HttpResponse object suitable to be passed to an HTTP response
* handler object.
*
* @param request Marshalled request object.
* @param method The HTTP method that was invoked to get the response.
* @param context The HTTP context associated with the request and response.
* @return The new, initialized HttpResponse object ready to be passed to an HTTP response
* handler object.
* @throws IOException If there were any problems getting any response information from the
* HttpClient method object.
*/
public static HttpResponse createResponse(Request<?> request,
HttpRequestBase method,
org.apache.http.HttpResponse apacheHttpResponse,
HttpContext context) throws IOException {
HttpResponse httpResponse = new HttpResponse(request, method, context);
if (apacheHttpResponse.getEntity() != null) {
httpResponse.setContent(apacheHttpResponse.getEntity().getContent());
}
httpResponse.setStatusCode(apacheHttpResponse.getStatusLine().getStatusCode());
httpResponse.setStatusText(apacheHttpResponse.getStatusLine().getReasonPhrase());
for (Header header : apacheHttpResponse.getAllHeaders()) {
httpResponse.addHeader(header.getName(), header.getValue());
}
return httpResponse;
}
代码示例来源:origin: com.amazonaws/aws-java-sdk-kinesisvideo
public ErrorUnmarshallingHandler(PutMediaResponseHandler responseHandler,
HttpResponseHandler<AmazonServiceException> errorResponseHandler,
Request<?> request) {
this.responseHandler = responseHandler;
this.errorResponseHandler = errorResponseHandler;
// Eagerly create the error response to serve as a container for dumping HTTP data into
this.errorResponse = new com.amazonaws.http.HttpResponse(request, null);
}
代码示例来源:origin: com.gluonhq/aws-java-sdk-core
/**
* Builds an instance of {@link HttpResponse}
*
* @return a new instance of {@link HttpResponse}
*/
public HttpResponse build() {
return new HttpResponse(statusText, statusCode,
Collections.unmodifiableMap(headers), content);
}
}
代码示例来源:origin: com.amazonaws/aws-android-sdk-core
/**
* Builds an instance of {@link HttpResponse}
*
* @return a new instance of {@link HttpResponse}
*/
public HttpResponse build() {
return new HttpResponse(statusText, statusCode,
Collections.unmodifiableMap(headers), content);
}
}
代码示例来源:origin: Nextdoor/bender
/**
* Creates and initializes an HttpResponse object suitable to be passed to an HTTP response
* handler object.
*
* @param method The HTTP method that was invoked to get the response.
* @param context The HTTP context associated with the request and response.
* @return The new, initialized HttpResponse object ready to be passed to an HTTP response
* handler object.
* @throws IOException If there were any problems getting any response information from the
* HttpClient method object.
*/
private HttpResponse createResponse(HttpRequestBase method,
org.apache.http.HttpResponse apacheHttpResponse,
HttpContext context) throws IOException {
HttpResponse httpResponse = new HttpResponse(request, method, context);
if (apacheHttpResponse.getEntity() != null) {
httpResponse.setContent(apacheHttpResponse.getEntity().getContent());
}
httpResponse.setStatusCode(apacheHttpResponse.getStatusLine().getStatusCode());
httpResponse.setStatusText(apacheHttpResponse.getStatusLine().getReasonPhrase());
for (Header header : apacheHttpResponse.getAllHeaders()) {
httpResponse.addHeader(header.getName(), header.getValue());
}
return httpResponse;
}
代码示例来源:origin: aws/aws-sdk-java-v2
@Benchmark
public Object getItem(GetItemState s) {
HttpResponse resp = new HttpResponse(null, null);
resp.setContent(new ByteArrayInputStream(s.testItem.utf8()));
try {
return getItemJsonResponseHandler().handle(resp);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: Netflix/spectator
private void execRequest(String endpoint, int status) {
AWSRequestMetrics metrics = new AWSRequestMetricsFullSupport();
metrics.addProperty(AWSRequestMetrics.Field.ServiceName, "AmazonCloudWatch");
metrics.addProperty(AWSRequestMetrics.Field.ServiceEndpoint, endpoint);
metrics.addProperty(AWSRequestMetrics.Field.StatusCode, "" + status);
if (status == 503) {
metrics.addProperty(AWSRequestMetrics.Field.AWSErrorCode, "Throttled");
}
String counterName = "BytesProcessed";
String timerName = "ClientExecuteTime";
metrics.setCounter(counterName, 12345);
metrics.getTimingInfo().addSubMeasurement(timerName, TimingInfo.unmodifiableTimingInfo(100000L, 200000L));
Request<?> req = new DefaultRequest(new ListMetricsRequest(), "AmazonCloudWatch");
req.setAWSRequestMetrics(metrics);
req.setEndpoint(URI.create(endpoint));
HttpResponse hr = new HttpResponse(req, new HttpPost(endpoint));
hr.setStatusCode(status);
Response<?> resp = new Response<>(null, new HttpResponse(req, new HttpPost(endpoint)));
collector.collectMetrics(req, resp);
}
代码示例来源:origin: org.apache.beam/beam-sdks-java-io-kinesis
@Override
public DescribeStreamResult describeStream(String streamName, String exclusiveStartShardId) {
int nextShardId = 0;
if (exclusiveStartShardId != null) {
nextShardId = parseInt(exclusiveStartShardId) + 1;
}
boolean hasMoreShards = nextShardId + 1 < shardedData.size();
List<Shard> shards = new ArrayList<>();
if (nextShardId < shardedData.size()) {
shards.add(new Shard().withShardId(Integer.toString(nextShardId)));
}
HttpResponse response = new HttpResponse(null, null);
response.setStatusCode(200);
DescribeStreamResult result = new DescribeStreamResult();
result.setSdkHttpMetadata(SdkHttpMetadata.from(response));
result.withStreamDescription(
new StreamDescription()
.withHasMoreShards(hasMoreShards)
.withShards(shards)
.withStreamName(streamName));
return result;
}
内容来源于网络,如有侵权,请联系作者删除!