WSO2 Message Broker

WSO2 Message Broker (WSO2 MB) was created as a mechanism to offer distributed message brokering capabilities. We currently have this capability within WSO2 Enterprise Integrator (WSO2 EI). WSO2 EI allows you to create integration flows by leveraging built-in message brokering capabilities. Try it now!

The 100% open source WSO2 Message Broker is a lightweight, easy-to-use, distributed message-brokering server. It features high availability (HA) support with a complete hot-to-hot continuous availability mode, the ability to scale up to several servers in a cluster, and no single point of failure. It is designed to manage persistent messaging and large numbers of queues, subscribers and messages.

By supporting the lightweight MQTT protocol WSO2 Message Broker extends enterprise messaging to IoT. This allows you to connect to remote devices and sensors, establishing machine-to-machine (M2M) communications that generate millions of concurrent events per second. It offers a flexible deployment model that supports single node execution to cluster deployments.

WSO2 Message Broker


Standards Compliant, Portable, Interoperable Message Broker

  • Support for JMS v1.0 and v1.1 API
  • Advanced Message Queuing Protocol (AMQP) v0.91, a leading industry standard protocol for interoperable reliable messaging
  • Supports MQTT protocol with support for all QoS levels and retained messaging
  • Interoperability with many languages / platforms via AMQP clients for Java, .Net, C, C++, PHP, Ruby, Erlang and more

Elastically Scalable Broker Architecture

  • Broker capacity can be adjusted by adding/removing broker nodes
  • Brokers can be added/removed at run-time without system restart
  • Supports relational databases as a scalable backend message store
  • Architecture for message store scalability
  • Allocate the load among brokers

Support for Distributed Queues

  • Publishers and subscribers can connect to any broker
  • Support for in-order reliable message delivery
  • Support for strict and best effort (faster) delivery guarantees
  • Support for dead letter channel

Support for Publish/Subscribe Model (Topics)

  • Supports shared subscription
  • Can publish and subscribe using JMS or MQTT

Management Console

  • Console to manage the cluster and to view statistics about the cluster
  • Support to browse publish/subscribe topics through management console
  • Support to create, delete queues and browse queues using management console
  • Support to display the messages inside a queue, send a test message to a queue, and purge the messages in the queue using management console

Manage & Monitor

  • Comprehensive management & monitoring Web console with enterprise-level security
  • Built-in collection and monitoring of standard access and performance statistics
  • JMX MBeans for key metrics monitoring and management
  • Flow control mechanism to control and safeguard from bursts of message loads and global error conditions
  • Flexible logging support with integration to enterprise logging systems
  • User based authorization support for queues
  • Role based authorization support for topics and users