jq-rs/mles-rs

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

Language: Rust - Size: 628 KB - Last synced: about 16 hours ago - Pushed: about 17 hours ago - Stars: 155 - Forks: 9

apstory/apstorymq

Lightweight Topic-based Restful Messaging API

Language: C# - Size: 304 KB - Last synced: about 19 hours ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

apstory/apstorymq-client-dotnet

.NET Standard C# Client for ApstoryMQ

Language: C# - Size: 14.6 KB - Last synced: about 19 hours ago - Pushed: almost 4 years ago - Stars: 2 - Forks: 0

eclipse-ecal/ecal-core

📦 eCAL C/C++ runtime core

Language: C++ - Size: 2.02 MB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 8 - Forks: 3

byte-chaos/mqtt-wildcard-publish

Enable MQTT Wildcard Publish.

Language: Java - Size: 72.3 KB - Last synced: 2 days ago - Pushed: 5 months ago - Stars: 1 - Forks: 0

engineering87/WART

Turns WebApi calls into SignalR events

Language: C# - Size: 580 KB - Last synced: 2 days ago - Pushed: 3 days ago - Stars: 6 - Forks: 0

FIWARE/tutorials.Subscriptions

:blue_book: FIWARE 106: Subscribing to Changes in Context

Language: Shell - Size: 2.11 MB - Last synced: 4 days ago - Pushed: 4 days ago - Stars: 4 - Forks: 5

f-str/radishmq

Fast and lightweight message broker written in Rust.

Language: Rust - Size: 198 KB - Last synced: 4 days ago - Pushed: 4 days ago - Stars: 2 - Forks: 0

2ndQuadrant/pglogical

Logical Replication extension for PostgreSQL 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.79 MB - Last synced: 4 days ago - Pushed: 4 days ago - Stars: 935 - Forks: 150

kavishkamk/BiddingSystem

This bidding system was created using java and used client sever and publisher subscriber architectures

Language: Java - Size: 1.84 MB - Last synced: 5 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

Benawi/Message-Oranted-comminicatio-JMS

Message Oranted comminication impimantaion with JMS API

Language: Java - Size: 35.2 KB - Last synced: 5 days ago - Pushed: about 1 year ago - Stars: 2 - Forks: 0

jimfilippou/distributed

A multi-threaded, distributed publish-subscribe system ☕️

Language: Kotlin - Size: 4.81 MB - Last synced: 6 days ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

krisleech/wisper

A micro library providing Ruby objects with Publish-Subscribe capabilities

Language: Ruby - Size: 294 KB - Last synced: 5 days ago - Pushed: about 2 months ago - Stars: 3,229 - Forks: 149

Israiloff/broker

JMS broker plugin

Language: Java - Size: 84 KB - Last synced: 7 days ago - Pushed: 7 days ago - Stars: 0 - Forks: 0

chandler767/Space-Race

Multiplayer, real-time, and cross platform racing game powered by PubNub

Language: Go - Size: 3.68 MB - Last synced: 7 days ago - Pushed: almost 5 years ago - Stars: 12 - Forks: 3

chandler767/Go-WASM-Chat

Example of a realtime Golang WASM chat app using PubNub in a minimal amount of code.

Language: JavaScript - Size: 2.38 MB - Last synced: 7 days ago - Pushed: over 4 years ago - Stars: 0 - Forks: 1

wamp-proto/wamp-proto

The Web Application Messaging Protocol

Language: Makefile - Size: 70.4 MB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 464 - Forks: 100

bondy-io/bondy

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.7 MB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 109 - Forks: 12

BCCDC-PHL/subscribe-and-symlink-illumina

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.

Language: Python - Size: 1.95 KB - Last synced: 9 days ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

BCCDC-PHL/illumina-run-publisher

Watch directories for the creation of illumina sequencer outputs. When detected, publish messages with details of the run to a TCP socket.

Language: Python - Size: 64.5 KB - Last synced: 9 days ago - Pushed: over 3 years ago - Stars: 1 - Forks: 0

eclipse-ecal/ecal

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

Language: C++ - Size: 80.2 MB - Last synced: 11 days ago - Pushed: 11 days ago - Stars: 771 - Forks: 160

keypup-io/cloudenvoy

Cross-application messaging for Ruby and Rails using Google Cloud Pub/Sub

Language: Ruby - Size: 223 KB - Last synced: 10 days ago - Pushed: 11 days ago - Stars: 34 - Forks: 9

nats-io/prometheus-nats-exporter

A Prometheus exporter for NATS metrics

Language: Go - Size: 10.7 MB - Last synced: 15 days ago - Pushed: 19 days ago - Stars: 350 - Forks: 130

alincc/angular-pubsub

Angular Publish Subscribe with custom Inject

Language: TypeScript - Size: 76.2 KB - Last synced: 12 days ago - Pushed: about 7 years ago - Stars: 0 - Forks: 0

twpayne/go-pubsub

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

Language: Go - Size: 1000 Bytes - Last synced: 11 days ago - Pushed: 14 days ago - Stars: 1 - Forks: 1

BillyWei01/LightEvent

A lightweight event bus base on Android platform

Language: Kotlin - Size: 85.9 KB - Last synced: 12 days ago - Pushed: about 1 year ago - Stars: 1 - Forks: 0

arces-wot/SEPADocs

A set of documents in the form of W3C Unofficial Drafts

Language: HTML - Size: 1.7 MB - Last synced: 12 days ago - Pushed: 6 months ago - Stars: 1 - Forks: 1

wkennedy/pubsubly

Pubsubly is an application to track messages as they flow through a pub/sub backed message driven architecture.

Language: Java - Size: 2.89 MB - Last synced: 13 days ago - Pushed: over 1 year ago - Stars: 1 - Forks: 1

ivandotv/estacion

Event bus implementation based on native node events. Also works in the browser.

Language: TypeScript - Size: 840 KB - Last synced: 13 days ago - Pushed: 13 days ago - Stars: 18 - Forks: 4

alaz/camel-pubsub 📦

Beware of publish-subscribe in Apache Camel

Language: Scala - Size: 223 KB - Last synced: 13 days ago - Pushed: about 10 years ago - Stars: 0 - Forks: 0

eclipse-iceoryx/iceoryx2

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

Language: Rust - Size: 1.31 MB - Last synced: 14 days ago - Pushed: 15 days ago - Stars: 328 - Forks: 15

open62541/open62541

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

Language: C - Size: 51.8 MB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 2,408 - Forks: 1,174

techerfan/panda

A module for simplifying the use of WebSocket.

Language: Go - Size: 73.2 KB - Last synced: 22 days ago - Pushed: 22 days ago - Stars: 2 - Forks: 0

eclipse-iceoryx/iceoryx

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

Language: C++ - Size: 21.7 MB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 1,481 - Forks: 357

na-trium-144/webcface

Web-based RPC & UI Library

Language: C++ - Size: 50.9 MB - Last synced: 16 days ago - Pushed: 16 days ago - Stars: 4 - Forks: 1

behrad/mom

Message Oriented Middleware playground

Language: JavaScript - Size: 72.3 KB - Last synced: 14 days ago - Pushed: over 6 years ago - Stars: 4 - Forks: 0

kokoro-rs/kokoro

A highly extensible Rust-based meta-framework designed for building decoupled and maintainable applications.

Language: Rust - Size: 174 KB - Last synced: 5 days ago - Pushed: 5 days ago - Stars: 29 - Forks: 0

aelhometta/aelhometta

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

Language: Rust - Size: 246 KB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 2 - Forks: 0

paritosh64ce/rxjs-pub-sub

:bell: Event publish - subscribe mechanism as Angular service 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: TypeScript - Size: 1.9 MB - Last synced: 15 days ago - Pushed: 16 days ago - Stars: 22 - Forks: 5

HBM/node-jet

Realtime Message Bus for the Web. Javascript Implementation

Language: TypeScript - Size: 1.73 MB - Last synced: 13 days ago - Pushed: 5 months ago - Stars: 169 - Forks: 27

php-service-bus/service-bus

PHP Service Bus (publish-subscribe pattern) implementation

Language: PHP - Size: 2.77 MB - Last synced: 15 days ago - Pushed: about 2 years ago - Stars: 347 - Forks: 23

naufalhilmiaji/dss-incomm

Distributed System - Indirect Communication - Python

Language: Jupyter Notebook - Size: 5.02 MB - Last synced: 20 days ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0

Cap32/subscribable-value

Subscribable value

Language: JavaScript - Size: 59.6 KB - Last synced: 21 days ago - Pushed: over 6 years ago - Stars: 1 - Forks: 0

pandeptwidyaop/gorabbit

RabbitMQ simple library for Go

Language: Go - Size: 22.5 KB - Last synced: 21 days ago - Pushed: 22 days ago - Stars: 2 - Forks: 2

kxcontrib/websocket Fork of mgracey/websocket

Code to accompany the kdb+ and WebSockets whitepaper

Language: HTML - Size: 8.79 KB - Last synced: 21 days ago - Pushed: about 6 years ago - Stars: 4 - Forks: 5

srinikhil-07/Notarization-With-Combine

CLI tool based on Combine framework for notarizing macOS software.

Language: Swift - Size: 25.4 KB - Last synced: 21 days ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

RaphiaRa/spms_ring

Single publisher multiple subscriber ring buffer written in C

Language: C - Size: 82 KB - Last synced: 24 days ago - Pushed: 24 days ago - Stars: 4 - Forks: 0

eXpl0it3r/PubBus

A simple implementation of a MessageBus.

Language: C++ - Size: 300 KB - Last synced: 12 days ago - Pushed: 2 months ago - Stars: 24 - Forks: 7

MarcoFontana48/GoogleChubby

Implementation of Google's Chubby distributed file system in Java using Raft consensus algorithm

Language: Java - Size: 921 KB - Last synced: 23 days ago - Pushed: 23 days ago - Stars: 1 - Forks: 0

m10k/foundry

A distributed package build system

Language: Shell - Size: 332 KB - Last synced: 29 days ago - Pushed: 29 days ago - Stars: 5 - Forks: 0

m10k/toolbox

Module framework for Bash

Language: Shell - Size: 387 KB - Last synced: 20 days ago - Pushed: 9 months ago - Stars: 59 - Forks: 2

georapbox/PubSub

Javascript implementation of the Publish/Subscribe pattern.

Language: JavaScript - Size: 479 KB - Last synced: 15 days ago - Pushed: over 1 year ago - Stars: 29 - Forks: 8

wqking/eventpy

Event Dispatcher and callback list for Python

Language: Python - Size: 151 KB - Last synced: 14 days ago - Pushed: about 4 years ago - Stars: 38 - Forks: 7

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: about 22 hours ago - Pushed: about 1 year ago - Stars: 140 - Forks: 33

daalvand/pub-sub

This package used to publish and subscribe with Regis or Kafka

Language: PHP - Size: 7.81 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

ng-eneter/eneter-net

Lightweight framework for interprocess communication for .NET platforms.

Language: C# - Size: 7.26 MB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 12 - Forks: 5

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.3 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 446 - Forks: 45

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: 13 days ago - Pushed: over 2 years ago - Stars: 93 - Forks: 8

davisouzaluna/Demoweek-2023-1-Sistemas-Distribuidos

Apresentação da Demoweek 2023.1

Language: C++ - Size: 13.7 KB - Last synced: about 1 month ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

gregwhitaker/pubnub-channelgroup-example

Example of using PubNub Channel Groups

Language: Java - Size: 69.3 KB - Last synced: about 1 month ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

gregwhitaker/pubnub-example

Example of using PubNub to publish and subscribe to messages

Language: Java - Size: 63.5 KB - Last synced: about 1 month ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

gregwhitaker/nats-pubsub-example

An example of using NATS for pubsub messaging

Language: Java - Size: 90.8 KB - Last synced: about 1 month ago - Pushed: over 6 years ago - Stars: 2 - Forks: 0

teivah/broadcast

Notification broadcaster library

Language: Go - Size: 185 KB - Last synced: 9 days ago - Pushed: almost 2 years ago - Stars: 146 - Forks: 7

divyanshu-rawat/Publish-Subscribe

This repository demonstrates use of Publish Subscibe design pattern in Ng Js.

Language: JavaScript - Size: 112 KB - Last synced: about 1 month ago - Pushed: almost 7 years ago - Stars: 0 - Forks: 0

rush2sk8/Intel-Edison-PS 📦

Testing PS for Intel edison Boards

Language: JavaScript - Size: 278 MB - Last synced: about 1 month ago - Pushed: over 5 years ago - Stars: 2 - Forks: 2

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: 10.5 MB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 120 - Forks: 36

privacylab/talek

a Private Publish Subscribe System

Language: Go - Size: 891 KB - Last synced: 10 days ago - Pushed: about 1 month ago - Stars: 44 - Forks: 5

wqking/eventpp

Event Dispatcher and callback list for C++

Language: C++ - Size: 849 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 1,184 - Forks: 201

dzaliznyak/Meta.Lib

A set of classes and modules for .Net development

Language: C# - Size: 291 KB - Last synced: about 5 hours ago - Pushed: 3 months ago - Stars: 13 - Forks: 5

0exp/evil_events

Ultra simple, but very flexible and fully customizable event subsystem for ruby applications with a wide set of customization interfaces and smart event definition DSL.

Language: Ruby - Size: 394 KB - Last synced: 2 days ago - Pushed: about 1 year ago - Stars: 8 - Forks: 2

pyrustic/pyrustic

Collection of lightweight Python projects that share the same policy

Language: Python - Size: 498 KB - Last synced: about 2 months ago - Pushed: about 1 year ago - Stars: 91 - Forks: 6

bredele/zeroin

The only Event Emitter you need

Language: JavaScript - Size: 44.9 KB - Last synced: 15 days ago - Pushed: over 5 years ago - Stars: 20 - Forks: 2

vaimee/SEPA

Get notifications about changes in your SPARQL endpoint.

Language: Java - Size: 33.9 MB - Last synced: about 16 hours ago - Pushed: about 1 month ago - Stars: 26 - Forks: 10

perfectsquircle/pg_mq

A simple asynchronous message queue for PostgreSQL

Language: PLpgSQL - Size: 47.9 KB - Last synced: 12 days ago - Pushed: 4 months ago - Stars: 11 - Forks: 1

wagnerjfr/bingo-game-publisher-subscriber

Mary, John, Mark, Ana and Paul try their luck in a Bingo. Who is going to win?

Language: Java - Size: 18.6 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

affinity4/magic

Magic Trait used to easily add event listeners, spelling suggestions in errors and Javascript __set and __get style setters an getters to any class. Magic!

Language: PHP - Size: 61.5 KB - Last synced: 10 days ago - Pushed: 2 months ago - Stars: 1 - Forks: 0

ly3too/async-plugin-based-app

Language: Python - Size: 6.84 KB - Last synced: 3 months ago - Pushed: about 5 years ago - Stars: 0 - Forks: 0

apstory/apstory-lib-angular

Apstory Angular 7 Libraries

Language: TypeScript - Size: 9.4 MB - Last synced: about 22 hours ago - Pushed: 4 months ago - Stars: 0 - Forks: 1

emyzelium/emyzelium-go

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 [][]byte data under topics to which other peers subscribe to receive respective data. Go version.

Language: Go - Size: 50.8 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

eclipse-ecal/tcp_pubsub

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

Language: C++ - Size: 103 KB - Last synced: 2 days ago - Pushed: 3 days ago - Stars: 34 - Forks: 18

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: 25 days ago - Pushed: almost 3 years ago - Stars: 64 - Forks: 2

ductranit/livedatabus

Making an Event Bus with LiveData

Language: Kotlin - Size: 138 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 18 - Forks: 6

Jiu-xiao/OneMessage

一个基于发布-订阅模型的多线程消息框架，用于嵌入式平台，纯C实现，性能和灵活性极高

Language: C - Size: 354 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 38 - Forks: 9

alessandro-caldonazzi/ws-redis 📦

Introduce channels, groups and user tracking in websocket. Scale horizontally using redis as publish-subscribe

Language: JavaScript - Size: 413 KB - Last synced: 27 days ago - Pushed: almost 3 years ago - Stars: 4 - Forks: 0

GoncaloPascoal/sdle-proj1

Reliable publish/subscribe service implemented on top of ZeroMQ. First project of the Large-Scale Distributed Systems curricular unit.

Language: Python - Size: 298 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - 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: 831 KB - Last synced: about 1 month ago - Pushed: 3 months ago - Stars: 73 - Forks: 6

iulianoroberto/JMS_MultiUserChat

Multi user chat as distributed application implemented by Java Message Service (JMS).

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

komputronika/SocketServerPubSub

Script socket server sederhana publish dan subscribe dengan format JSON terinspirasi oleh MQTT untuk keperluan IoT

Language: PHP - Size: 67.4 KB - Last synced: 3 months ago - Pushed: about 5 years ago - Stars: 2 - Forks: 2

emitter-io/go

Go/Golang client for emitter

Language: Go - Size: 4.6 MB - Last synced: 3 months ago - Pushed: about 1 year ago - Stars: 65 - Forks: 80

Rebirth-Project/ufo-event-bus

UFO EventBus: Ultra Fast Object-Oriented Event Bus for Java and Android.

Language: Java - Size: 2.33 MB - Last synced: 29 days ago - Pushed: 29 days ago - Stars: 10 - Forks: 0

insikl/prometheus-nats-ambassador

Collect Prometheus exporter metrics over NATS message bus

Language: Go - Size: 26.4 KB - Last synced: about 1 month ago - Pushed: 2 months ago - Stars: 0 - Forks: 1

chop-dbhi/eda

eda is a library for implementing event-driven architectures.

Language: Go - Size: 75.2 KB - Last synced: 13 days ago - Pushed: over 6 years ago - Stars: 32 - Forks: 3

mg-kh/event-bus-react

This hook can carry events across the app.

Language: JavaScript - Size: 68.4 KB - Last synced: about 14 hours ago - Pushed: about 1 year ago - Stars: 6 - Forks: 0

tommyskeff/JObserve

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

Language: Java - Size: 23.4 KB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 2 - Forks: 0

n89nanda/pyeventbus

Python Eventbus

Language: Python - Size: 328 KB - Last synced: 2 days ago - Pushed: about 4 years ago - Stars: 17 - Forks: 6

petar-m/EventBroker

An implementation of in-memory multi-threaded event broker.

Language: C# - Size: 75.2 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 5 - Forks: 1

ReactiveSets/toubkal

Fully reactive programming for nodejs and the browser

Language: JavaScript - Size: 12.1 MB - Last synced: 18 days ago - Pushed: about 1 year ago - Stars: 71 - Forks: 13

elkodon/elkodon 📦

Elkodon - true zero-copy inter-process-communication in rust

Language: Rust - Size: 990 KB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 13 - Forks: 3

Squadrick/shadesmar

Fast C++ IPC using shared memory

Language: C++ - Size: 445 KB - Last synced: 4 months ago - Pushed: over 1 year ago - Stars: 493 - Forks: 76

konimarti/flow

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

Language: Go - Size: 90.8 KB - Last synced: about 2 months ago - Pushed: almost 5 years ago - Stars: 16 - Forks: 1