[cosmin-staicu]

Summary

Every node reads every Redis Streams broadcast event, its own included, and decoded each one in full before dropping its own. A writer now adds the event's source as a separate src field; readers compare it first and skip their own entries without decoding.

 XADD <stream> MAXLEN ~ N *
   event  <payload>            // unchanged, field name = FieldName (default "event")
+  src    <source uri text>    // the form SameSource compares

 reader, per entry
-  parse reply -> decode payload (System.Text.Json) -> SameSource? drop
+  src present and equal to this node's source -> skip decode, ACK, advance position
+  src absent or different -> decode -> SameSource? as before

• Mixed versions keep working. Old readers (2.1, 3.0) take the payload with @event[FieldName], a lookup by name that ignores the extra field; a test pins that expression over the new field layout, and a Redis integration test reads a published entry back with the client. Entries from old writers have no src field and are decoded and compared as before.
• ACKs, the stream position, gap and loss detection and ordering are unchanged; skipping a decode skips no bookkeeping. Both read paths (the Redis 7+ script and the Redis below 7 pipelined read) handle both formats.
• The topic name used for the read metric is built once instead of per event.
• The fast path is off while EmitStreamReceivedEvent is on (default off), so that receipt keeps the event id. A topic whose FieldName is src writes no source field and keeps the decode path.

Evidence

Own-event backlog of 1000 entries, in-memory stream, script path: 2835 -> 1072 bytes per own entry, 0 decodes. An old-format own entry still costs 2654 bytes (decoded, as compatibility requires). Each reader now parses two more values per entry, about 100-130 bytes.

New tests: own-entry skip on both read paths (in-memory and real Redis, including a forced below-7 connector), ACK and position advance, old-format own and foreign entries, a case-only source difference, diagnostic-on decode, the field layout, and the allocation probe. net10.0 4327 passed, net8.0 4285 passed.

Merge Danger

Door: two-way for the code; the extra src field is written to shared streams, which older readers ignore.

Blast Radius: broadcast readers and writers on the Redis Streams transport. Own entries no longer log the Debug "event received" line on the fast path.

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
100.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud