Skip to content

Commit e8706fb

Browse files
authored
Fix setting HTTP transport factory for Datastore (#1144)
1 parent f9484f3 commit e8706fb

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

gcloud-java-datastore/src/main/java/com/google/cloud/datastore/spi/DefaultDatastoreRpc.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package com.google.cloud.datastore.spi;
1818

19+
import com.google.api.client.http.HttpTransport;
1920
import com.google.cloud.datastore.DatastoreException;
2021
import com.google.cloud.datastore.DatastoreOptions;
2122
import com.google.datastore.v1beta3.AllocateIdsRequest;
@@ -40,10 +41,12 @@ public class DefaultDatastoreRpc implements DatastoreRpc {
4041
private final com.google.datastore.v1beta3.client.Datastore client;
4142

4243
public DefaultDatastoreRpc(DatastoreOptions options) {
44+
HttpTransport transport = options.httpTransportFactory().create();
4345
com.google.datastore.v1beta3.client.DatastoreOptions.Builder clientBuilder =
4446
new com.google.datastore.v1beta3.client.DatastoreOptions.Builder()
4547
.projectId(options.projectId())
46-
.initializer(options.httpRequestInitializer());
48+
.initializer(options.httpRequestInitializer())
49+
.transport(transport);
4750
String normalizedHost = options.host() != null ? options.host().toLowerCase() : "";
4851
if (isLocalHost(normalizedHost)) {
4952
clientBuilder = clientBuilder.localHost(removeScheme(normalizedHost));

0 commit comments

Comments
 (0)