Open-source alternatives to GoEventBus

Chanify is a safe and simple notification tools. This repository is command line tools for Chanify.

Declare AMQP entities like queues, producers, and consumers in a declarative way. Can be used to work with RabbitMQ.

💨 A real time messaging system to build a scalable in-app notifications, multiplayer games, chat apps in web and mobile apps.

Confluent's Apache Kafka Golang client

A simple pubsub package for go.

A generic oplog/replication system for microservices

Glue - Robust Go and Javascript Socket Library (Alternative to Socket.io)

Mercure is an HTTP-based message broker and real-time pub/sub server that routes asynchronous data updates to authorized subscribers. It functions as a centralized hub that receives data via standard HTTP requests and broadcasts it to web clients using the Server-Sent Events protocol. The project distinguishes itself by replacing WebSockets with a unidirectional HTTP connection, leveraging HTTP/2 and HTTP/3 for multiplexed, low-latency delivery. It implements a secure access control layer using JSON Web Tokens and JSON Web Signatures to validate the identity of publishers and subscribers, and

Lightweight library that handles RabbitMQ auto-reconnect and publishing retry routine for you.

Native Go bindings for D-Bus

GCM library for Go.

A Simplest Storage-Agnostic and Zero-dep Message Queue for Your Concurrent Go Program

Asynq is a distributed background job processing framework for Go applications. It manages asynchronous task queues by offloading heavy operations to persistent storage, allowing the main application to remain responsive while background workers handle workloads. The system utilizes Redis to manage task state, concurrency, and message distribution across multiple worker instances. It employs atomic Lua scripting and sorted sets to ensure reliable job acquisition, precise scheduling of delayed tasks, and fault-tolerant processing through a two-stage acknowledgement flow. The framework support

Ratus is a RESTful asynchronous task queue server. It translated concepts of distributed task queues into a set of resources that conform to REST principles and provides a consistent HTTP API for various backends.

Sarama is an Apache Kafka Go client library that provides native support for the Kafka protocol. It includes a protocol client for managing offsets and timestamps, a producer implementation for sending messages, and a consumer group coordinator to balance workloads across multiple instances. The library enables high throughput data streaming through concurrent message production and maintains strict partition ordering during network retries. It supports secure communication with Kafka brokers using certificate-based encryption to protect data traffic. The project covers a broad range of dist

RabbitMQ wire tap and swiss army knife

golang long polling library. Makes web pub-sub easy via HTTP long-poll servers and clients :smiley: :coffee: :computer:

Build event-driven and event streaming applications with ease

RES Service protocol library for Go

Go client to reliable queues based on Redis Cluster Streams

:incoming_envelope: A fast Message/Event Hub using publish/subscribe pattern with support for topics like* rabbitMQ exchanges for Go applications

🐇 CLI tool for websockets and Go package

golang client library to Viessmann Vitotrol web service

🚃 A library for handling mediator patterns and simplified CQRS patterns within an event-driven architecture, inspired by csharp MediatR library.

The implementation of the pattern observer