diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index 47844e0f6..076e18d90 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -79,7 +79,7 @@ func (r *Inputer) startWorkerForRoom(roomID string) {
 	})
 	w := v.(*worker)
 	w.Lock()
-	defer w.Lock()
+	defer w.Unlock()
 	if !loaded || w.subscription == nil {
 		consumer := r.Cfg.Matrix.JetStream.Prefixed("RoomInput" + jetstream.Tokenise(w.roomID))
 		subject := r.Cfg.Matrix.JetStream.Prefixed(jetstream.InputRoomEventSubj(w.roomID))