From 9d4f7830b1ef1b16b83e5c91279e02d0417a5cf2 Mon Sep 17 00:00:00 2001 From: Andrzej Lichnerowicz Date: Tue, 5 Mar 2024 13:34:32 +0100 Subject: [PATCH] Add missed topic names (#426) --- pubsub/tests/test_pubsub.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pubsub/tests/test_pubsub.go b/pubsub/tests/test_pubsub.go index 873ac6412..4defb7633 100644 --- a/pubsub/tests/test_pubsub.go +++ b/pubsub/tests/test_pubsub.go @@ -332,7 +332,7 @@ func TestConcurrentSubscribeMultipleTopics( receivedMessagesCh := make(chan message.Messages, topicsCount) for i := 0; i < topicsCount; i++ { - topicName := testTopicName(tCtx.TestID) + fmt.Sprintf("_%d", i) + topicName := testTopicName(tCtx.TestID) + fmt.Sprintf("-%d", i) go func() { defer subsWg.Done() @@ -850,8 +850,8 @@ func TestTopic( pub, sub := pubSubConstructor(t) defer closePubSub(t, pub, sub) - topic1 := testTopicName(tCtx.TestID) + "_1" - topic2 := testTopicName(tCtx.TestID) + "_2" + topic1 := testTopicName(tCtx.TestID) + "-1" + topic2 := testTopicName(tCtx.TestID) + "-2" if subscribeInitializer, ok := sub.(message.SubscribeInitializer); ok { require.NoError(t, subscribeInitializer.SubscribeInitialize(topic1))