From 259fca9067a6a6d72e217c24223b02d3803e36e1 Mon Sep 17 00:00:00 2001 From: Marco Ziccardi Date: Tue, 9 Aug 2016 12:37:34 +0200 Subject: [PATCH] Fix setting HTTP transport factory for Datastore --- .../com/google/cloud/datastore/spi/DefaultDatastoreRpc.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/gcloud-java-datastore/src/main/java/com/google/cloud/datastore/spi/DefaultDatastoreRpc.java b/gcloud-java-datastore/src/main/java/com/google/cloud/datastore/spi/DefaultDatastoreRpc.java index 255da4c6e229..4258cb325290 100644 --- a/gcloud-java-datastore/src/main/java/com/google/cloud/datastore/spi/DefaultDatastoreRpc.java +++ b/gcloud-java-datastore/src/main/java/com/google/cloud/datastore/spi/DefaultDatastoreRpc.java @@ -16,6 +16,7 @@ package com.google.cloud.datastore.spi; +import com.google.api.client.http.HttpTransport; import com.google.cloud.datastore.DatastoreException; import com.google.cloud.datastore.DatastoreOptions; import com.google.datastore.v1beta3.AllocateIdsRequest; @@ -40,10 +41,12 @@ public class DefaultDatastoreRpc implements DatastoreRpc { private final com.google.datastore.v1beta3.client.Datastore client; public DefaultDatastoreRpc(DatastoreOptions options) { + HttpTransport transport = options.httpTransportFactory().create(); com.google.datastore.v1beta3.client.DatastoreOptions.Builder clientBuilder = new com.google.datastore.v1beta3.client.DatastoreOptions.Builder() .projectId(options.projectId()) - .initializer(options.httpRequestInitializer()); + .initializer(options.httpRequestInitializer()) + .transport(transport); String normalizedHost = options.host() != null ? options.host().toLowerCase() : ""; if (isLocalHost(normalizedHost)) { clientBuilder = clientBuilder.localHost(removeScheme(normalizedHost));