discourse/message_bus
Message Bus
Message Bus is a messaging library for Ruby and Rack applications designed to facilitate real-time data broadcasting and inter-process communication. It provides a framework for pushing live updates to connected clients and synchronizing state across multiple application instances, ensuring consistent data delivery in scaled environments.
The library distinguishes itself through a flexible architecture that supports multiple storage backends, including Redis, PostgreSQL, and in-memory options. It functions as a persistent connection framework that serves as an alternative to traditional web sockets, utilizing a long-polling transport layer to maintain communication channels. Developers can implement granular control over data flow through middleware-based filtering, which allows for the interception and restriction of messages based on content, metadata, or user identity.
Beyond basic messaging, the library includes tools for distributed system coordination, such as propagating cache invalidations and managing message queues. It supports pluggable serialization strategies and data encoding configurations, enabling optimization of transmission speed and payload size for high-volume traffic. The library integrates directly into the Rack request cycle to provide event-driven updates and targeted message distribution via channel-based routing.
Features
- Ruby Message Buses - Provides a messaging library for Ruby and Rack applications to facilitate real-time data broadcasting and inter-process communication.
- Distributed Cache Synchronizers - Propagates cache invalidations across multiple application instances to maintain consistency in scaled environments.
- Server-Pushed Message Streams - Maintains open communication channels to deliver continuous data updates to clients without repeated polling.
- Real-Time State Broadcasting - Broadcasts data updates to connected clients across specific channels using persistent connections.
- Real-Time Web Communication - Enables interactive web applications to push live data updates to clients instantly.
- Message Delivery Scoping - Implements granular control over data flow by restricting message delivery based on user identity and metadata.
- Long-Polling Queries - Utilizes a long-polling transport layer to hold HTTP requests open until new data is available.
- Real-Time Frameworks - Functions as a persistent connection framework alternative to traditional web sockets.
- Pluggable File and Message Backends - Abstracts message storage and synchronization across multiple processes using pluggable drivers like Redis or PostgreSQL.
- Client-Side Message Filtering - Restricts message delivery to end users based on identity or content rules.
- Serialization Strategies - Provides pluggable serialization strategies to optimize data transmission speed and payload size for high-volume traffic.
- PubSub Interfaces - Synchronizes messages and distributed cache updates across processes using Redis pub-sub.
- Structured Message Serialization - Supports multiple structured message serialization formats to improve processing speed and reduce bandwidth usage.
- Message Queues - Provides infrastructure for reliable message delivery and persistence between services.
- Incoming Message Processors - Intercepts and discards incoming data packets based on content or metadata rules before application processing.
- Channel-Based Routings - Organizes message distribution by mapping publishers and subscribers to specific topics for targeted delivery.
- Distributed State Synchronization - Propagates cache invalidations and system updates across multiple application instances to maintain consistency.
- Storage Synchronization - Synchronizes messages across multiple processes using persistent storage backends to ensure consistent communication.
- Outgoing Message Filtering - Intercepts and drops outgoing data packets based on server-side criteria before transmission to clients.
- Rack-Based Middleware Pipelines - Integrates directly into the Rack request cycle to facilitate event-driven updates.
- Path-Based Middleware Filtering - Provides configurable middleware hooks to intercept and filter data packets based on security and content rules.
