docs(samples): Publish with Retry Setting Example

samples/README.md

@@ -89,16 +89,17 @@ __Usage:__ `node topics.js --help`
 topics.js <command>
 
 Commands:
-  topics.js list                                      Lists all topics in the current project.
-  topics.js create <topicName>                        Creates a new topic.
-  topics.js delete <topicName>                        Deletes a topic.
-  topics.js publish <topicName> <message>             Publishes a message to a topic.
-  topics.js publish-attributes <topicName> <message>  Publishes a message with custom attributes to a Topic
-  topics.js publish-batch <topicName> <message>       Publishes messages to a topic using custom batching settings.
-  topics.js publish-ordered <topicName> <message>     Publishes an ordered message to a topic.
-  topics.js get-policy <topicName>                    Gets the IAM policy for a topic.
-  topics.js set-policy <topicName>                    Sets the IAM policy for a topic.
-  topics.js test-permissions <topicName>              Tests the permissions for a topic.
+  topics.js list                                            Lists all topics in the current project.
+  topics.js create <topicName>                              Creates a new topic.
+  topics.js delete <topicName>                              Deletes a topic.
+  topics.js publish <topicName> <message>                   Publishes a message to a topic.
+  topics.js publish-attributes <topicName> <message>        Publishes a message with custom attributes to a Topic
+  topics.js publish-batch <topicName> <message>             Publishes messages to a topic using custom batching settings.
+  topics.js publish-retry <projectId> <topicName> <message> Publishes a message to a topic with retry settings.
+  topics.js publish-ordered <topicName> <message>           Publishes an ordered message to a topic.
+  topics.js get-policy <topicName>                          Gets the IAM policy for a topic.
+  topics.js set-policy <topicName>                          Sets the IAM policy for a topic.
+  topics.js test-permissions <topicName>                    Tests the permissions for a topic.
 
 Options:
   --version  Show version number                                                                               [boolean]

samples/system-test/topics.test.js

@@ -30,6 +30,7 @@ const topicNameTwo = `nodejs-docs-samples-test-${uuid.v4()}`;
 const subscriptionNameOne = `nodejs-docs-samples-test-${uuid.v4()}`;
 const subscriptionNameTwo = `nodejs-docs-samples-test-${uuid.v4()}`;
 const subscriptionNameThree = `nodejs-docs-samples-test-${uuid.v4()}`;
+const subscriptionNameFour = `nodejs-docs-samples-test-${uuid.v4()}`;
 const fullTopicNameOne = `projects/${projectId}/topics/${topicNameOne}`;
 const expectedMessage = {data: `Hello, world!`};
 const cmd = `node topics.js`;
@@ -54,6 +55,9 @@ after(async () => {
   try {
     await pubsub.subscription(subscriptionNameThree).delete();
   } catch (err) {} // ignore error
+  try {
+    await pubsub.subscription(subscriptionNameFour).delete();
+  } catch (err) {} // ignore error
   try {
     await pubsub.topic(topicNameTwo).delete();
   } catch (err) {} // ignore error
@@ -196,6 +200,21 @@ it(`should publish with specific batch settings`, async () => {
   assert.strictEqual(publishTime - startTime > expectedWait, true);
 });
 
+it(`should publish with retry settings`, async () => {
+  const [subscription] = await pubsub
+    .topic(topicNameOne)
+    .subscription(subscriptionNameFour)
+    .get({autoCreate: true});
+  await tools.runAsync(
+    `${cmd} publish-retry ${projectId} ${topicNameOne} "${
+      expectedMessage.data
+    }"`,
+    cwd
+  );
+  const receivedMessage = await _pullOneMessage(subscription);
+  assert.strictEqual(receivedMessage.data.toString(), expectedMessage.data);
+});
+
 it(`should set the IAM policy for a topic`, async () => {
   await tools.runAsync(`${cmd} set-policy ${topicNameOne}`, cwd);
   const results = await pubsub.topic(topicNameOne).iam.getPolicy();

samples/topics.js

@@ -175,6 +175,60 @@ async function publishBatchedMessages(
   // [END pubsub_publisher_batch_settings]
 }
 
+async function publishWithRetrySettings(projectId, topicName, data) {
+  // [START pubsub_publisher_retry_settings]
+  // Imports the Google Cloud client library
+  const PubSub = require('@google-cloud/pubsub');
+
+  // Creates a publisher client
+  const client = new PubSub.v1.PublisherClient({
+    // optional auth parameters
+  });
+
+  /**
+   * TODO(developer): Uncomment the following lines to run the sample.
+   */
+  // const projectId = 'my-project-id'
+  // const topicName = 'my-topic';
+  // const data = JSON.stringify({ foo: 'bar' });
+
+  const formattedTopic = client.topicPath(projectId, topicName);
+  // Publishes the message as a string, e.g. "Hello, world!" or JSON.stringify(someObject)
+  const dataBuffer = Buffer.from(data);
+  const messagesElement = {
+    data: dataBuffer,
+  };
+  const messages = [messagesElement];
+  // Build the request
+  const request = {
+    topic: formattedTopic,
+    messages: messages,
+  };
+
+  // Retry settings control how the publisher handles retryable failures
+  // Default values are shown
+  const retrySettings = {
+    retry_codes: {
+      idempotent: ['UNAVAILABLE', 'DEADLINE_EXCEEDED'],
+      non_idempotent: [],
+    },
+    backoffSettings: {
+      initial_retry_delay_millis: 100,
+      retry_delay_multiplier: 1.2,
+      max_retry_delay_millis: 1000,
+      initial_rpc_timeout_millis: 2000,
+      rpc_timeout_multiplier: 1.5,
+      max_rpc_timeout_millis: 30000,
+      total_timeout_millis: 45000,
+    },
+  };
+
+  const [response] = await client.publish(request, {retry: retrySettings});
+  console.log(`Message ${response.messageIds} published.`);
+
+  // [END pubsub_publisher_retry_settings]
+}
+
 let publishCounterValue = 1;
 
 function getPublishCounterValue() {
@@ -361,6 +415,14 @@ const cli = require(`yargs`)
       );
     }
   )
+  .command(
+    `publish-retry <projectId> <topicName> <message>`,
+    `Publishes a message to a topic with retry settings.`,
+    {},
+    opts => {
+      publishWithRetrySettings(opts.projectId, opts.topicName, opts.message);
+    }
+  )
   .command(
     `publish-ordered <topicName> <message>`,
     `Publishes an ordered message to a topic.`,
@@ -400,6 +462,7 @@ const cli = require(`yargs`)
   .example(`node $0 publish-attributes my-topic "Hello, world!"`)
   .example(`node $0 publish-ordered my-topic "Hello, world!"`)
   .example(`node $0 publish-batch my-topic "Hello, world!" -w 1000`)
+  .example(`node $0 publish-retry my-project my-topic "Hello, world!"`)
   .example(`node $0 get-policy greetings`)
   .example(`node $0 set-policy greetings`)
   .example(`node $0 test-permissions greetings`)