add back PubSub samples by pongad · Pull Request #1540 · googleapis/google-cloud-java

pongad · 2017-01-16T23:51:10Z

No description provided.

Sign in to view

+ * A snippet for Google Cloud Pub/Sub showing how to create a Pub/Sub pull subscription and
+ * asynchronously pull messages from it.
+ */
+public class CreateSubscriptionAndPullMessages {


Sign in to view

+      subscriberClient.createSubscription(subscription, topic, PushConfig.getDefaultInstance(), 0);
+    }
+
+    MessageReceiver receiver =


Sign in to view

+      Thread.sleep(60000);
+    } finally {
+      if (subscriber != null) {
+        subscriber.stopAsync();


Sign in to view

+            @Override
+            public void failed(Service.State from, Throwable failure) {
+              System.err.println(failure);
+            }


Sign in to view

+            }
+          },
+          MoreExecutors.directExecutor());
+      subscriber.startAsync().awaitRunning();


Sign in to view

+      for (String message : messages) {
+        messageIds.add(
+            publisher.publish(
+                PubsubMessage.newBuilder().setData(ByteString.copyFromUtf8(message)).build()));


Sign in to view

+            publisher.publish(
+                PubsubMessage.newBuilder().setData(ByteString.copyFromUtf8(message)).build()));
+      }
+      for (String messageId : Futures.allAsList(messageIds).get()) {


Sign in to view

      return new Builder(topic);
    }

+    public static Builder newBuilder(TopicName topic) {


Sign in to view

@@ -142,6 +143,10 @@ public static Builder newBuilder(String subscription, MessageReceiver receiver)
      return new Builder(subscription, receiver);


Sign in to view

@@ -186,6 +187,10 @@ public static Builder newBuilder(String topic) {
      return new Builder(topic);


pongad · 2017-01-18T02:46:31Z

@garrettjonesgoogle PTAL

coveralls · 2017-01-18T03:53:29Z

Coverage remained the same at 83.113% when pulling 7b2cac7 on pongad:pub-doc into 19acb03 on GoogleCloudPlatform:pubsub-rm.

Sign in to view

+      for (String message : messages) {
+        PubsubMessage pubsubMessage =
+            PubsubMessage.newBuilder().setData(ByteString.copyFromUtf8(message)).build();
+        messageIds.add(publisher.publish(pubsubMessage));


pongad · 2017-01-18T23:09:37Z

@garrettjonesgoogle You mean splitting the ByteString off? PTAL

garrettjonesgoogle · 2017-01-19T01:00:02Z

LGTM for merging purposes. Add a to do somewhere to make the samples simpler.

🤖 I have created a release *beep* *boop* --- ### Updating meta-information for bleeding-edge SNAPSHOT release. --- This PR was generated with [Release Please](https://togithub.com/googleapis/release-please). See [documentation](https://togithub.com/googleapis/release-please#release-please).

Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>

🤖 I have created a release *beep* *boop* --- ### Updating meta-information for bleeding-edge SNAPSHOT release. --- This PR was generated with [Release Please](https://togithub.com/googleapis/release-please). See [documentation](https://togithub.com/googleapis/release-please#release-please).

…data-jdbc to v3.2.4 (googleapis#1540)

…0.127.31 (#1540)

* receipt-modack for exactly once * changing setup * changing the pendingReceipt List * using scheduled fixed rate * using blocked queues * using blocked queues * using blocked queues * adding null safety * adding null safety * removing list * adding list back * if permanent failure, remove outstandingmsg from queue * adding snippet of test * adding method to streaming subscriber * adding method to streaming subscriber * adding notifyAcks * changing notifyAckFailed calls * addressing some comments * changed logic to use one datastructure * fixing notifyFailed * fixing notifyFailed * changing Pair to custom class * removing the not needed data structure * Fixing test * Fixing test * Fixing test * Fixing test * fixing format * fixing test to call receiveMessage * testing test failure * testing test failure * testing test failure * increasing timestamp to test * increasing timestamp to test * adding log statement for testing * Fixing lint * Adding more logs * batch size log * changing method to syncronized * fixing for loop to not remove as we are iterating * trying a concurrent map * fix: syncronizing notifyFailed * fix: removing unused import * fix: reformat * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * fix: removing System.out.println statements * fix: reviewign comments * fix: lint * adding another ordering key test example * fix: trying to run this test again * fix: trying to run this test again * fix: removing commented code * fix: removing commented code * resolving the comments from review * adding custom matcher * adding custom matcher * adding custom matcher * adding custom matcher * adding custom matcher correcting the matching statement * lint * removing comments * removing comments * removing comments * changing messageMatcher to messageDataMatcher, and fixing other nit things * lint * addressing review comments * addressing review comments --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

* receipt-modack for exactly once * changing setup * changing the pendingReceipt List * using scheduled fixed rate * using blocked queues * using blocked queues * using blocked queues * adding null safety * adding null safety * removing list * adding list back * if permanent failure, remove outstandingmsg from queue * adding snippet of test * adding method to streaming subscriber * adding method to streaming subscriber * adding notifyAcks * changing notifyAckFailed calls * addressing some comments * changed logic to use one datastructure * fixing notifyFailed * fixing notifyFailed * changing Pair to custom class * removing the not needed data structure * Fixing test * Fixing test * Fixing test * Fixing test * fixing format * fixing test to call receiveMessage * testing test failure * testing test failure * testing test failure * increasing timestamp to test * increasing timestamp to test * adding log statement for testing * Fixing lint * Adding more logs * batch size log * changing method to syncronized * fixing for loop to not remove as we are iterating * trying a concurrent map * fix: syncronizing notifyFailed * fix: removing unused import * fix: reformat * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * fix: removing System.out.println statements * fix: reviewign comments * fix: lint * adding another ordering key test example * fix: trying to run this test again * fix: trying to run this test again * fix: removing commented code * fix: removing commented code * resolving the comments from review * adding custom matcher * adding custom matcher * adding custom matcher * adding custom matcher * adding custom matcher correcting the matching statement * lint * removing comments * removing comments * removing comments * changing messageMatcher to messageDataMatcher, and fixing other nit things * lint * addressing review comments * addressing review comments --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

add back PubSub samples

8859c23

pongad assigned garrettjonesgoogle Jan 16, 2017

googlebot added the cla: yes This human has signed the Contributor License Agreement. label Jan 16, 2017

garrettjonesgoogle reviewed Jan 17, 2017

View reviewed changes

PR comments

7b2cac7

garrettjonesgoogle reviewed Jan 18, 2017

View reviewed changes

pongad added 2 commits January 19, 2017 10:00

Merge branch 'pubsub-rm' into pub-doc

1254596

PR comment

3cdda88

split creating message id future

5100324

pongad merged commit d70aaf7 into googleapis:pubsub-rm Jan 19, 2017

pongad deleted the pub-doc branch January 19, 2017 01:01

chingor13 pushed a commit that referenced this pull request Jan 22, 2026

chore(main): release 2.21.1 (#1540)

a9e90f3

Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>

suztomo pushed a commit to suztomo/google-cloud-java that referenced this pull request Mar 23, 2026

deps: update dependency org.springframework.boot:spring-boot-starter-…

0fbf884

…data-jdbc to v3.2.4 (googleapis#1540)

suztomo pushed a commit that referenced this pull request Mar 30, 2026

chore(deps): update dependency com.google.cloud:google-cloud-nio to v…

fb6dd49

…0.127.31 (#1540)

lqiu96 pushed a commit that referenced this pull request Apr 1, 2026

chore(deps): update dependency com.google.cloud:google-cloud-nio to v…

49e84aa

…0.127.31 (#1540)

		@@ -142,6 +143,10 @@ public static Builder newBuilder(String subscription, MessageReceiver receiver)
		return new Builder(subscription, receiver);

		@@ -186,6 +187,10 @@ public static Builder newBuilder(String topic) {
		return new Builder(topic);

Conversation

pongad commented Jan 16, 2017

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

pongad commented Jan 18, 2017

Uh oh!

coveralls commented Jan 18, 2017

Uh oh!

This comment was marked as spam.

Uh oh!

pongad commented Jan 18, 2017

Uh oh!

garrettjonesgoogle commented Jan 19, 2017

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants