Firebase queue consumer for Node with at-least-once semantics

A PostgreSQL based transactional outbox and inbox pattern implementation to support exactly once message processing (with at least once message delivery).

Inbound webhook receipt handling with explicit at-least-once semantics.

Sync core-llm-wiki SQLite outbox events to your Prisma-backed database using the transactional outbox pattern — at-least-once delivery with ordering guarantees.

Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou

Declarative reverse-ETL: mirror framework table changes outward to external sinks (webhook, Kafka via @voltro/plugin-queue's kafkaSink, plus a CdcSink interface for custom sinks) through a durable outbox — ordered per pipe, at-least-once from enqueue, ret

Nwire — NATS-backed EventBus adapter. Core pub/sub OR JetStream (at-least-once + DLQ) — same EventBus contract.

🚌 Persistent event bus with at-least-once delivery via SQLite + Redis, Fully typed.

The ONE Supabase Realtime layer for Matrx clients: channel-naming registry, enforced channel lifecycle, echo suppression on by default, at-least-once delivery with idempotent dedup, a decoupled ordered handler queue, reconnect with jittered backoff and a

YDB Topics client for publish-subscribe messaging. Provides at-least-once delivery, exactly-once publishing, FIFO guarantees, and scalable message processing for unstructured data.

At-least-once outbox and idempotent inbox primitives

Durable at-least-once background work for Open Mercato apps: a leased job record in Postgres with epoch fencing, bounded resumable slices, a server-side reconciler, fenced cancel and an operator API. Pluggable transport (BullMQ or pg-boss).

Delayed and recurring jobs on PostgreSQL: named schema-typed handlers, SKIP LOCKED dispatch with heartbeat leases, cron scheduling with timezones, at-least-once delivery, dead letters, graceful drain, per-job metrics.

Lesto's in-house durable job queue — at-least-once delivery on the SQL database, no Redis.

Drop-in replacement for Open Mercato's core data_sync module that runs sync runs as durable at-least-once work (via @fullstackhouse/open-mercato-durable-work): survives deploys and worker kills, resumes from the committed cursor, retries transient errors

A lease-based work queue for Source RPC networks: at-least-once, bounded, transport-neutral over socket.io and MQTT 5

High-reliability Feishu/Lark bridge for Pi — zero-config onboarding, persistent outbox (at-least-once), streaming output, native pi command adapter, permission bridge, one-click diagnostics

At least once delivery of Redux Actions

Neurai Connect relay: self-hosted WebSocket pub/sub relay implementing the irn_* JSON-RPC with at-least-once delivery.

Background worker system using Redis Streams with at-least-once delivery.