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 06:29:07 UTC
[pulsar-client-node] 30/36: name topics test title
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
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();