---

rahulKQL · sduskis · commit c349cecf22de · 2019-02-14T18:05:27.000-05:00
yaml --- r: 20087 b: refs/heads/autosynth-os-login c: 228192e h: refs/heads/master i: 20085: 28d3ece 20083: 20ba0ca 20079: 8406570
diff --git a/[refs] b/[refs]
@@ -135,7 +135,7 @@ refs/heads/autosynth-firestore: d1a44f9acc302750e37b008ecb9c1aa535cc94df
 refs/heads/autosynth-iot: f03bdd338a9056ca3b7ea6d9ca901649ba9aab78
 refs/heads/autosynth-kms: 2828edfe3d2c53dd6e71912eae8a53c87bf40c87
 refs/heads/autosynth-language: c3d990dd34d81e7e935041e7147fb9dd27f8a557
-refs/heads/autosynth-os-login: e195b5f60b793a1d85f3cdc679cfb2fc58128887
+refs/heads/autosynth-os-login: 228192ee97d6968acbc8fe9becfed23159f80720
 refs/heads/autosynth-redis: 0cdb2e47359d51b73763bcea8af3de62aa99119b
 refs/heads/autosynth-scheduler: d97f8743ba965c7d5e492c8dc1f51d023104e260
 refs/heads/autosynth-spanner: 9bff86d057df31e04c76d72865e8e073ac5794fb
diff --git a/branches/autosynth-os-login/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStub.java b/branches/autosynth-os-login/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStub.java
@@ -90,6 +90,7 @@ public static EnhancedBigtableStub create(EnhancedBigtableStubSettings settings)
             .setTransportChannelProvider(settings.getTransportChannelProvider())
             .setEndpoint(settings.getEndpoint())
             .setCredentialsProvider(settings.getCredentialsProvider())
+            .setHeaderProvider(settings.getHeaderProvider())
             .setStreamWatchdogProvider(settings.getStreamWatchdogProvider())
             .setStreamWatchdogCheckInterval(settings.getStreamWatchdogCheckInterval());
 
diff --git a/branches/autosynth-os-login/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/stub/ResourceHeaderTest.java b/branches/autosynth-os-login/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/stub/ResourceHeaderTest.java
@@ -20,6 +20,8 @@
 import com.google.api.gax.core.NoCredentialsProvider;
 import com.google.api.gax.grpc.testing.InProcessServer;
 import com.google.api.gax.grpc.testing.LocalChannelProvider;
+import com.google.api.gax.rpc.FixedHeaderProvider;
+import com.google.api.gax.rpc.HeaderProvider;
 import com.google.bigtable.v2.BigtableGrpc;
 import com.google.cloud.bigtable.data.v2.BigtableDataClient;
 import com.google.cloud.bigtable.data.v2.BigtableDataSettings;
@@ -48,6 +50,9 @@ public class ResourceHeaderTest {
   private static final Pattern EXPECTED_HEADER_PATTERN =
       Pattern.compile(".*" + NameUtil.formatTableName(PROJECT_ID, INSTANCE_ID, TABLE_ID) + ".*");
   private static final String HEADER_NAME = "x-goog-request-params";
+  private static final String TEST_HEADER_NAME = "simple-header-name";
+  private static final String TEST_HEADER_VALUE = "simple-header-value";
+  private static final Pattern TEST_PATTERN = Pattern.compile(".*" + TEST_HEADER_VALUE + ".*");
 
   private InProcessServer<?> server;
   private LocalChannelProvider channelProvider;
@@ -59,11 +64,13 @@ public void setUp() throws Exception {
     server.start();
     channelProvider = LocalChannelProvider.create(NAME);
 
+    HeaderProvider headerProvider = FixedHeaderProvider.create(TEST_HEADER_NAME, TEST_HEADER_VALUE);
     BigtableDataSettings.Builder settings =
         BigtableDataSettings.newBuilder()
             .setProjectId(PROJECT_ID)
             .setInstanceId(INSTANCE_ID)
             .setTransportChannelProvider(channelProvider)
+            .setHeaderProvider(headerProvider)
             .setCredentialsProvider(NoCredentialsProvider.create());
 
     // Force immediate flush
@@ -132,5 +139,7 @@ public void readModifyWriteTest() {
   private void verifyHeaderSent() {
     boolean headerSent = channelProvider.isHeaderSent(HEADER_NAME, EXPECTED_HEADER_PATTERN);
     assertWithMessage("Header was sent").that(headerSent).isTrue();
+    boolean testHeader = channelProvider.isHeaderSent(TEST_HEADER_NAME, TEST_PATTERN);
+    assertWithMessage("HeaderProvider's header received in Channel").that(testHeader).isTrue();
   }
 }
