From f42ecbb8966bfbdb3b65d23ab07963d157944d5f Mon Sep 17 00:00:00 2001
From: thijsheijden <hi@thijsheijden.nl>
Date: Mon, 19 Apr 2021 21:00:55 +0200
Subject: [PATCH] Changed up some comments and fixed linting
---
internal/drivers/brokerdriver/mock/consumer.go | 6 +++---
internal/drivers/brokerdriver/mock/producer.go | 3 ++-
2 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/internal/drivers/brokerdriver/mock/consumer.go b/internal/drivers/brokerdriver/mock/consumer.go
index b339126..9118043 100644
--- a/internal/drivers/brokerdriver/mock/consumer.go
+++ b/internal/drivers/brokerdriver/mock/consumer.go
@@ -2,17 +2,17 @@ package mockbrokerdriver
import "query-service/internal/adapters/brokeradapter"
-// Consumer is a mock consumer
+// A Consumer implements the consumer interface (mock)
type Consumer struct {
broker *Driver
}
-// ConsumeMessages mocks the consume messages func
+// ConsumeMessages consumes messages from the broker (mock)
func (c *Consumer) ConsumeMessages() {
}
-// SetMessageHandler mocks the setting of a message handler
+// SetMessageHandler mocks the setting of a message handler (mock)
func (c *Consumer) SetMessageHandler(handler func(msg *brokeradapter.Message)) {
}
diff --git a/internal/drivers/brokerdriver/mock/producer.go b/internal/drivers/brokerdriver/mock/producer.go
index d92435b..1367971 100644
--- a/internal/drivers/brokerdriver/mock/producer.go
+++ b/internal/drivers/brokerdriver/mock/producer.go
@@ -6,6 +6,7 @@ import (
"github.com/streadway/amqp"
)
+// A Producer implements the producer interface (mock)
type Producer struct {
broker *Driver
@@ -13,7 +14,7 @@ type Producer struct {
exchange string
}
-// PublishMessage publishes a message to the given queue
+// PublishMessage publishes a message to the given queue (mock)
func (p *Producer) PublishMessage(body *[]byte, routingKey *string, headers *amqp.Table) {
// Create the message
msg := brokeradapter.Message{
--
GitLab