@@ -182,7 +182,7 @@ func setupSubscriber[T any](
183 case event, ok := <-subCh:
183 case event, ok := <-subCh:
185− logging.Info("%s subscription channel closed", name)
185+ logging.Info("subscription channel closed", "name", name)
@@ -191,13 +191,13 @@ func setupSubscriber[T any](
192 case outputCh <- msg:
192 case outputCh <- msg:
193 case <-time.After(2 * time.Second):
193 case <-time.After(2 * time.Second):
194− logging.Warn("%s message dropped due to slow consumer", name)
194+ logging.Warn("message dropped due to slow consumer", "name", name)
195 case <-ctx.Done():
195 case <-ctx.Done():
196− logging.Info("%s subscription cancelled", name)
196+ logging.Info("subscription cancelled", "name", name)
199 case <-ctx.Done():
199 case <-ctx.Done():
200− logging.Info("%s subscription cancelled", name)
200+ logging.Info("subscription cancelled", "name", name)