From 277eebc2d3abd73fa376a1d6f39fcb93a9f0335d Mon Sep 17 00:00:00 2001 From: Alix Hamilton Date: Wed, 16 May 2018 14:08:53 -0700 Subject: [PATCH] PubSub: Update region tags to standard --- .../examples/pubsub/snippets/SubscriberSnippets.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java index 44cde5558ada..059665282a61 100644 --- a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java +++ b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java @@ -100,7 +100,7 @@ public void failed(Subscriber.State from, Throwable failure) { } private void createSubscriber() throws Exception { - // [START pubsub_pull] + // [START pubsub_subscriber_async_pull] String projectId = "my-project-id"; String subscriptionId = "my-subscription-id"; @@ -129,7 +129,7 @@ public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) { subscriber.stopAsync(); } } - // [END pubsub_pull] + // [END pubsub_subscriber_async_pull] } private Subscriber createSubscriberWithErrorListener(Subscriber subscriber) throws Exception { @@ -190,7 +190,7 @@ private Subscriber createSubscriberWithCustomCredentials() throws Exception { static List createSubscriberWithSyncPull( String projectId, String subscriptionId, int numOfMessages) throws Exception { - // [START subscriber_sync_pull] + // [START pubsub_subscriber_sync_pull] SubscriberStubSettings subscriberStubSettings = SubscriberStubSettings.newBuilder().build(); try (SubscriberStub subscriber = GrpcSubscriberStub.create(subscriberStubSettings)) { @@ -223,6 +223,6 @@ static List createSubscriberWithSyncPull( subscriber.acknowledgeCallable().call(acknowledgeRequest); return pullResponse.getReceivedMessagesList(); } - // [END subscriber_sync_pull] + // [END pubsub_subscriber_sync_pull] } }