Add Expires time to Confirm events

ella-to · Aug 18, 2024 · 6f3ed3e · 6f3ed3e
1 parent 5f87fe1
commit 6f3ed3e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/bus.go b/bus.go
@@ -235,7 +235,11 @@ func (m *Msg) Ack(ctx context.Context) error {
 	}
 
 	for replySubject := range m.replyConfirms {
-		confirmEvent, err := NewEvent(WithSubject(replySubject), WithData(confirmMsg))
+		confirmEvent, err := NewEvent(
+			WithSubject(replySubject),
+			WithData(confirmMsg),
+			WithExpiresAt(30*time.Second),
+		)
 		if err != nil {
 			return err
 		}