Initialize subscribers for each consumer group (#225)

Co-authored-by: Lucas Bremgartner <lucas@elblox.com>
ThreeDotsLabs · Apr 4, 2021 · f7f908f · f7f908f
1 parent e083ac2
commit f7f908f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pubsub/tests/test_pubsub.go b/pubsub/tests/test_pubsub.go
@@ -1189,6 +1189,9 @@ func generateConsumerGroup(t *testing.T, pubSubConstructor ConsumerGroupPubSubCo
 	// create a pubsub to ensure that the consumer group exists
 	// for those providers that require subscription before publishing messages (e.g. Google Cloud PubSub)
 	pub, sub := pubSubConstructor(t, groupName)
+	if subInitializer, ok := sub.(message.SubscribeInitializer); ok {
+		require.NoError(t, subInitializer.SubscribeInitialize(topicName))
+	}
 	_, err := sub.Subscribe(context.Background(), topicName)
 	require.NoError(t, err)
 	closePubSub(t, pub, sub)