Skip to content

Commit

Permalink
fix: add missing set jetstream context
Browse files Browse the repository at this point in the history
  • Loading branch information
jonaslagoni committed Oct 5, 2022
1 parent 718cb61 commit 4a9f2c7
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions Oxide.Ext.GamingApi/GamingApiNats.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
using System.Diagnostics;
using System.Threading;
using Asyncapi.Nats.Client;
using NATS.Client.JetStream;

namespace Oxide.Ext.GamingApi
{
Expand Down Expand Up @@ -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())
{
Expand Down

0 comments on commit 4a9f2c7

Please sign in to comment.