WSO2 Message Broker

WSO2 Message Broker

Message Brokers enable applications to exchange communications asynchronously or publish messages for timely access by many subscribers. For example, news bureaus can publish different categories of news – business, sports, science and technology, weather – and consumers can subscribe to the latest news that interests them.


Standards Compliant, Portable, Interoperable Message Broker

  • Support for JMS v1.0 and v1.1 API
  • Advanced Message Queuing Protocol (AMQP) v0.91, the only industry standard protocol for interoperable reliable messaging
  • Interoperability with many languages / platforms via AMQP clients for Java, .Net, C, C++, PHP, Ruby, Erlang and more
  • Support for in memory message store to improve performance.

Distributed, Highly Scalable, Fault-Tolerant and Persistent Message Broker with Apache Cassandra and Apache ZooKeeper

  • Apache Cassandra NoSQL storage to store messages persistently and share messages across multiple broker nodes
  • Apache ZooKeeper for message coordination and failure recovery
  • Flexible deployment model supporting single node execution to massively distributed execution
  • Support for Cassandra replication factor, read/write consistency levels configuration.

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
  • Client connections get automatically redistributed as loads change
  • Message storage capacity scales linearly as new brokers are added using underlying Cassandra ring
  • Intelligently allocate the load among brokers using Zookeeper coordination

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 Publish/Subscribe Model (Topics)

  • Publishers and subscribers can connect to any
  • Can publish and subscribe using JMS or WS-Eventing
  • Support interoperability between JMS and WS-Eventing clients

Management Console

  • Centralized governance of topics via integration to WSO2 Governance Registry
  • 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
  • Integrates with WSO2 Business Activity Monitor for operational audit and KPI monitoring and management
  • Flexible logging support with integration to enterprise logging systems
  • Centralized configuration management across different environments with lifecycles and versioning via integration to WSO2 Governance Registry
  • User based authorization support for queues
  • Role based authorization support for topics