com.google.api.client.http.HttpRequest.getHeaders()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(119)

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

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);
 }
}

相关文章