From 6f63758ab1742c88d75d2cd39619c514b9ad1ef5 Mon Sep 17 00:00:00 2001
From: Lucas Rouckhout <lucas.rouckhout@showpad.com>
Date: Sat, 18 Feb 2023 16:39:46 +0100
Subject: [PATCH] prefix instead of suffix routing key

---
 lib/service/rabbitmq.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/service/rabbitmq.go b/lib/service/rabbitmq.go
index de489f0..62c6a2c 100644
--- a/lib/service/rabbitmq.go
+++ b/lib/service/rabbitmq.go
@@ -73,7 +73,7 @@ func (svc *LndhubService) StartRabbitMqPublisher(ctx context.Context) error {
 }
 
 func (svc *LndhubService) publishInvoice(ctx context.Context, invoice models.Invoice, ch *amqp.Channel) {
-	key := fmt.Sprintf("%s.%s.invoice", invoice.Type, invoice.State)
+	key := fmt.Sprintf("invoice.%s.%s", invoice.Type, invoice.State)
 
 	user, err := svc.FindUser(context.Background(), invoice.UserID)
 	if err != nil {