A simple implementation of the extremely lightweight publish/subscribe machine-to-machine (M2M) connectivity protocol.

Adventures in messaging

Minimalistic library that simplifies the adoption of async/await (asyncio) programming style in a multithreaded application.

Basic event publish/subscribe implementation that transfers a message from a sender to a receiver. It provides a loosely coupled communication between objects.

為koishi提供基於broker的訂閱發佈服務

Flexible PubSub messaging bus system for node and browser applications

JObserve is a replacement for the legacy java observer package, with support for object attributes and attribute listeners.

Group of WebSockets Routes (w/ Express.js WS library), that use Protobuf/JSON, some work as gRPC Client, have Rooms/Channels, query MongoDB or Redis Pub/Sub.

This is the MEGA event protocol. It aims to be a common protocol for all your event-streaming needs, regardless of platform.

Repository for the prototype for the publish-subscribe Petri net model

A SPARQL Event Processing Architecture

Spigot allows you to simply connect into any event stream to pull in and publish strongly typed objects rather than simple strings

AmPub can help abstract the specifics of publishing to some message broker. The envisioned use case is for an ambassador/adaptor container in a composite-container deployment.

Publish subscribe pattern implementation with Azure Service Bus.

Simple publish-subscribe pattern implementation

Listen for messages indicating the arrival of a new illumina run. When a new run arrives, create symbolic links (aka. 'symlinks') from .fastq.gz files in the run to a specific directory.

Simple signal pubsub framework in C

auth-service is a service to create a new user registration, login, token etc. We are using JWT to handle the token. This service will publish a message (rabbit event) after registering a new user. To publish the event, here is using Topic type, Exchange key and Routing key. So that, the consumer should consume the event/message with the exchang…

We have developed two jar files based on Apache Kafka that allow for the transmission and reception of images. The first jar file is the Producer jar file, which is used to send images to a Kafka broker. The second jar file is the Consumer jar file, which listens for incoming images and saves them to a file.

ModernEvents are async capable events that support both sync and async subscribers