Faye - Simple pub/sub messaging for the web

•    Javascript

---

Faye is a set of tools for simple publish-subscribe messaging between web clients. It ships with easy-to-use message routing servers for Node.js and Rack applications, and clients that can be used on the server and in the browser. It is based on the Bayeux protocol.

pub-sub messaging message-queue publish-subscribe bayeux

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

mist - A distributed, tag-based pub-sub service for modern web applications and container-driven cloud

•    Go

---

Mist is a simple pub/sub based on the idea that messages are tagged. To subscribe, a client simply constructs a list of tags that it is interested in, and all messages that are tagged with all of those tags are sent to that client. A client can not only be a subscriber (with multiple active subscriptions), but also a publisher. Clients will receive messages for any tags they are subscribed, except message publish by themselves.

pub-sub nanobox tcp-client websocket-client messaging developer-tools devtools nanopack

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

Jafka - A fast and simple distributed publish-subscribe messaging system (mq)

•    Java

---

Jafka mq is a distributed publish-subscribe messaging system cloned from Apache Kafka.

publish-subscribe message-queue pub-sub distributed kafka-alternative kafka-clone

Luxun - A high-throughput, persistent, distributed, publish-subscribe messaging system based on memo

•    Java

---

A high-throughput, persistent, distributed, publish-subscribe messaging system based on memory mapped file and Thrift RPC.

publish-subscribe message-queue pub-sub distributed thrift-rpc

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

private_pub - Handle pub/sub messaging through private channels in Rails using Faye.

•    Ruby

---

Private Pub is a Ruby gem for use with Rails to publish and subscribe to messages through Faye. It allows you to easily provide real-time updates through an open socket without tying up a Rails process. All channels are private so users can only listen to events you subscribe them to. Watch RailsCasts Episode 316 for a demonstration of Private Pub.

golongpoll - golang long polling library

•    Go

---

Golang long polling library. Makes web pub-sub easy via an HTTP long-poll server.To use, create a LongpollManager and then use it to publish events and expose an HTTP handler to subscribe to events.

messaging pub-sub message-queue

Kapacitor - Open source framework for processing, monitoring, and alerting on time series data

•    Go

---

Kapacitor is a open source framework for processing, monitoring, and alerting on time series data. Kapacitor imports (stream or batch) time series data, and then transform, analyze, and act on the data. It uses Telegraf to collect system metrics on your local machine and store them in InfluxDB.

monitoring data-processing data-analysis alerts streaming data-streaming streaming-analytics

RxPY - Reactive Extensions for Python

•    Python

---

Reactive Extensions for Python (RxPY) is a set of libraries for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in Python. Using Rx, developers represent asynchronous data streams with Observables, query asynchronous data streams using operators, and parameterize concurrency in data/event streams using Schedulers.Using Rx, you can represent multiple asynchronous data streams (that come from diverse sources, e.g., stock quote, Tweets, computer events, web service requests, etc.), and subscribe to the event stream using the Observer object. The Observable notifies the subscribed Observer instance whenever an event occurs.You can put various transformations in-between the source Observable and the consuming Observer as well.

reactive reactivex reactive-extensions rxpy

Redisson - Redis based In-Memory Data Grid for Java

•    Java

---

Redisson - distributed Java objects and services (Set, Multimap, SortedSet, Map, List, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, AtomicLong, Map Reduce, Publish / Subscribe, Bloom filter, Spring Cache, Executor service, Tomcat Session Manager, Scheduler service, JCache API) on top of Redis server. Rich Redis client.

cache distributed-caching distributed-locks redis-client redis-cluster collections java-collections hashmap set queue

Apache Apollo - ActiveMQ's next generation of messaging

•    Java

---

ActiveMQ Apollo is a faster, more reliable, easier to maintain messaging broker built from the foundations of the original ActiveMQ. It accomplishes this using a radically different threading and message dispatching architecture. Like ActiveMQ, Apollo is a multi-protocol broker and supports STOMP, AMQP, MQTT, Openwire, SSL, and WebSockets.

messaging message-queue queue publish-subscribe pub-sub mqtt stomp amqp

backbone.radio - Messaging patterns for Backbone applications.

•    Javascript

---

Messaging patterns for Backbone applications.

backbone marionette radio pub-sub decoupling messaging request events backbone-applications decoupled pubsub publish subscribe architecture spa

js-signals - Custom Event/Messaging system for JavaScript inspired by AS3-Signals

•    Javascript

---

Custom event/messaging system for JavaScript inspired by AS3-Signals.For a more in-depth introduction read the JS-Signals Project Page and visit the links below.

js-signals signals pub/sub event publish subscribe observer

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

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

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

gnatsd - High-Performance server for NATS, the cloud native messaging system.

•    Go

---

NATS Server is a simple, high performance open source messaging system for cloud native applications, IoT messaging, and microservices architectures. It implements a highly scalable and elegant publish-subscribe (pub/sub) distribution model. The performant nature of NATS make it an ideal base for building modern, reliable, scalable cloud native distributed systems.

messaging message-bus message-queue cloud-native microservices-architecture nats-server distributed-systems cloud cloud-computing

watermill - Building event-driven applications easy way in Go.

•    Go

---

Watermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling event sourcing, RPC over messages, sagas and basically whatever else comes to your mind. You can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog if that fits your use case. Note: Watermill should run reliably in a production environment, but it is still under heavy development and the public API may change before the 1.0.0 release.

watermill event-driven event-sourcing sagas events stream-processing reactive rabbitmq kafka cqrs