Skip to content
Snippets Groups Projects
Commit f42ecbb8 authored by thijsheijden's avatar thijsheijden
Browse files

Changed up some comments and fixed linting

parent 7de7083e
No related branches found
No related tags found
No related merge requests found
......@@ -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)) {
}
......@@ -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{
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment