Merge pull request #3296 from alixhami/pubsub-region-tags

Pubsub: adds missing region tags

Author: alixhami

google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PublisherSnippets.java

@@ -122,13 +122,13 @@ public Publisher getPublisherWithCustomRetrySettings(ProjectTopicName topicName)
   }
 
   public Publisher getSingleThreadedPublisher(ProjectTopicName topicName) throws Exception {
-    // [START pubsub_publisher_single_threaded]
+    // [START pubsub_publisher_concurrency_control]
     // create a publisher with a single threaded executor
     ExecutorProvider executorProvider = InstantiatingExecutorProvider.newBuilder()
         .setExecutorThreadCount(1).build();
     Publisher publisher = Publisher.newBuilder(topicName)
         .setExecutorProvider(executorProvider).build();
-    // [END pubsub_publisher_single_threaded]
+    // [END pubsub_publisher_concurrency_control]
     return publisher;
   }
 

google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java

@@ -146,7 +146,7 @@ public void failed(Subscriber.State from, Throwable failure) {
   }
 
   private Subscriber createSingleThreadedSubscriber() throws Exception {
-    // [START pubsub_subscriber_single_threaded]
+    // [START pubsub_subscriber_concurrency_control]
     // provide a separate executor service for polling
     ExecutorProvider executorProvider =
         InstantiatingExecutorProvider.newBuilder().setExecutorThreadCount(1).build();
@@ -155,7 +155,7 @@ private Subscriber createSingleThreadedSubscriber() throws Exception {
         Subscriber.newBuilder(subscriptionName, receiver)
             .setExecutorProvider(executorProvider)
             .build();
-    // [END pubsub_subscriber_single_threaded]
+    // [END pubsub_subscriber_concurrency_control]
     return subscriber;
   }