feat: workflow-engine extensions (async wire tap, scatter-gather, enricher, normalizer, polling consumer, TTL stores, outbox)#333

Merged

JerrettDavis merged 11 commits into

mainfrom

feat/workflow-engine-extensions

May 23, 2026

Commits on May 23, 2026

feat(messaging-channel): add AsyncWireTap with per-tap error isolation

JerrettDavis
and
claude
committed
feat(messaging-routing): add AsyncScatterGather with completion strategies

JerrettDavis
and
claude
committed
feat(messaging-transformation): add AsyncContentEnricher with per-step error policy

JerrettDavis
and
claude
committed
feat(messaging-transformation): add Normalizer with content-predicate dispatch

JerrettDavis
and
claude
committed
feat(messaging-consumers): add AsyncPollingConsumer with dispatch loop and back-off

JerrettDavis
and
claude
committed
feat(messaging-reliability): add IIdempotencyStoreWithTtl and in-memory implementation

JerrettDavis
and
claude
committed
feat(messaging-transformation): add IClaimCheckStoreWithTtl and in-memory implementation

JerrettDavis
and
claude
committed
feat(messaging-reliability): add IOutboxStore interface, InMemoryOutboxStore, and OutboxDispatcher

JerrettDavis
and
claude
committed
fix(messaging-routing): remove ambiguous Task.WhenAll cref in XML doc

JerrettDavis
and
claude
committed
fix(tests): correct AsyncScatterGather test for all-failed-recipients scenario

JerrettDavis
and
claude
committed
fix(messaging): refine EarlyExitCounter, callerCt, and minor corrections across primitives

JerrettDavis
and
claude
committed