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" />
                    
Directory.Packages.props
<PackageReference Include="Rymote.Synapse.Persistence.Memory" />
                    
Project file
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
                    
#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
                    
Install as a Cake Addin
#tool nuget:?package=Rymote.Synapse.Persistence.Memory&version=1.0.0
                    
Install as a Cake Tool

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 — implements IMessageLog with ack-bounded retention. Entries stay in the log until every active subscription's cursor advances past them.
  • Publisher backpressure: AppendAsync blocks when the log holds MaxLogSize un-ack'd entries; resumes when an ack frees space.
  • MemoryPersistenceOptions.MaxLogSize (default 10 000) caps memory use.
  • UseMemoryPersistence extension on ISynapseBuilder for 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.Rethrow will infinitely redeliver a failing message and pin the log; use Retry → DeadLetter for self-limiting behaviour.
  • A permanently-stuck subscription can block publishers via the MaxLogSize cap. Dispose stuck subscriptions to free the log.
Product 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.

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