Go Messaging

DISCONTINUED. Sarama is a Go library for Apache Kafka. [Moved to: https://github.com/IBM/sarama]

Simple, reliable, and efficient distributed task queue in Go

Machinery is an asynchronous task queue/job queue based on distributed message passing.

Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably. Set up once and forever.

DISCONTINUED. Fancy stream processing made operationally mundane [Moved to: https://github.com/redpanda-data/connect]

A push notification server written in Go (Golang).

Building event-driven applications the easy way in Go.

Golang client for NATS, the cloud native messaging system.

Golang client for NATS, the cloud native messaging system.

Confluent's Apache Kafka Golang client

🪽 An open, easy, fast, reliable and battery-efficient solution for real-time communications

⚡ HTTP/2 Apple Push Notification Service (APNs) push provider for Go — Send push notifications to iOS, tvOS, Safari and OSX apps, using the APNs HTTP/2 protocol.

Golang push server cluster

The official Go package for NSQ

[Go] Lightweight eventbus with async compatibility for Go

Uniqush is a free and open source software system which provides a unified push service for server side notification to apps on mobile devices.

An AMQP 0-9-1 Go client maintained by the RabbitMQ team. Originally by @streadway: `streadway/amqp`

A Go interface to ZeroMQ version 4

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

Native Go bindings for D-Bus

An n:m message multiplexer written in Go

mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"

PingMe is a CLI which provides the ability to send messages or alerts to multiple messaging platforms & email.

Emits events in Go way, with wildcard, predicates, cancellation possibilities and many other good wins

A simple pubsub package for go.

Home of Quamina, a fast pattern-matching library in Go

A generic oplog/replication system for microservices

🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit

Go simple async message bus

RabbitMQ wire tap and swiss army knife

redisqueue provides a producer and consumer of a queue that uses Redis streams

websocket based messaging server written in golang

A tiny wrapper over amqp exchanges and queues 🚌 ✨

A lightweight transactional message bus on top of RabbitMQ

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

:mega: Pure nodejs EventEmmiter for the Go Programming Language.

Sending line notifications using a binary, docker or Drone CI.

A tiny wrapper around NSQ topic and channel :rocket:

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.

RapidMQ is a pure, extremely productive, lightweight and reliable library for managing of the local messages queue

Package notify provides an implementation of the Gnome DBus Notifications Specification.

The implementation of the pattern observer

RES Service protocol library for Go

Build event-driven and event streaming applications with ease

🐇 CLI tool for websockets and Go package

Publish and subscribe functionality within a single process in Go.

golang client library to Viessmann Vitotrol web service

Parked: PubSub queuing with long-polling subscribers (not bound to http)

Go client to reliable queues based on Redis Cluster Streams

A library for scheduling when to dispatch a message to a channel

Abstraction layer for simple rabbitMQ connection, messaging and administration

RabbitMQ Reconnection client

Gaurun Client written in Go

DISCONTINUED. mob is a generic-based, simple mediator / event aggregator Golang library. It supports in-process requests / events processing.

Event Bus package for Go

Send message to Slack, just providing webhook url.

Send message to Slack, just providing webhook url.