mtmk
mtmk
This PR introduces an interface-based Core API dependency for the JetStream API. As a result of this change, several internal APIs will need to be made public. This will enable...
**Problem Statement:** Users coming from other messaging platforms (e.g. RabbitMQ, Masstransit) might find it challenging to register NATS constructs (e.g. consumers) and process messages in the current setup. Most examples...
* NATS.Client.Core.Tests.ProtocolTest.Protocol_parser_under_load(size: 1) [FAIL] https://github.com/nats-io/nats.net/actions/runs/10079531020/job/27868508654#step:7:195 * Test timeout https://github.com/nats-io/nats.net/actions/runs/10079531020/job/27867077586 * NATS.Client.JetStream.Tests.ConsumerConsumeTest.Consume_dispose_test [FAIL] https://github.com/nats-io/nats.net/actions/runs/10081615424/job/27874047364#step:8:145 * NATS.Client.JetStream.Tests.ErrorHandlerTest.Ordered_consumer_consume_handling [FAIL] https://github.com/nats-io/nats.net/actions/runs/10081615424/job/27877247127#step:8:297 * NATS.Client.JetStream.Tests.ConsumerFetchTest.Fetch_dispose_test [FAIL] https://github.com/nats-io/nats.net/actions/runs/10116691455/job/27980062188#step:8:308
### Proposed change ```csharp public NatsBuilder AddJsonSerialization(params JsonSerializerContext[] contexts) => ConfigureOptions(opts => { var jsonRegistry = new NatsJsonContextSerializerRegistry(contexts); return opts with { SerializerRegistry = jsonRegistry }; }); ``` ...or collect...
When multiple filters are passed, client library should check `consumer info` from `consumer create method` if the filters are matching, as nats-server < 2.10 would ignore them. see also https://github.com/nats-io/nats.net.v2/pull/545#issuecomment-2211767607...
Expand public API of NATS client library * Introduce NATS.Client NuGet package (to be published on top on v1 client) * Simplified NatsClient with more beginner-friendly options * Exposed more...
### Proposed change (1) Add `NATS.Client.Serializers.Json` to `NATS.Net` main package and `NATS.Extensions.Microsoft.DependencyInjection` package then add the ad-hoc serialization to the default serialization registry without breaking the AOT compilation (i.e. compile...
> Where this gets tricky is, if the object is above a certain size, grab a pooled array and copy the contents over. > > -OR-, it might be better...
The capacity now has a limit set to `maxMsgs` to prevent pulling excessive messages from the server. It also has been bounded to a maximum of 1024 to avoid large...