style: better output formatting for processor

ShatteredRealms · Dec 11, 2024 · 3f51fcf · 3f51fcf
1 parent 8a93e64
commit 3f51fcf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/bus/processor.go b/pkg/bus/processor.go
@@ -50,7 +50,7 @@ func (bp *DefaultBusProcessor[T]) StartProcessing(ctx context.Context) {
 			bp.mu.Unlock()
 		}()
 
-		log.Logger.WithContext(ctx).Infof("Starting bus processor for %T", bp.Reader)
+		log.Logger.WithContext(ctx).Infof("Starting bus processor for %s", bp.Reader.GetMessageType())
 		for bp.isProcessing {
 			err := bp.process(ctx)
 			if errors.Is(err, ErrProcessingFailed) {
@@ -122,6 +122,6 @@ func (bp *DefaultBusProcessor[T]) StopProcessing() {
 		return
 	}
 
-	log.Logger.Infof("Stopping bus processor for	%T", bp.Reader)
+	log.Logger.Infof("Stopping bus processor for %s", bp.Reader.GetMessageType())
 	bp.isProcessing = false
 }