From 4a9f2c7de4cbdce91d29fe1b2b7d225ee3b8a8d0 Mon Sep 17 00:00:00 2001 From: jonaslagoni Date: Wed, 5 Oct 2022 02:22:39 +0200 Subject: [PATCH] fix: add missing set jetstream context --- Oxide.Ext.GamingApi/GamingApiNats.cs | 3 +++ 1 file changed, 3 insertions(+) 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()) {