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 <[email protected]> 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();
