BlazingMQ is an open source distributed message queueing framework, which focuses on efficiency, reliability, and a rich feature set for modern-day workflows.
At its core, BlazingMQ provides durable, fault-tolerant, highly performant, and highly available queues, along with features like various message routing strategies (e.g., work queues, priority, fan-out, broadcast, etc.), compression, strong consistency, poison pill detection, etc.
Message queues generally provide a loosely-coupled, asynchronous communication channel ("queue") between application services (producers and consumers) that send messages to one another. You can think about it like a mailbox for communication between application programs, where 'producer' drops a message in a mailbox and 'consumer' picks it up at its own leisure. Messages placed into the queue are stored until the recipient retrieves and processes them. In other words, producer and consumer applications can temporally and spatially isolate themselves from each other by using a message queue to facilitate communication.
BlazingMQ's back-end (message brokers) has been implemented in C++, and client libraries are available in C++, Java, and Python.
BlazingMQ is an actively developed project and has been battle-tested in production at Bloomberg for 8+ years.
This repository contains BlazingMQ message broker, BlazingMQ C++ client library and a BlazingMQ command line tool, while BlazingMQ Java client library can be found in this repository.
- Documentation
- Quick Start
- Building
- Installation
- Contributions
- License
- Code of Conduct
- Security Vulnerability Reporting
Comprehensive documentation about BlazingMQ can be found here.
This article guides readers to build, install, and experiment with BlazingMQ locally in a Docker container.
In the companion article, readers can learn about some intermediate and advanced features of BlazingMQ and see them in action.
bin/build-ubuntu.sh and bin/build-darwin.sh build BlazingMQ and its dependencies, respectively, on Ubuntu 22.04.2 LTS and Darwin 22.6.0. They can serve as a basis to build BlazingMQ on other systems.
To build BlazingMQ with plugins, pass '--plugins' argument with desired plugin names to the build script, e.g.
bin/build-ubuntu.sh --plugins plugin-1-name,plugin-2-nameThere is also support for building BlazingMQ with vpckg.
Before attempting to build, you will have to acquire flex, bison, and bde-tools for your system, as vcpkg cannot fetch them. Both flex and bison can likely be installed through your system's package manager. Clone bde-tools, we'll assume blazingmq/thirdparty/bde-tools for this guide.
Once the prerequisite tools are installed, you should be able to build BlazingMQ with the following:
export VCPKG_ROOT=/path/to/vcpkg
cmake --preset [preset-name] -DCMAKE_PREFIX_PATH=/path/to/thirdparty/bde-tools
cmake --build cmake.bldFor a list of presets, please look at the *-vcpkg configurations in CMakePresets.json.
This article describes the steps for installing a BlazingMQ cluster in a set of Docker containers, along with a recommended set of configurations.
We welcome your contributions to help us improve and extend this project!
We welcome issue reports here; be sure to choose the proper issue template for your issue, so that we can be sure you're providing us with the necessary information.
Before sending a Pull Request, please make sure you have read our Contribution Guidelines.
BlazingMQ is Apache 2.0 licensed, as found in the LICENSE file.
This project has adopted a Code of Conduct. If you have any concerns about the Code, or behavior which you have experienced in the project, please contact us at opensource@bloomberg.net.
If you believe you have identified a security vulnerability in this project, please send an email to the project team at opensource@bloomberg.net, detailing the suspected issue and any methods you've found to reproduce it.
Please do NOT open an issue in the GitHub repository, as we'd prefer to keep vulnerability reports private until we've had an opportunity to review and address them.