Broke

The world’s first message broker that takes latency into account. It defines load balancing mechanism based on latency-related metrics.

Online Resources

• User Guide
• Javadoc

Prerequisites

• apache-maven-3.5.2 or above
• Java 1.8.0_151 or above

Build

git clone https://github.com/dsngroup/broke
cd broke
mvn package

Configure the Broke server

The configuration file for the broker ServerContext.properties is located in /broke-broker/src/main/resources Example of the ServerContext.properties:

# Configurable properties of server related context

# Port bindings
BOUND_PORT = 8181

# Number of boss (a.k.a. reactor) threads
NUM_OF_BOSS = 1

# Number of worker threads
NUM_OF_WORKER = 4

Run Broke server

The jar for the broker is located in /broke-broker/target/

cd /broke-broker/target/
java -jar Server-jar-with-dependencies.jar

Client APIs for Broke Server

Introduction to client APIs

License

Apache License 2.0