diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index 9a27ba1eb..8b3d47a44 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -113,10 +113,10 @@ func (r *Inputer) Start() error {
 						"type":     inputRoomEvent.Event.Type(),
 					}).Warn("Roomserver failed to process async event")
 				}
-				if !retry {
-					_ = msg.Ack()
-				} else {
+				if retry {
 					_ = msg.Nak()
+				} else {
+					_ = msg.Ack()
 				}
 			})
 		},