Java Kafka producer for streaming order events using Avro and Confluent Schema Registry.

Async rabbitmq reports producer server for cdc-microservices

Nodejs aplicacion to publish messages to rabbitmq via postgresql notify

Java service for Tuya Open MQ SDK. Built on Eclipse Temurin for real-time IoT device messaging.

a flask web app to generate mqtt clients (emqx)

Bridges a Victron Cerbo GX local MQTT broker to a downstream broker, with remapping of topic tree

BROKA is a self-hosted operations console for message brokers.

opclabs/opccmd

opclabs

Perform OPC operations from command line. Acts as Client, Server, or PubSub. OPC UA, OPC XML-DA, ...

Broker to support backstage event hub

Durable change feeds for PostgreSQL, powered by logical replication.

OITC Access Control System: service that logs all access attempts to the OpenSearch database.

Receives messages from one MQTT topic and re-publishes them on one or many other topics.

OITC Access Control System: service to send access notifications via pushover.

OITC Access Control System: service to send access notifications by mail.

Fair job queue on Redis: REST/WebSocket/TCP API, retries, archive, live dashboard.

Telegram bot forwarding updates to Kafka or RabbitMQ, configurable via env, no code needed.

Testing pulsar images

Qpid Java AMQP Broker

taskqueue-manager provides management dashboard for taskqueue-go

Transparent Ed25519 signing and verification for CloudEvents on Knative.

Tinode chat server with onesignal push

Powerful single binary, zero-dependency job queue server

xk6 Kafka

Exaland Offer Push Notification with Google Service Config File

OITC Access Control System: service that controls the door relays.

RabbitMQ with message deduplication plugin for reliable, duplicate-free messaging.

Project:Real-time Chat