feat: Add logging for successfully handling message

imulab · Oct 31, 2023 · bf101f2 · bf101f2
1 parent 5c46a37
commit bf101f2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cmd/listener/cmd.go b/cmd/listener/cmd.go
@@ -104,7 +104,10 @@ func newMqttClient(c *config, logger *zerolog.Logger, subscribers []wt.Subscribe
 		router.RegisterHandler(s.Option().Topic, func(p *paho.Publish) {
 			if handleErr := s.Handle(p); handleErr != nil {
 				logger.Err(handleErr).Str("topic", p.Topic).Msg("failed to handle message")
+				return
 			}
+
+			logger.Info().Str("topic", p.Topic).Msg("handled message")
 		})
 	}