googleapis
diff --git a/‎packages/google-cloud-pubsub/samples/snippets/publisher.py‎
Lines changed: 33 additions & 0 deletions b/‎packages/google-cloud-pubsub/samples/snippets/publisher.py‎
Lines changed: 33 additions & 0 deletions
diff --git a/‎packages/google-cloud-pubsub/samples/snippets/requirements.txt‎
Lines changed: 2 additions & 1 deletion b/‎packages/google-cloud-pubsub/samples/snippets/requirements.txt‎
Lines changed: 2 additions & 1 deletion
@@ -22,6 +22,7 @@
 """
 
 import argparse
+import concurrent.futures
 
 from google.cloud import pubsub_v1
 
@@ -123,6 +124,38 @@ def publish_messages_with_futures(project, topic_name):
     # [END pubsub_publisher_concurrency_control]
 
 
+def publish_messages_with_error_handler(project, topic_name):
+    """Publishes multiple messages to a Pub/Sub topic with an error handler."""
+    # [START pubsub_publish_messages_error_handler]
+    publisher = pubsub_v1.PublisherClient()
+    topic_path = publisher.topic_path(project, topic_name)
+
+    # When you publish a message, the client returns a Future. This Future
+    # can be used to track if an error has occurred.
+    futures = []
+
+    def callback(f):
+        exc = f.exception()
+        if exc:
+            print('Publishing message on {} threw an Exception {}.'.format(
+                topic_name, exc))
+
+    for n in range(1, 10):
+        data = u'Message number {}'.format(n)
+        # Data must be a bytestring
+        data = data.encode('utf-8')
+        message_future = publisher.publish(topic_path, data=data)
+        message_future.add_done_callback(callback)
+        futures.append(message_future)
+
+    # We must keep the main thread from exiting to allow it to process
+    # messages in the background.
+    concurrent.futures.wait(futures)
+
+    print('Published messages.')
+    # [END pubsub_publish_messages_error_handler]
+
+
 def publish_messages_with_batch_settings(project, topic_name):
     """Publishes multiple messages to a Pub/Sub topic with batch settings."""
     # [START pubsub_publisher_batch_settings]
 
@@ -1 +1,2 @@
-google-cloud-pubsub==0.33.0
+google-cloud-pubsub==0.32.1
+futures==3.1.1; python_version < '3'
Original file line number	Diff line number	Diff line change
@@ -1 +1,2 @@
1		- google-cloud-pubsub==0.33.0
	1	+ google-cloud-pubsub==0.32.1
	2	+ futures==3.1.1; python_version < '3'