diff --git a/go.mod b/go.mod index 8b697264e..e90974907 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/ThreeDotsLabs/watermill +module github.com/golang-boy/watermill go 1.17 diff --git a/pubsub/gochannel/pubsub.go b/pubsub/gochannel/pubsub.go index f47d0ca2b..3754c1963 100644 --- a/pubsub/gochannel/pubsub.go +++ b/pubsub/gochannel/pubsub.go @@ -142,8 +142,9 @@ func (g *GoChannel) sendMessage(topic string, message *message.Message) (<-chan if len(subscribers) == 0 { close(ackedBySubscribers) - g.logger.Info("No subscribers to send message", logFields) - return ackedBySubscribers, nil + err := errors.New("No subscribers") + g.logger.Error("No subscribers to send message", err, logFields) + return ackedBySubscribers, err } go func(subscribers []*subscriber) {