This is an automated email from the ASF dual-hosted git repository. massakam pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git
commit d95f5d155bab1671908e2925667d676c69934672 Author: shustsud <[email protected]> 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
