本文整理了Java中com.google.api.client.http.HttpRequest.getHeaders()
方法的一些代码示例,展示了HttpRequest.getHeaders()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpRequest.getHeaders()
方法的具体详情如下:
包路径:com.google.api.client.http.HttpRequest
类名称:HttpRequest
方法名:getHeaders
暂无
代码示例来源:origin: googleapis/google-cloud-java
@Override
public void initialize(HttpRequest httpRequest) throws IOException {
delegate.initialize(httpRequest);
httpRequest.getHeaders().setUserAgent(applicationName);
}
};
代码示例来源:origin: googleapis/google-cloud-java
@Override
public void intercept(HttpRequest request) throws IOException {
checkNotNull(request);
if (this.interceptor != null) {
this.interceptor.intercept(request);
}
if (propagationTextFormat != null && propagationTextFormatSetter != null) {
SpanContext spanContext = tracer.getCurrentSpan().getContext();
if (!SpanContext.INVALID.equals(spanContext)) {
propagationTextFormat.inject(
spanContext, request.getHeaders(), propagationTextFormatSetter);
}
}
}
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void implementationOfDefaultTextFormatSetter() {
String testKey = "testKey";
String testValue = "testValue";
TextFormat.Setter<HttpHeaders> setter =
CensusHttpModule.DefaultPropagationTextFormatSetter.INSTANCE;
setter.put(httpRequest.getHeaders(), testKey, testValue);
assertThat(httpRequest.getHeaders().get(testKey)).isEqualTo(testValue);
}
代码示例来源:origin: googleapis/google-cloud-java
@Override
public void initialize(HttpRequest httpRequest) throws IOException {
if (delegate != null) {
delegate.initialize(httpRequest);
}
if (connectTimeout >= 0) {
httpRequest.setConnectTimeout(connectTimeout);
}
if (readTimeout >= 0) {
httpRequest.setReadTimeout(readTimeout);
}
HttpHeadersUtils.setHeaders(httpRequest.getHeaders(), headerProvider.getHeaders());
}
};
代码示例来源:origin: googleapis/google-cloud-java
range.append('*');
httpRequest.getHeaders().setContentRange(range.toString());
int code;
String message;
代码示例来源:origin: googleapis/google-cloud-java
range.append('*');
httpRequest.getHeaders().setContentRange(range.toString());
int code;
String message;
代码示例来源:origin: googleapis/google-cloud-java
@Override
public String open(Job loadJob) {
try {
String builder = BASE_RESUMABLE_URI + options.getProjectId() + "/jobs";
GenericUrl url = new GenericUrl(builder);
url.set("uploadType", "resumable");
JsonFactory jsonFactory = bigquery.getJsonFactory();
HttpRequestFactory requestFactory = bigquery.getRequestFactory();
HttpRequest httpRequest =
requestFactory.buildPostRequest(url, new JsonHttpContent(jsonFactory, loadJob));
httpRequest.getHeaders().set("X-Upload-Content-Value", "application/octet-stream");
HttpResponse response = httpRequest.execute();
return response.getHeaders().getLocation();
} catch (IOException ex) {
throw translate(ex);
}
}
代码示例来源:origin: googleapis/google-cloud-java
HttpRequest httpRequest =
requestFactory.buildPostRequest(url, new JsonHttpContent(jsonFactory, object));
HttpHeaders requestHeaders = httpRequest.getHeaders();
requestHeaders.set(
"X-Upload-Content-Type",
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void censusHttpExecuteInterceptorShouldInjectHeader() throws IOException {
Random random = new Random();
SpanContext spanContext =
SpanContext.create(
TraceId.generateRandomId(random),
SpanId.generateRandomId(random),
TraceOptions.DEFAULT);
Span mockSpan =
createMockBuilder(Span.class)
.withConstructor(SpanContext.class, EnumSet.class)
.withArgs(spanContext, null)
.createMock();
Scope scope = tracer.withSpan(mockSpan);
try {
HttpExecuteInterceptor interceptor = censusHttpModule.new CensusHttpExecuteInterceptor(null);
interceptor.intercept(httpRequest);
assertThat(httpRequest.getHeaders().get("X-Cloud-Trace-Context")).isNotNull();
} finally {
scope.close();
}
}
代码示例来源:origin: GoogleCloudPlatform/java-docs-samples
boolean verifyJwtForAppEngine(HttpRequest request, long projectNumber, String projectId)
throws Exception {
// Check for iap jwt header in incoming request
String jwt = request.getHeaders().getFirstHeaderStringValue("x-goog-iap-jwt-assertion");
if (jwt == null) {
return false;
}
return verifyJwt(
jwt,
String.format("/projects/%s/apps/%s", Long.toUnsignedString(projectNumber), projectId));
}
代码示例来源:origin: GoogleCloudPlatform/java-docs-samples
boolean verifyJwtForComputeEngine(
HttpRequest request, long projectNumber, long backendServiceId) throws Exception {
// Check for iap jwt header in incoming request
String jwtToken = request.getHeaders()
.getFirstHeaderStringValue("x-goog-iap-jwt-assertion");
if (jwtToken == null) {
return false;
}
return verifyJwt(
jwtToken,
String.format(
"/projects/%s/global/backendServices/%s",
Long.toUnsignedString(projectNumber), Long.toUnsignedString(backendServiceId)));
}
代码示例来源:origin: GoogleCloudPlatform/java-docs-samples
HttpHeaders httpHeaders = request.getHeaders().clone().setAuthorization("Bearer " + idToken);
代码示例来源:origin: com.google.enterprise.cloudsearch/google-cloudsearch-connector-sdk
/** Gets an {@link HttpRequestInitializer} that sets the http header for proxy authorization. */
public HttpRequestInitializer getHttpRequestInitializer() {
return authToken.isPresent()
? httpRequest ->
httpRequest
.getHeaders()
.set("Proxy-Authorization", String.format("Basic %s", authToken.get()))
: httpRequest -> {};
}
代码示例来源:origin: GoogleCloudPlatform/bigdata-interop
@Override
public Void answer(InvocationOnMock unused) {
req.getHeaders().setAuthorization(authHeaderValue);
return null;
}
})
代码示例来源:origin: GoogleCloudPlatform/bigdata-interop
@Override
public Void answer(InvocationOnMock unused) {
req.getHeaders().setAuthorization(authHeaderValue);
return null;
}
})
代码示例来源:origin: GoogleCloudPlatform/bigdata-interop
@Override
public Void answer(InvocationOnMock unused) {
req.getHeaders().setAuthorization(authHeaderValue);
return null;
}
})
代码示例来源:origin: jpotts/alfresco-api-java-examples
@Override
public void initialize(HttpRequest request) throws IOException {
request.setParser(new JsonObjectParser(new JacksonFactory()));
request.getHeaders().setBasicAuthentication(getUsername(), getPassword());
}
});
代码示例来源:origin: com.google.api-client/google-api-client
@Override
protected TokenResponse executeRefreshToken() throws IOException {
GenericUrl tokenUrl = new GenericUrl(getTokenServerEncodedUrl());
HttpRequest request = getTransport().createRequestFactory().buildGetRequest(tokenUrl);
request.setParser(new JsonObjectParser(getJsonFactory()));
request.getHeaders().set("Metadata-Flavor", "Google");
return request.execute().parseAs(TokenResponse.class);
}
代码示例来源:origin: GoogleCloudPlatform/bigdata-interop
@Override
protected TokenResponse executeRefreshToken() throws IOException {
HttpRequest request =
getTransport()
.createRequestFactory(getRequestInitializer())
.buildGetRequest(new GenericUrl(getTokenServerEncodedUrl()))
.setParser(new JsonObjectParser(getJsonFactory()));
request.getHeaders().set("Metadata-Flavor", "Google");
return request.execute().parseAs(TokenResponse.class);
}
}
代码示例来源:origin: com.google.cloud.bigdataoss/util
@Override
protected TokenResponse executeRefreshToken() throws IOException {
HttpRequest request =
getTransport()
.createRequestFactory(getRequestInitializer())
.buildGetRequest(new GenericUrl(getTokenServerEncodedUrl()))
.setParser(new JsonObjectParser(getJsonFactory()));
request.getHeaders().set("Metadata-Flavor", "Google");
return request.execute().parseAs(TokenResponse.class);
}
}
内容来源于网络,如有侵权,请联系作者删除!