MBassador - Light-weight, high-performance event bus implementing the publish subscribe pattern

•    Java

---

MBassador is a light-weight, high-performance event bus implementing the publish subscribe pattern. It is designed for ease of use and aims to be feature rich and extensible while preserving resource efficiency and performance. The core of MBassador is built around a custom data structure that provides non-blocking reads and minimized lock contention for writes such that performance degradation of concurrent read/write access is minimal.

event-bus messaging message-queue pub-sub publish-subscribe

SwiftEventBus - A publish/subscribe EventBus optimized for iOS

•    Swift

---

Subscribers implement event handling methods that will be called when an event is received. Post an event from any part of your code. All subscribers matching the event type will receive it.

pub-sub eventbus communication notifications thread ios

NetworkEvents - Android library listening network connection state and change of the WiFi signal strength with event bus

•    Java

---

Android library listening network connection state and change of the WiFi signal strength with event bus. It works with any implementation of the Event Bus. In this repository you can find samples with Otto and GreenRobot's bus.

android internet-connection network-connection wifi event-bus otto greenrobot-bus

servicebus - Simple service bus for sending events between processes using amqp.

•    Javascript

---

Simple service bus for sending events between processes using amqp. Allows for send/receive and publish/subscribe pattern messaging over RabbitMQ. Simply running multiple versions of Process A, above, will cause servicebus to distribute sent messages evenly accross the list of listeners, in a round-robin pattern.

rabbitmq amqp node messaging bus message-bus servicebus service-bus round-robin middleware message-acknowledgement

onfire

•    Javascript

---

onfire.js is a simple events dispatcher library (just 0.9kb). simple and usefull. Binding / subscribe the event_name with callback. when has event named event_name fired, callback function will process.

onfire event-dispatcher trigger fire emitter event-subscribe event-publish dispatcher react vue.js angular component-communication

Distributed Publish/Subscribe (Pub/Sub) Event System

•    

---

The Web Solutions Platform (WSP) event system is a general-purpose distributed publish/subscribe event system designed for high performance and low latency. Publish/subscribe is a common communication pattern though there are many variations to solve different scenario require...

distributed-systems architecture biztalk distributed esb

event_bus - :surfer: Traceable, extendable and minimalist **event bus** implementation for Elixir with built-in **event store** and **event watcher** based on ETS

•    Elixir

---

Traceable, extendable and minimalist event bus implementation for Elixir with built-in event store and event watcher based on ETS.

elixir eventbus event-sourcing eventstore

Avis event router

•    Java

---

Avis is a multicast event bus. It provides a fast, publish/subscribe event routing service compatible with the commercial Elvin implementation developed by Mantara Software.

eventemitter3 - EventEmitter3 - Because there's also a number 2. And we're faster.

•    Javascript

---

It's a drop in replacement for existing EventEmitters, but just faster. Free performance, who wouldn't want that? The EventEmitter is written in EcmaScript 3 so it will work in the oldest browsers and node versions that you need to support.We've upgraded the API of the EventEmitter.on, EventEmitter.once and EventEmitter.removeListener to accept an extra argument which is the context or this value that should be set for the emitted events. This means you no longer have the overhead of an event that required fn.bind in order to get a custom this value.

eventemitter nodejs browser eventemitter2 eventemitter3 events addeventlistener addlistener emit emits emitter event once pub/sub publish reactor subscribe

nanoevents - Simple and tiny (119 bytes) event emitter library for JavaScript

•    Javascript

---

Simple and tiny event emitter library for JavaScript. Methods on returns unbind function. Call it and this listener will be removed from event.

eventemitter events emit emitter event pub/sub publish reactor subscribe

Mediator.js - An implementation of the mediator pattern for asynchronous events in Javascript

•    Javascript

---

Mediator is a simple class that allows you to register, unregister, and call subscriber methods to help event-based, asyncronous programming. Its purpose is to make the usage of WebSockets, Ajax calls, DOM events, or any other asynchronous operations easy to maintain and test. Mediator has no dependencies on any other libraries.

pubsub events mediator publish subscribe design-patterns

eventuate-local - The on premise, open source version of Eventuate, which is a platform for developing transactional business applications that use the microservice architecture

•    Java

---

Eventuate™ Local is the on-premise, open source version of Eventuate™, which is a platform for developing transactional business applications that use the microservice architecture. Eventuate provides an event-driven programming model for microservices that is based on event sourcing and CQRS. Eventuate™ Local has the same API as the SaaS version but uses a SQL database to persist events and Kafka as the publish/subscribe mechanism. A framework for developing (microservice-based) applications.

MeiliES - A Rust based event store using the Redis protocol

•    Rust

---

MeiliES is an Event Sourcing database that uses the RESP (REdis Serialization Protocol) to communicate. This way it is possible to create clients by reusing the already available protocol. For example, it is possible to use the official Redis command line interface program to communicate with MeiliES. There is a release blog post if you want to know more. An event store is like a Kafka or a Rabbit MQ but it stores events on disk indefinitely. The first purpose of the server is to publish events of a stream to all subscribed clients, note that events are saved in reception order. A client can also specify from which event number (incrementing) it wants to read, therefore it is possible to recover from crashing by reading and reconstructing a state with only new events. Keep in mind that a message queue is not made for event-sourcing.

event-store redis-protocol

wisper - A micro library providing Ruby objects with Publish-Subscribe capabilities

•    Ruby

---

Note: Wisper was originally extracted from a Rails codebase but is not dependant on Rails. Please also see the Wiki for more additional information and articles.

events publish-subscribe pubsub

AxonFramework - High Performance and Scalability framework for Java

•    Java

---

A CQRS (Command Query Responsibility Segregation) Framework for Scalable, High-Performance Java Applications.

cqrs event-sourcing framework application-framework scalability

Distributed Event Bus

•    Java

---

Distributed event bus library for passing application events to listeners running anywhere on the network. Library is a lightweight wrapper over the JGroups toolkit with event filtering features.

RxBus - Event Bus By RxJava.

•    Java

---

This is an event bus designed to allowing your application to communicate efficiently. I have use it in many projects, and now i think maybe someone would like it, so i publish it.

rxbus rxandroid rxjava rxjava2

PubSubJS - Dependency free publish/subscribe for JavaScript

•    Javascript

---

PubSubJS is a topic-based publish/subscribe library written in JavaScript. PubSubJS has synchronisation decoupling, so topics are published asynchronously. This helps keep your program predictable as the originator of topics will not be blocked while consumers process them.

pub/sub pubsub publish/subscribe publish subscribe

Apollo - 🚀 Awesome EventBus by RxJava.

•    Kotlin

---

🚀 Awesome EventBus by RxJava.

eventbus rxbus rxjava sticky-events receive-events android-library android rxjava2 ipc

Plumber - A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems

•    Go

---

Plumber is a CLI devtool for inspecting, piping, massaging and redirecting data in message systems like Kafka, RabbitMQ , GCP PubSub and many more. It helps to safely view the contents of your data streams, Decode protobuf/avro/thrift/JSON data in real-time, Route data from one place to another, Replay events into a message system on your local network and lot more.

kafka protobuf rabbitmq message-bus message-queue event-driven event-bus cli command-line