stan.net
stan.net copied to clipboard
nats-io
The official NATS .NET C# Streaming Client
Currently `STAN.Client` Nuget package uses `Google.Protobuf` version 3.13.0 which contains security vulnerabilities. See e.g.: - https://www.nuget.org/packages/Google.Protobuf/3.13.0 - https://github.com/advisories/GHSA-77rm-9x9h-xj3g It's possible for the downstream systems to pin to a newer version...
I create a simple stan client with the below code by stan client 0.3.0: ``` static void Main(string[] args) { var cf = new ConnectionFactory(); var sf = new StanConnectionFactory();...
``` private IConnection CreateNatsConnection() { var natsOptions = ConnectionFactory.GetDefaultOptions(); natsOptions.AllowReconnect = true; natsOptions.MaxReconnect = Options.ReconnectForever; natsOptions.Url = _stanConfig.Url; return new ConnectionFactory().CreateConnection(natsOptions); } public Task CreateStanConnection() { var options = StanOptions.GetDefaultOptions();...
Had a process crash following a disconnect from the NATS server with this stack trace: ``` NATS.Client.NATSConnectionClosedException: Connection is closed. at NATS.Client.Subscription.unsubscribe(Boolean throwEx) at NATS.Client.AsyncSubscription.Unsubscribe() at STAN.Client.Connection.cleanupOnClose(Exception ex) at STAN.Client.Connection.closeDueToPing(Exception...
Would it be possible to introduce an async message handler for Subscribe method? I would like to be able to await inside message handler and properly handle exceptions thrown.
As per this MR nats-io/stan.go#295 a redeliveryCount method is added in stan.go. Please add support for redeliveryCount
NATS client has overloads for Publish method accepting byte array along with offset and length of data to be used. It'd be great to have the same for STAN client....
```csharp // Subscribe starting with most recently published value var opts = StanSubscriptionOptions.GetDefaultOptions(); opts.StartWithLastReceived(); var s = c.Subscribe("foo", opts, (obj, args) => { Console.WriteLine("Received a message: {0}", System.Text.Encoding.UTF8.GetString(args.Message.Data)); }); ```...
Hi All, good evening, I am trying to test STAN client in .Net Core deployed into Kubernetes as Pod. The following are the stand options set ```c# StanOptions cOpts =...
I had encountered quite invalid behavior: We have single instance of NATS `IConnection`. We use it to setup NATS subscriptions and the same instance is also used in `IStanConnection` (passed...
