fix(mailman): check on startup and fix trace

ItsNotGoodName · Sep 16, 2023 · 76bd9c9 · 76bd9c9
1 parent 69ba72e
commit 76bd9c9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/mailman/mailman.go b/internal/mailman/mailman.go
@@ -32,6 +32,8 @@ func New(id int, app core.App, bus core.Bus, fileStore endpoint.FileStore, endpo
 
 func (m Mailman) Serve(ctx context.Context) error {
 	checkC := make(chan struct{}, 1)
+	checkC <- struct{}{}
+
 	release := m.bus.OnMailmanEnqueued(func(ctx context.Context, evt models.EventMailmanEnqueued) error {
 		select {
 		case checkC <- struct{}{}:
@@ -65,7 +67,7 @@ func (m Mailman) Serve(ctx context.Context) error {
 				}
 				env := *maybeEnv
 
-				tracer = tracer.Sticky(trace.WithEnvelope(env.Message.ID))
+				tracer := tracer.Sticky(trace.WithEnvelope(env.Message.ID))
 
 				if err := m.send(ctx, tracer, env); err != nil {
 					tracer.Trace(ctx, "mailman.error", trace.WithError(err))