EdgeStream is an enterprise-grade, real-time message orchestration pipeline that powers the BizFirstAi ecosystem. Unified infrastructure for async messaging, event streaming, pub/sub distribution, and real-time communication — across every platform, every service, every message.
EdgeStream is not another message broker. It is a purpose-built orchestration layer designed around the realities of enterprise real-time communication.
Messages without full context create bugs, security risks, and poor user experience. EdgeStream carries user, session, conversation, and entity context through the entire message pipeline — automatically. Every hook, every subscriber, every delivery.
Most systems treat send and receive differently. EdgeStream flows all messages — both directions — through the same hooks, handlers, and logging. Consistency is not a feature you configure. It is enforced by the architecture.
Hooks created at runtime with priority ordering. Handlers registered dynamically. Message types added without modifying core code. A 50+ plugin ecosystem — as composable as WordPress, as reliable as enterprise infrastructure.
EdgeStream ships with every capability required for production enterprise messaging — without the operational overhead of a separate cluster.
SignalR, WebSocket, and HTTP transports. Azure SignalR backend for horizontal scaling. Automatic reconnection with configurable retry strategy. Every connection managed centrally.
Wildcard subscriptions (user:123:*, order:*:status), exact topic matching, and context-aware delivery filtering. Subscribers receive only what they need — zero noise, full isolation.
All messages normalised to the CNCF CloudEvents standard — type, source, id, time, datacontenttype. IEnvelope wraps every message with routing metadata, body, headers, and attributes.
HookActivityLogger and SubscriberActivityLogger track every stage of every message. Query logs by message ID, topic, source, or status. Performance stats, success rates, and audit trails built in.
Automatic message persistence, retry mechanisms with exponential backoff, and complete activity audit trails on every delivery. Failed messages are queued and re-delivered — nothing is silently dropped.
Strict type safety throughout all 14 packages. Full type inference from message creation to subscriber delivery. Zero runtime type surprises — type errors caught at build time.
EdgeStream is not a standalone product. It is the communication layer beneath the entire BizFirstAi platform — every real-time message in FlowEngine, EdgeInteract, and the Process Engine travels through EdgeStream.
EdgeInteract's ContextManager and CommManager are built directly on top of EdgeStream. Every chat message, form submission, and workflow update travels through the EdgeStream pipeline.
SignalR-based execution streaming from FlowEngine back to the UI uses EdgeStream as the transport. Real-time step progress, approval requests, and workflow events all flow through EdgeStream.
Background processing, batch operations, and long-running task events surface to the UI layer through EdgeStream's pub/sub. Human-in-the-loop notifications land in the correct context, every time.
Sub-100ms latency. 10k+ messages per second. Enterprise-grade from day one.