From 1b62170927a199435d7119814275ecdc2b33aed0 Mon Sep 17 00:00:00 2001 From: yfuruta Date: Thu, 13 Jun 2019 11:17:50 +0900 Subject: [PATCH] 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 5387cddbce1e44..b713d996a60d76 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();