Merge branch 'master' into update-sql-v3

Author: roblaszczak

docs/content/docs/awesome.md

@@ -30,6 +30,7 @@ If you know another library or are an author of one, please [add it to the list]
 * MongoDB https://github.com/cunyat/watermill-mongodb
 * MQTT https://github.com/perfect13/watermill-mqtt
 * NSQ https://github.com/chennqqi/watermill-nsq
+* Redis Zset https://github.com/stong1994/watermill-rediszset
 
 ### Logging
 

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))
@@ -1214,7 +1214,7 @@ func assertConsumerGroupReceivedMessages(
 }
 
 func testTopicName(testID TestID) string {
-	return "topic_" + string(testID)
+	return "topic-" + string(testID)
 }
 
 func closePubSub(t *testing.T, pub message.Publisher, sub message.Subscriber) {