fix: generic pubsub

Author: ochom

pubsub/publisher.go

@@ -1,6 +1,7 @@
 package pubsub
 
 import (
+	"fmt"
 	"time"
 
 	"github.com/streadway/amqp"
@@ -22,14 +23,13 @@ func NewPublisher(rabbitURL, exchange, queue string) *publisher {
 func (p *publisher) publish(body []byte, delay time.Duration) error {
 	conn, ch, err := initQ(p.url)
 	if err != nil {
-		return err
+		return fmt.Errorf("failed to initialize a connection: %s", err.Error())
 	}
-
 	defer ch.Close()
 	defer conn.Close()
 
 	if err := initPubSub(ch, p.exchange, p.queue); err != nil {
-		return err
+		return fmt.Errorf("failed to initialize a pubsub: %s", err.Error())
 	}
 
 	// publish message to exchange

pubsub/pubsub.go

@@ -9,17 +9,17 @@ import (
 func initQ(url string) (*amqp.Connection, *amqp.Channel, error) {
 	conn, err := amqp.Dial(url)
 	if err != nil {
-		return nil, nil, err
+		return nil, nil, fmt.Errorf("failed to connect to RabbitMQ: %s", err.Error())
 	}
 
 	ch, err := conn.Channel()
 	if err != nil {
-		return nil, nil, err
+		return nil, nil, fmt.Errorf("failed to open a channel: %s", err.Error())
 	}
 
 	err = ch.Qos(1, 0, false) // fair dispatch
 	if err != nil {
-		return nil, nil, err
+		return nil, nil, fmt.Errorf("failed to set QoS: %s", err.Error())
 	}
 
 	return conn, ch, nil