diff --git a/integration_tests/rabbitmq_test.go b/integration_tests/rabbitmq_test.go
index 175f339..e471756 100644
--- a/integration_tests/rabbitmq_test.go
+++ b/integration_tests/rabbitmq_test.go
@@ -88,7 +88,7 @@ func (suite *RabbitMQTestSuite) TestPublishInvoice() {
 
 	m, err := ch.Consume(
 		q.Name,
-		"",
+		"#.#.invoice",
 		true,
 		false,
 		false,