diff --git a/internal/usecases/produce/publishmessage.go b/internal/usecases/produce/publishmessage.go
index 1b46dd4239d7822db3b8413dfb8f764913baa44c..8e9b31e8cef943c1f75df320bce91b1c531a5a98 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)
 }