commit 3fa417f8da7cf28fa94307b15a266163d815ce13
author nkurihar <nkurihar@apache.org> Thu Jun 13 13:10:20 2019 +0900
committer GitHub <noreply@github.com> Thu Jun 13 13:10:20 2019 +0900
tree 5863290df0d8200ffe91375b199614e8d14d48b4
parent 1d03ff69c57f6e2d105c606e56eaa297817f0975
parent d95f5d155bab1671908e2925667d676c69934672

Merge pull request #34 from shustsud/Add_subscription_type_to_examples

Add subscription type to examples.

tests/end_to_end.test.js

diff --git a/tests/end_to_end.test.js b/tests/end_to_end.test.js
index 5387cdd..b713d99 100644
--- a/tests/end_to_end.test.js
+++ b/tests/end_to_end.test.js
@@ -29,15 +29,16 @@
         operationTimeoutSeconds: 30,
       });
 
+      const topic = 'persistent://public/default/produce-consume';
       const producer = await client.createProducer({
-        topic: 'persistent://public/default/test-end-to-end',
+        topic,
         sendTimeoutMs: 30000,
         batchingEnabled: true,
       });
       expect(producer).not.toBeNull();
 
       const consumer = await client.subscribe({
-        topic: 'persistent://public/default/test-end-to-end',
+        topic,
         subscription: 'sub1',
         ackTimeoutMs: 10000,
       });
@@ -73,15 +74,16 @@
         operationTimeoutSeconds: 30,
       });
 
+      const topic = 'persistent://public/default/acknowledgeCumulative';
       const producer = await client.createProducer({
-        topic: 'persistent://public/default/acknowledgeCumulative',
+        topic,
         sendTimeoutMs: 30000,
         batchingEnabled: true,
       });
       expect(producer).not.toBeNull();
 
       const consumer = await client.subscribe({
-        topic: 'persistent://public/default/acknowledgeCumulative',
+        topic,
         subscription: 'sub1',
         ackTimeoutMs: 10000,
       });
@@ -118,15 +120,16 @@
       });
       expect(client).not.toBeNull();
 
+      const topic = 'persistent://public/default/produce-read';
       const producer = await client.createProducer({
-        topic: 'persistent://public/default/test-end-to-end',
+        topic,
         sendTimeoutMs: 30000,
         batchingEnabled: true,
       });
       expect(producer).not.toBeNull();
 
       const reader = await client.createReader({
-        topic: 'persistent://public/default/test-end-to-end',
+        topic,
         startMessageId: Pulsar.MessageId.latest(),
       });
       expect(reader).not.toBeNull();