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

[pulsar-client-node] 30/45: name topics test title

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 1b62170927a199435d7119814275ecdc2b33aed0
Author: yfuruta <yf...@yahoo-corp.jp>
AuthorDate: Thu Jun 13 11:17:50 2019 +0900

    name topics test title
---
 tests/end_to_end.test.js | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

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 @@ const Pulsar = require('../index.js');
         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 @@ const Pulsar = require('../index.js');
         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 @@ const Pulsar = require('../index.js');
       });
       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();