fix: consumer pkg uses proper logger (#591)

Author: alexluong

internal/consumer/consumer.go

@@ -2,10 +2,11 @@ package consumer
 
 import (
 	"context"
-	"log"
 
+	"github.com/hookdeck/outpost/internal/logging"
 	"github.com/hookdeck/outpost/internal/mqs"
 	"go.opentelemetry.io/otel"
+	"go.uber.org/zap"
 )
 
 type Consumer interface {
@@ -19,6 +20,7 @@ type MessageHandler interface {
 type consumerImplOptions struct {
 	name        string
 	concurrency int
+	logger      *logging.Logger
 }
 
 func WithName(name string) func(*consumerImplOptions) {
@@ -33,6 +35,12 @@ func WithConcurrency(concurrency int) func(*consumerImplOptions) {
 	}
 }
 
+func WithLogger(logger *logging.Logger) func(*consumerImplOptions) {
+	return func(c *consumerImplOptions) {
+		c.logger = logger
+	}
+}
+
 func New(subscription mqs.Subscription, handler MessageHandler, opts ...func(*consumerImplOptions)) Consumer {
 	options := &consumerImplOptions{
 		name:        "",
@@ -86,10 +94,11 @@ recvLoop:
 			defer span.End()
 
 			err = c.handler.Handle(handlerCtx, msg)
-			// TODO: error handling?
 			if err != nil {
 				span.RecordError(err)
-				log.Printf("consumer handler error: %v", err)
+				if c.logger != nil {
+					c.logger.Ctx(handlerCtx).Error("consumer handler error", zap.String("name", c.name), zap.Error(err))
+				}
 			}
 		}()
 	}

internal/services/consumer_worker.go

@@ -57,6 +57,7 @@ func (w *ConsumerWorker) Run(ctx context.Context) error {
 	csm := consumer.New(subscription, w.handler,
 		consumer.WithName(w.name),
 		consumer.WithConcurrency(w.concurrency),
+		consumer.WithLogger(w.logger),
 	)
 
 	if err := csm.Run(ctx); err != nil {