diff --git a/bus.go b/bus.go
index 85d466b..0d1263d 100644
--- 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
 		}