diff --git a/Oxide.Ext.GamingApi/GamingApiNats.cs b/Oxide.Ext.GamingApi/GamingApiNats.cs index 9dd89cd..8b72aa2 100644 --- a/Oxide.Ext.GamingApi/GamingApiNats.cs +++ b/Oxide.Ext.GamingApi/GamingApiNats.cs @@ -3,6 +3,7 @@ using System.Diagnostics; using System.Threading; using Asyncapi.Nats.Client; +using NATS.Client.JetStream; namespace Oxide.Ext.GamingApi { @@ -70,6 +71,8 @@ private GamingApiNats(LoggingInterface logger) }; opts.SetNkey(this.GetNatsNkeyUser(), sigEh); this.Connect(opts); + var jetstreamOptions = JetStreamOptions.Builder().Build(); + this.createJetStreamContext(jetstreamOptions); } private GamingApiNats() : this(new Imp()) {