Rymote.Synapse.Persistence.Memory
1.0.0
dotnet add package Rymote.Synapse.Persistence.Memory --version 1.0.0
NuGet\Install-Package Rymote.Synapse.Persistence.Memory -Version 1.0.0
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Rymote.Synapse.Persistence.Memory" Version="1.0.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="Rymote.Synapse.Persistence.Memory" Version="1.0.0" />
<PackageReference Include="Rymote.Synapse.Persistence.Memory" />
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add Rymote.Synapse.Persistence.Memory --version 1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: Rymote.Synapse.Persistence.Memory, 1.0.0"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
#:package Rymote.Synapse.Persistence.Memory@1.0.0
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=Rymote.Synapse.Persistence.Memory&version=1.0.0
#tool nuget:?package=Rymote.Synapse.Persistence.Memory&version=1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
Rymote.Synapse.Persistence.Memory
In-memory IMessageLog provider for Rymote.Synapse, enabling the AtLeastOnce dispatch policy without disk persistence.
This provider is ephemeral — process restart loses all un-ack'd entries. For durability across restarts, use Rymote.Synapse.Persistence.File (forthcoming).
What it does
InMemoryMessageLog— implementsIMessageLogwith ack-bounded retention. Entries stay in the log until every active subscription's cursor advances past them.- Publisher backpressure:
AppendAsyncblocks when the log holdsMaxLogSizeun-ack'd entries; resumes when an ack frees space. MemoryPersistenceOptions.MaxLogSize(default 10 000) caps memory use.UseMemoryPersistenceextension onISynapseBuilderfor DI registration.
Quickstart
services.AddSynapse()
.UseMessagePackSerialization()
.UseMemoryPersistence(memory => memory.MaxLogSize = 10_000)
.ConfigureMessageType<PaymentCaptured>(typeOptions =>
typeOptions.Dispatch = new DispatchPolicy.AtLeastOnce(
MaxAttempts: 5,
Backoff: BackoffPolicy.Exponential(TimeSpan.FromSeconds(1), TimeSpan.FromMinutes(1)),
DeadLetter: new DeadLetterDestination.Channel("payments.dlq")));
ISynapseBus bus = provider.GetRequiredService<ISynapseBus>();
// Subscribers receive the typed message; failures trigger retry-with-backoff;
// after MaxAttempts the message is dead-lettered to "payments.dlq", observable via:
bus.Subscribe<DeadLetterEnvelope<PaymentCaptured>>(async (envelope, context, cancellationToken) =>
{
// alert / log / forward
});
Limitations
- Ephemeral — un-ack'd entries are lost on process exit.
- Strict FIFO per subscription. No in-flight parallelism within one subscription.
- A subscription that uses
FailurePolicy.Rethrowwill infinitely redeliver a failing message and pin the log; useRetry → DeadLetterfor self-limiting behaviour. - A permanently-stuck subscription can block publishers via the
MaxLogSizecap. Dispose stuck subscriptions to free the log.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
net10.0
- Microsoft.Extensions.DependencyInjection (>= 10.0.0)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.0)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.0)
- Rymote.Synapse.Abstractions (>= 1.0.0)
- Rymote.Synapse.Core (>= 1.0.0)
NuGet packages (1)
Showing the top 1 NuGet packages that depend on Rymote.Synapse.Persistence.Memory:
| Package | Downloads |
|---|---|
|
Rymote.Synapse.Cluster
Cross-node clustering for Rymote.Synapse: full-mesh peer connections, reconnect, subscription propagation, routing, AtLeastOnce across peers. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 1.0.0 | 157 | 5/18/2026 |