Stream Activity

Global CRM activity firehose (SSE), 4Hz wall-clock-aligned.

Subscribes to Redis channel ‘crm:activity:firehose’. The workflow engine (same service) is the sole producer — it publishes slim events for customer.registered, transaction.approved, order.opened/closed, stopout.triggered.

Cadence: aligned to the 4Hz wall-clock metronome (250ms boundaries), matching the rest of the JumpTech tick pipeline (PnL flush, OHLC flush, last_ticks flush). Every metronome boundary the buffered events are drained and emitted as a single SSE frame containing a JSON array. Two clients connected to the same broker tick on the same boundary — no phase drift between subsystems.

Buffer cap: 250 events per cycle (oldest dropped on overflow). At 4Hz that’s 1000 events/sec sustainable per client.

Heartbeat: empty array on each metronome boundary keeps proxies alive, so no separate keepalive timer needed.