diff --git a/roomserver/internal/api.go b/roomserver/internal/api.go
index 22cfc7aa..e3c7821c 100644
--- a/roomserver/internal/api.go
+++ b/roomserver/internal/api.go
@@ -90,8 +90,10 @@ func (r *RoomserverInternalAPI) SetFederationAPI(fsAPI fsAPI.FederationInternalA
 
 	r.Inputer = &input.Inputer{
 		DB:                   r.DB,
+		InputRoomEventTopic:  r.InputRoomEventTopic,
 		OutputRoomEventTopic: r.OutputRoomEventTopic,
 		ServerName:           r.Cfg.Matrix.ServerName,
+		JetStream:            r.JetStream,
 		ACLs:                 r.ACLs,
 		FSAPI:                r.fsAPI,
 	}