GitHub topics: publish-subscribe

Repositories

halilbulentorhon/cb-pubsub

Modern Pub/Sub library using Couchbase, built with Go generics

Language: Go - Size: 43.9 KB - Last synced at: about 13 hours ago - Pushed at: about 16 hours ago - Stars: 2 - Forks: 0

eclipse-ecal/ecal

📦 eCAL - enhanced Communication Abstraction Layer. A high performance publish-subscribe, client-server cross-plattform middleware.

Language: C++ - Size: 119 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 942 - Forks: 197

mikey75/eventbus

Poor Man's Event Bus

Language: Java - Size: 58.6 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 1 - Forks: 0

Bondy is an open source, always-on and scalable application networking platform connecting all elements of a distributed application—offering service and event mesh capabilities combined. Bondy implements the open Web Application Messaging Protocol (WAMP) and is written in Erlang.

Language: Erlang - Size: 9.53 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 145 - Forks: 16

eclipse-iceoryx/iceoryx2

Eclipse iceoryx2™ - true zero-copy inter-process-communication in pure Rust

Language: Rust - Size: 9.05 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 1,638 - Forks: 81

na-trium-144/webcface

Web-based Communication Framework & Dashboard-like UI

Language: C++ - Size: 180 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 7 - Forks: 0

open62541/open62541

Open source implementation of OPC UA (OPC Unified Architecture) aka IEC 62541 licensed under Mozilla Public License v2.0

Language: C - Size: 59.7 MB - Last synced at: 9 days ago - Pushed at: 10 days ago - Stars: 2,876 - Forks: 1,342

krisleech/wisper

A micro library providing Ruby objects with Publish-Subscribe capabilities

Language: Ruby - Size: 319 KB - Last synced at: 2 days ago - Pushed at: about 1 year ago - Stars: 3,318 - Forks: 155

eclipse-iceoryx/meta-iceoryx2

Yocto Layer for Eclipse iceoryx2™

Language: BitBake - Size: 43.9 KB - Last synced at: 12 days ago - Pushed at: 13 days ago - Stars: 2 - Forks: 3

eclipse-ecal/rustecal

Idiomatic Rust bindings for eCAL.

Language: Rust - Size: 1.5 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 6 - Forks: 4

ZigRazor/JackRussell

A C++ Publish/Subscriber Library

Language: C++ - Size: 86.9 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 4 - Forks: 0

engineering87/WART

Transforms REST APIs into SignalR events, bringing real-time interaction to your applications.

Language: C# - Size: 687 KB - Last synced at: 1 day ago - Pushed at: 14 days ago - Stars: 16 - Forks: 1

2ndQuadrant/pglogical

Logical Replication extension for PostgreSQL 17, 16, 15, 14, 13, 12, 11, 10, 9.6, 9.5, 9.4 (Postgres), providing much faster replication than Slony, Bucardo or Londiste, as well as cross-version upgrades.

Language: C - Size: 1.84 MB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 1,145 - Forks: 165

nonlin-lin-chaos-order-et-more/local-community-fractal-routable-crossposter-system-called-knots

Size: 1.95 KB - Last synced at: 15 days ago - Pushed at: 16 days ago - Stars: 1 - Forks: 0

pjritee/pico_pedro_client

A micropython client for the Pedro publish-subscribe system.

Language: Python - Size: 33.2 KB - Last synced at: 8 days ago - Pushed at: 21 days ago - Stars: 0 - Forks: 0

nats-io/prometheus-nats-exporter

A Prometheus exporter for NATS metrics

Language: Go - Size: 10.7 MB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 426 - Forks: 155

nimbly/Syndicate

A powerful queue and pubsub message publisher and consumer framework.

Language: PHP - Size: 357 KB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 30 - Forks: 0

Dasync/Dasync

Every developer deserves the right of creating microservices without using any framework 🤍

Language: C# - Size: 3.31 MB - Last synced at: 13 days ago - Pushed at: about 2 years ago - Stars: 193 - Forks: 23

eclipse-iceoryx/iceoryx

Eclipse iceoryx™ - true zero-copy inter-process-communication

Language: C++ - Size: 22.2 MB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 1,880 - Forks: 438

nuwber/rabbitevents

Nuwber's RabbitEvents provides a simple observer implementation, allowing you to publishing and handling for various events that occur in your applications. For example, if you need to react to some event occurred in another API.

Language: PHP - Size: 18.1 MB - Last synced at: 9 days ago - Pushed at: 27 days ago - Stars: 120 - Forks: 35

konimarti/flow

Create simple flows based on user-defined filters (data stream processing).

Language: Go - Size: 90.8 KB - Last synced at: 7 days ago - Pushed at: about 6 years ago - Stars: 18 - Forks: 1

edward-jazzhands/ezpubsub

An ultra simple, modern pub/sub library and blinker alternative for Python

Language: Python - Size: 125 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

an-dr/pubsub-bus

Thread-safe one-to-many event system without garbage

Language: Rust - Size: 102 KB - Last synced at: 21 days ago - Pushed at: 4 months ago - Stars: 4 - Forks: 0

FIWARE/tutorials.Subscriptions

:blue_book: FIWARE 106: Subscribing to Changes in Context

Language: Shell - Size: 2.16 MB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 6 - Forks: 5

adrielcafe/broker

💬 Publish-Subscribe (a.k.a Pub/Sub, EventBus) library for Android and JVM built with Coroutines

Language: Kotlin - Size: 229 KB - Last synced at: 27 days ago - Pushed at: about 4 years ago - Stars: 99 - Forks: 9

Stiffstream/sobjectizer

An implementation of Actor, Publish-Subscribe, and CSP models in one rather small C++ framework. With performance, quality, and stability proved by years in the production.

Language: C++ - Size: 14.4 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 545 - Forks: 50

insikl/prometheus-nats-ambassador

Collect Prometheus exporter metrics over NATS message bus

Language: Go - Size: 50.8 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 1

wqking/eventpp

Event Dispatcher and callback list for C++

Language: C++ - Size: 872 KB - Last synced at: about 1 month ago - Pushed at: 9 months ago - Stars: 1,534 - Forks: 240

vaimee/SEPA

Get notifications about changes in your SPARQL endpoint.

Language: Java - Size: 34.8 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 30 - Forks: 10

peterbourgon/ps

Publish/subscribe utility

Language: Go - Size: 24.4 KB - Last synced at: 8 days ago - Pushed at: 3 months ago - Stars: 26 - Forks: 0

shawnfeng0/uorb

C++ inter-thread publish/subscribe middleware ported from PX4 and redesigned based on POSIX

Language: Python - Size: 858 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 66 - Forks: 15

Anton-Grebenkin/FlashEvents

In-memory event publishing library

Language: C# - Size: 66.4 KB - Last synced at: 16 days ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

emyzelium/emyzelium-rs

Another wrapper around ZeroMQ's Pub-Sub with Curve+ZAP, over Tor. Provides peers, each identified by public key, onion address, and port, that publish vec<vec<u8>> data under topics to which other peers subscribe to receive respective data. Rust version.

Language: Rust - Size: 56.6 KB - Last synced at: 18 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

semiversus/python-broqer

Carefully crafted library to operate with continuous streams of data in a reactive style with publish/subscribe, asyncio support and broker functionality.

Language: Python - Size: 851 KB - Last synced at: 14 days ago - Pushed at: 5 months ago - Stars: 74 - Forks: 6

arces-wot/SEPADocs

A set of documents in the form of W3C Unofficial Drafts

Language: HTML - Size: 2.44 MB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 1 - Forks: 1

RaphiaRa/spms_ring

Single publisher multiple subscriber ring buffer written in C

Language: C - Size: 69.3 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 4 - Forks: 0

endurodave/DelegateMQ

Invoke any C++ callable synchronously, asynchronously, or remotely using delegates.

Language: C++ - Size: 6.83 MB - Last synced at: about 2 months ago - Pushed at: 3 months ago - Stars: 15 - Forks: 2

mpostol/OPC-UA-OOI

Object Oriented Internet - C# deliverables supporting a new Machine To Machine (M2M) communication architecture

Language: C# - Size: 14.5 MB - Last synced at: 22 days ago - Pushed at: over 2 years ago - Stars: 143 - Forks: 33

ductranit/livedatabus

Making an Event Bus with LiveData

Language: Kotlin - Size: 138 KB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 20 - Forks: 8

alphanull/publisher

Publisher is a JavaScript Publish/Subscribe (Pub/Sub) library crafted to handle event-driven communication. Provides pub/sub functionality with extensive wildcard support, async/sync publishing, priority and invocation options, content based filtering & more.

Language: JavaScript - Size: 82 KB - Last synced at: 8 days ago - Pushed at: 2 months ago - Stars: 1 - Forks: 0

chandler767/Magic-Leap-Gesture-IoT-Example

Control lights in the physical world from the augmented world using hand gestures. Using Magic Leap Hand Poses (Gestures) and PubNub.

Language: C# - Size: 215 MB - Last synced at: about 2 months ago - Pushed at: almost 7 years ago - Stars: 22 - Forks: 5

jfversluis/Plugin.Maui.MessagingCenter

Plugin.Maui.MessagingCenter provides a drop-in compatible replacement for the deprecated .NET MAUI MessagingCenter.

Language: C# - Size: 190 KB - Last synced at: 1 day ago - Pushed at: 3 months ago - Stars: 16 - Forks: 5

twpayne/go-pubsub

Package pubsub is a simple publish-subscribe implementation using generics.

Language: Go - Size: 5.86 KB - Last synced at: 6 days ago - Pushed at: 11 months ago - Stars: 13 - Forks: 2

aelhometta/aelhometta

Archaic attempt at autonomous non-sandboxed distributed artificial life of assembler automaton type.

Language: Rust - Size: 315 KB - Last synced at: 18 days ago - Pushed at: about 1 year ago - Stars: 6 - Forks: 0

paritosh64ce/rxjs-pub-sub

:bell: Event publish - subscribe mechanism as JavaScript library using Observable. You can publish your event along with any data to all the subscribers of your event (event identification is being done using event-name as string).

Language: HTML - Size: 4.43 MB - Last synced at: 13 days ago - Pushed at: about 1 month ago - Stars: 24 - Forks: 5

SyntaxErrorLineNULL/nats-pubsub-go

nats-pubsub-go is a Go library that provides a simple and efficient interface for interacting with NATS, a lightweight, high-performance messaging system. This library simplifies the process of publishing and subscribing to messages on NATS subjects, making it easy to build scalable and distributed applications.

Language: Go - Size: 118 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

endurodave/StateMachineWithThreads

C++ State Machine with Asynchronous Callbacks

Language: C++ - Size: 269 KB - Last synced at: about 2 months ago - Pushed at: 3 months ago - Stars: 25 - Forks: 3

mchristou/topic-stream

Multi-topic publish-subscribe system in Rust with async support

Language: Rust - Size: 24.4 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 3 - Forks: 1

endurodave/MulticastCallback

Type-Safe Multicast Callbacks in C

Language: C - Size: 11.7 KB - Last synced at: 8 days ago - Pushed at: 3 months ago - Stars: 1 - Forks: 0

FIWARE/tutorials.LD-Subscriptions-Registrations

:blue_book: FIWARE 604. Linked Data Subscriptions and Registrations

Language: Shell - Size: 1.13 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 4 - Forks: 1

GGCIRILLO/Sistemi-Operativi-Unina

Esercizi e prove di esame svolte per l'esame di Sistemi Operativi @Unina con il Prof Domenico Cotroneo

Size: 11.7 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 1 - Forks: 0

m10k/toolbox

Module framework for Bash

Language: Shell - Size: 387 KB - Last synced at: 7 days ago - Pushed at: about 2 years ago - Stars: 72 - Forks: 5

hopsoft/local_bus

A lightweight pub/sub system for decoupled intra-process communication in Ruby applications

Language: Ruby - Size: 106 KB - Last synced at: 1 day ago - Pushed at: 3 months ago - Stars: 94 - Forks: 3

yoanesber/Spring-Boot-Redis-Stream-Producer

This Spring Boot REST API handles order payments using Redis Streams instead of Pub/Sub, offering a more reliable and scalable message-driven solution. Redis Streams retain messages until acknowledged, ensuring durability and preventing message loss when no consumers are available.

Language: Java - Size: 62.5 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

andrlange/mqtt5-demo

Complete MQTT5 demo with Mosquitto broker, Spring Boot REST publisher, and Dart subscriber featuring authentication, graceful shutdown, and real-time messaging

Language: Java - Size: 49.8 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

endurodave/AsyncMulticastDelegateCpp11

Asynchronous Multicast Delegates in C++11

Language: C++ - Size: 1.01 MB - Last synced at: about 2 months ago - Pushed at: 7 months ago - Stars: 5 - Forks: 4

literally-anything/DDSKit

A messaging and RPC library for both local and distributed systems in Swift built using FastDDS

Language: Swift - Size: 456 KB - Last synced at: 11 days ago - Pushed at: 5 months ago - Stars: 2 - Forks: 0

jakmeier/nuts

Nuts is a Rust library that offers a simple publish-subscribe API, featuring decoupled creation of the publisher and the subscriber.

Language: Rust - Size: 294 KB - Last synced at: 10 days ago - Pushed at: about 4 years ago - Stars: 68 - Forks: 1

Squadrick/shadesmar

Fast C++ IPC using shared memory

Language: C++ - Size: 445 KB - Last synced at: 4 months ago - Pushed at: about 3 years ago - Stars: 579 - Forks: 84

coreygirard/puppy

A pub/sub architecture genetically engineered to make your project simpler, not more complicated. And to be adorable.

Language: Python - Size: 64.5 KB - Last synced at: 19 days ago - Pushed at: 3 months ago - Stars: 14 - Forks: 0

LazyDoomSlayer/python-mqtt-simulation

A Python-based MQTT simulation tool for testing and experimenting with MQTT protocols in IoT and network environments.

Language: Python - Size: 31.3 KB - Last synced at: 3 months ago - Pushed at: 8 months ago - Stars: 1 - Forks: 0

lishank0119/pubsub

A lightweight internal Publish/Subscribe (Pub/Sub) system written in Go.

Language: Go - Size: 15.6 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0

m10k/foundry

A distributed package build system

Language: Shell - Size: 332 KB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 9 - Forks: 0

teivah/broadcast

Notification broadcaster library

Language: Go - Size: 185 KB - Last synced at: 4 months ago - Pushed at: over 3 years ago - Stars: 154 - Forks: 8

ononak/Smoke

Language: C++ - Size: 47.9 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0

jq-rs/mles-rs

Distributed publish-subscribe data service and Mles protocol reference implementation on Rust, Warp and Serde

Language: Rust - Size: 817 KB - Last synced at: 11 days ago - Pushed at: 5 months ago - Stars: 166 - Forks: 10

hoddmimes/Distributor

A Java low latency pub/sub framework using multicast, one-to-many with reliable delivery

Language: Java - Size: 37 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 3 - Forks: 1

ngljcb/px-publish-subscribe

Implements a Java publish/subscribe system where clients post or receive topic-specific messages via a server.

Language: Java - Size: 144 MB - Last synced at: 7 days ago - Pushed at: 9 months ago - Stars: 12 - Forks: 5

php-service-bus/service-bus

PHP Service Bus (publish-subscribe pattern) implementation

Language: PHP - Size: 2.8 MB - Last synced at: 23 days ago - Pushed at: 3 months ago - Stars: 349 - Forks: 18

thesharpninjas/Ninja.Sharp.OpenMessagingWrapper

A .NET library that abstracts messaging systems with unified interfaces, offering built-in connection recovery and failover for reliable communication in distributed environments.

Language: C# - Size: 106 KB - Last synced at: 22 days ago - Pushed at: 3 months ago - Stars: 4 - Forks: 0

eXpl0it3r/PubBus

A simple implementation of a MessageBus.

Language: C++ - Size: 300 KB - Last synced at: about 2 hours ago - Pushed at: over 1 year ago - Stars: 26 - Forks: 8

pyrustic/pyrustic

Collection of lightweight Python projects that share the same policy

Language: Python - Size: 498 KB - Last synced at: 4 days ago - Pushed at: over 2 years ago - Stars: 93 - Forks: 6

jfversluis/XFMessagingCenterSample 📦

Sample code to demonstrate how to work with the MessagingCenter in Xamarin.Forms

Language: C# - Size: 448 KB - Last synced at: 5 months ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 2

flolu/kafka

Realtime BTC and ETH Wallet Tracker with Node.js and Kafka

Language: TypeScript - Size: 290 KB - Last synced at: 4 months ago - Pushed at: over 2 years ago - Stars: 26 - Forks: 14

f-str/radishmq

Fast and lightweight message broker written in Rust.

Language: Rust - Size: 250 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 2 - Forks: 0

eclipse-ecal/tcp_pubsub

📦 TCP based publish-subscribe library for C++ 🌐

Language: C++ - Size: 177 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 42 - Forks: 20

dzaliznyak/Meta.Lib

A set of classes and modules for .Net development

Language: C# - Size: 208 KB - Last synced at: 10 days ago - Pushed at: 7 months ago - Stars: 16 - Forks: 4

georapbox/PubSub

Javascript implementation of the Publish/Subscribe pattern.

Language: JavaScript - Size: 506 KB - Last synced at: 1 day ago - Pushed at: about 2 months ago - Stars: 30 - Forks: 8

tommasobertoni/Iris.NET

TCP-based, Pub/Sub C# library.

Language: C# - Size: 235 KB - Last synced at: 20 minutes ago - Pushed at: about 6 years ago - Stars: 12 - Forks: 6

alexeyraspopov/newsletter

Observer done right

Language: JavaScript - Size: 40 KB - Last synced at: 6 days ago - Pushed at: 10 months ago - Stars: 14 - Forks: 1

addu390/django-kafka

Python Django as Producer and Consumer using Apache Kafka for content queue and Celery for task queue

Language: Python - Size: 29.3 KB - Last synced at: 18 days ago - Pushed at: almost 5 years ago - Stars: 60 - Forks: 22

marein/php-nchan-client

A PHP https://nchan.io client.

Language: PHP - Size: 207 KB - Last synced at: 25 days ago - Pushed at: 5 months ago - Stars: 13 - Forks: 0

ng-eneter/eneter-net

Lightweight framework for interprocess communication for .NET platforms.

Language: C# - Size: 7.26 MB - Last synced at: 23 days ago - Pushed at: over 3 years ago - Stars: 14 - Forks: 5

MicahParks/websocket-pubsub 📦

An in-memory HTTP websocket publish-subscribe system written in Golang.

Language: Go - Size: 48.8 KB - Last synced at: 5 months ago - Pushed at: 12 months ago - Stars: 10 - Forks: 3

apstory/apstory-lib-angular

Apstory Angular 7 Libraries

Language: TypeScript - Size: 9.99 MB - Last synced at: 29 days ago - Pushed at: 6 months ago - Stars: 0 - Forks: 1

wqking/eventpy

Event Dispatcher and callback list for Python

Language: Python - Size: 151 KB - Last synced at: 2 months ago - Pushed at: over 5 years ago - Stars: 46 - Forks: 7

PubNubDevelopers/chat-component-app-live-support

Live support chat featuring reusable chat components.

Language: TypeScript - Size: 803 KB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 9 - Forks: 6

jpmikkers/Baksteen.Async.ModernEvents

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

Language: C# - Size: 101 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

vpatel95/MesApp

This is a basic web-application based messaging app with functionality of personal and group chats. It enables user to chat with registered users and also create groups. Application is developed using Laravel along with MySQL (Eloquent ORM). The searching is powered by ElasticSearch. It is used on the top of Eloqurnt ORM to ensure continuous searching service.

Language: PHP - Size: 1.01 MB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 2 - Forks: 0