From 8fc180ff6a6ff2444d612c52ec3e84e5522e15e4 Mon Sep 17 00:00:00 2001
From: thijsheijden <hi@thijsheijden.nl>
Date: Tue, 20 Apr 2021 14:57:52 +0200
Subject: [PATCH] Fixed pointer typo in publishmessage
---
internal/usecases/produce/publishmessage.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/internal/usecases/produce/publishmessage.go b/internal/usecases/produce/publishmessage.go
index 1b46dd4..8e9b31e 100644
--- a/internal/usecases/produce/publishmessage.go
+++ b/internal/usecases/produce/publishmessage.go
@@ -16,7 +16,7 @@ func (s *Service) PublishMessage(data *[]byte, sessionID *string) {
}
headers := amqp.Table{}
- headers["sessionID"] = sessionID
+ headers["sessionID"] = *sessionID
headers["type"] = "queryResult"
s.producerDriver.PublishMessage(data, &clientQueueID, &headers)
}
--
GitLab