Letting compensate method return error

thumperware · Jun 26, 2022 · 187c959 · 187c959
1 parent a2252ee
commit 187c959
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/internal/consumer/handler_command.go b/internal/consumer/handler_command.go
@@ -96,9 +96,14 @@ func (h *handlerCommand[T]) retry(msgBytes []byte) {
 }
 
 func (h *handlerCommand[T]) compensate(consumerMsg handler.HandlerMessage[T]) {
+	methodPath := reflection.MethodPath(h.compensate)
 	compensateMsgStream := make(chan handler.HandlerMessage[T])
 	go func(consumerMsg handler.HandlerMessage[T]) {
-		h.handler.Compensate(compensateMsgStream)
+		err := h.handler.Compensate(compensateMsgStream)
+		if err != nil {
+			log.Default().Println(formatter.FormatErr(methodPath, err))
+			return
+		}
 	}(consumerMsg)
 	compensateMsgStream <- consumerMsg
 }
diff --git a/pkg/handler/handler.go b/pkg/handler/handler.go
@@ -8,7 +8,7 @@ type IMessage interface {
 
 type IHandler[T IMessage] interface {
 	Handle(msg <-chan HandlerMessage[T]) error
-	Compensate(msg <-chan HandlerMessage[T])
+	Compensate(msg <-chan HandlerMessage[T]) error
 }
 
 type HandlerMessage[T IMessage] struct {