Tyto.Transports.InMemory 0.0.1-alpha.94

Tyto.Transports.InMemory

In-process transport for Tyto. Messages are delivered through in-memory channels — no broker, no network. Ideal for tests, local development, and single-process apps that still want Tyto's messaging model (handlers, pipeline, retries, dead-lettering).

Not durable: messages live in memory and are lost on restart. For production across processes use the Postgres, RabbitMQ or Kafka transports.

Install

dotnet add package Tyto.Transports.InMemory

Usage

builder.AddTyto(tyto => {
    tyto.MessageDefinitions(d => d.Add<PlaceOrder>("place-order", 1));

    tyto.Transports(t => t.AddInMemory("memory", options => {
        options.ChannelCapacity = 5_000;         // bounded channel size (backpressure)
        options.DefaultConcurrencyLimit = 2;     // concurrent consumers per queue
        options.MaxRetryCount = 3;               // retries before dead-letter
        options.RetryDelayMilliseconds = 1_000;  // delay between retries
        options.Bind("orders-exchange", "orders"); // fan-out binding (exchange -> queue)
    }));

    tyto.Endpoints(e => e.Add("orders-endpoint", ep => {
        TransportEndpoint queue = new() { TransportName = "memory", Address = "orders" };
        ep.ListenOn(queue);
        ep.Routing.Send<PlaceOrder>().To(queue);
        ep.AddHandlersFromAssembly(typeof(PlaceOrder).Assembly);
    }));
});

• Commands are sent directly to a queue.
• Events are published fan-out to every queue bound to the exchange (Bind); with no bindings the event is dropped.

Retries & dead-lettering

On a handler failure the message is re-enqueued with an incremented retry header until MaxRetryCount is reached, then moved to the queue's DLQ. If you register Tyto.DeadLettering, the final failure is also captured in your dead-letter store:

tyto.AddInMemoryDeadLettering(out InMemoryDeadLetterStore dlq);

The dead-letter record captures the full failure context — reason, attempts, and the exception (type / message / stack).

Observability (OpenTelemetry)

Meter and ActivitySource are both named Tyto.Transports.InMemory.

tracing.AddSource("Tyto.Transports.InMemory");
metrics.AddMeter("Tyto.Transports.InMemory");

Counters: enqueued, completed, abandoned, deadlettered; histogram: processing.duration. All logs are source-generated with deliberate levels.