Fix stress test add added more tests debug (#106)

message/infrastructure/bench_pubsub.go

@@ -13,7 +13,7 @@ type BenchmarkPubSubConstructor func(n int) (message.Publisher, message.Subscrib
 
 func BenchSubscriber(b *testing.B, pubSubConstructor BenchmarkPubSubConstructor) {
 	pub, sub := pubSubConstructor(b.N)
-	topicName := testTopicName()
+	topicName := testTopicName(NewTestID())
 
 	messages, err := sub.Subscribe(context.Background(), topicName)
 	if err != nil {

message/infrastructure/gochannel/pubsub_stress_test.go

@@ -0,0 +1,24 @@
+// +build stress
+
+package gochannel_test
+
+import (
+	"testing"
+
+	"github.com/ThreeDotsLabs/watermill/message/infrastructure"
+)
+
+func TestPublishSubscribe_stress(t *testing.T) {
+	infrastructure.TestPubSubStressTest(
+		t,
+		infrastructure.Features{
+			ConsumerGroups:        false,
+			ExactlyOnceDelivery:   true,
+			GuaranteedOrder:       false,
+			Persistent:            false,
+			RequireSingleInstance: true,
+		},
+		createPersistentPubSub,
+		nil,
+	)
+}

message/infrastructure/gochannel/pubsub_test.go

@@ -55,7 +55,7 @@ func TestPublishSubscribe_not_persistent(t *testing.T) {
 	msgs, err := pubSub.Subscribe(context.Background(), topicName)
 	require.NoError(t, err)
 
-	sendMessages := infrastructure.AddSimpleMessages(t, messagesCount, pubSub, topicName)
+	sendMessages := infrastructure.PublishSimpleMessages(t, messagesCount, pubSub, topicName)
 	receivedMsgs, _ := subscriber.BulkRead(msgs, messagesCount, time.Second)
 
 	infrastructure.AssertAllMessagesReceived(t, sendMessages, receivedMsgs)