aljaz/lndhub.go
1
1
Fork 0
mirror of https://github.com/getAlby/lndhub.go.git synced 2025-12-23 23:55:02 +01:00
Code Issues Packages Projects Releases Wiki Activity

prefix instead of suffix routing key

Browse Source
This commit is contained in:
Lucas Rouckhout
2023-02-18 16:39:46 +01:00
parent 90929134cb
commit 6f63758ab1
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
lib/service/rabbitmq.go
View File

@@ -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) { 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) user, err := svc.FindUser(context.Background(), invoice.UserID)
if err != nil { if err != nil {