You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by nk...@apache.org on 2019/06/13 04:10:24 UTC

[pulsar-client-node] branch master updated: Add subscription type to examples.

This is an automated email from the ASF dual-hosted git repository.

nkurihar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git


The following commit(s) were added to refs/heads/master by this push:
     new d95f5d1  Add subscription type to examples.
     new 3fa417f  Merge pull request #34 from shustsud/Add_subscription_type_to_examples
d95f5d1 is described below

commit d95f5d155bab1671908e2925667d676c69934672
Author: shustsud <sh...@yahoo-corp.jp>
AuthorDate: Thu Jun 13 11:43:29 2019 +0900

    Add subscription type to examples.
    
    Add subscription type to examples.
---
 examples/consumer.js          | 1 +
 examples/consumer_tls_auth.js | 1 +
 2 files changed, 2 insertions(+)

diff --git a/examples/consumer.js b/examples/consumer.js
index c754ac3..f0b370d 100644
--- a/examples/consumer.js
+++ b/examples/consumer.js
@@ -30,6 +30,7 @@ const Pulsar = require('../index.js');
   const consumer = await client.subscribe({
     topic: 'persistent://public/default/my-topic',
     subscription: 'sub1',
+    subscriptionType: 'Shared',
     ackTimeoutMs: 10000,
   });
 
diff --git a/examples/consumer_tls_auth.js b/examples/consumer_tls_auth.js
index e71b251..7f846c5 100644
--- a/examples/consumer_tls_auth.js
+++ b/examples/consumer_tls_auth.js
@@ -36,6 +36,7 @@ const Pulsar = require('../index.js');
   const consumer = await client.subscribe({
     topic: 'persistent://public/default/my-topic',
     subscription: 'sub1',
+    subscriptionType: 'Shared',
   });
 
   // Receive messages